rdd

Type Members

1. class AsyncRDDActions[T] extends Serializable with Logging

   A set of asynchronous RDD actions available through an implicit conversion.

2. class CoGroupedRDD[K] extends RDD[(K, Array[Iterable[_]])]

   :: DeveloperApi :: A RDD that cogroups its parents.

3. class DoubleRDDFunctions extends Logging with Serializable

   Extra functions available on RDDs of Doubles through an implicit conversion.

4. class HadoopRDD[K, V] extends RDD[(K, V)] with Logging

   :: DeveloperApi :: An RDD that provides core functionality for reading data stored in Hadoop (e.

5. class JdbcRDD[T] extends RDD[T] with Logging

   An RDD that executes an SQL query on a JDBC connection and reads results.

6. class NewHadoopRDD[K, V] extends RDD[(K, V)] with SparkHadoopMapReduceUtil with Logging

   :: DeveloperApi :: An RDD that provides core functionality for reading data stored in Hadoop (e.

7. class OrderedRDDFunctions[K, V, P <: Product2[K, V]] extends Logging with Serializable

   Extra functions available on RDDs of (key, value) pairs where the key is sortable through an implicit conversion.

8. class PairRDDFunctions[K, V] extends Logging with SparkHadoopMapReduceUtil with Serializable

   Extra functions available on RDDs of (key, value) pairs through an implicit conversion.

9. class PartitionPruningRDD[T] extends RDD[T]

   :: DeveloperApi :: A RDD used to prune RDD partitions/partitions so we can avoid launching tasks on all partitions.

10. abstract class RDD[T] extends Serializable with Logging

    A Resilient Distributed Dataset (RDD), the basic abstraction in Spark.

11. class SequenceFileRDDFunctions[K, V] extends Logging with Serializable

    Extra functions available on RDDs of (key, value) pairs to create a Hadoop SequenceFile, through an implicit conversion.

12. class ShuffledRDD[K, V, C] extends RDD[(K, C)]

    :: DeveloperApi :: The resulting RDD from a shuffle (e.

13. class UnionRDD[T] extends RDD[T]

    Annotations

    @DeveloperApi()