package rdd

  1. Public
  2. All

Type Members

  1. class CoGroupedRDD[K] extends RDD[(K, Seq[Seq[_]])] with Logging

  2. class CoalescedRDD[T] extends RDD[T]

    Coalesce the partitions of a parent RDD (prev) into fewer partitions, so that each partition of this RDD computes one or more of the parent ones.

  3. class HadoopRDD[K, V] extends RDD[(K, V)]

    An RDD that reads a Hadoop dataset as specified by a JobConf (e.

  4. class NewHadoopRDD[K, V] extends RDD[(K, V)]

  5. class PipedRDD[T] extends RDD[String]

    An RDD that pipes the contents of each parent partition through an external command (printing them one per line) and returns the output as a collection of strings.

  6. class RepartitionShuffledRDD[K, V] extends ShuffledRDD[K, V, V]

    Repartition a key-value pair RDD.

  7. class SampledRDD[T] extends RDD[T]

  8. class ShuffledAggregatedRDD[K, V, C] extends ShuffledRDD[K, V, C]

    The resulting RDD from shuffle and running (hash-based) aggregation.

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

    The resulting RDD from a shuffle (e.

  10. class ShuffledSortedRDD[K, V] extends RepartitionShuffledRDD[K, V]

    A sort-based shuffle (that doesn't apply aggregation).

  11. class UnionRDD[T] extends RDD[T] with Serializable

Value Members

  1. object PipedRDD extends Serializable