package cascade

  1. Public
  2. All

Type Members

  1. class CascadeRDD[T, U] extends RDD[U]

    Represents the concept of a series of RDDs with cascaded dependencies, where the partition of each cascade is a function of the previous cascade and an input RDD partition.

  2. class CascadeRDDFunctions[T] extends Serializable

Value Members

  1. object implicits

    Implicit conversion to CascadeRDDFunctions to enrich RDDs with the cascadePartitions method.