rdd

Value Members

1. def cache[A](rdd: RDD[A]): RDD[A]

   

   cache() the specified RDD

   cache() the specified RDD

   returns

   the input RDD, after calling cache()

2. object docs

   

   Stub object necessary due to https://issues.scala-lang.org/browse/SI-8124

   Stub object necessary due to https://issues.scala-lang.org/browse/SI-8124

   Documentation for ops.core.rdd can be found at software.uncharted.sparkpipe.ops.core.rdd

   Attributes

   protected[this]

   See also

   software.uncharted.sparkpipe.ops.core.rdd

3. package io

   

   Input/output operations for RDDs, based on the SparkContext.textFile API

4. def toDF[A <: Product](sparkSession: SparkSession)(rdd: RDD[A])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A]): DataFrame

   

   Convert a suitable RDD to a DataFrame

   Convert a suitable RDD to a DataFrame

   A

   The record type of the RDD. Must be <: Product

   sparkSession

   a SparkSession

   rdd

   the input RDD

   returns

   a DataFrame constructed from rdd