Package

io.radanalytics.silex.rdd

cascade

Permalink

package cascade

Visibility
  1. Public
  2. All

Type Members

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

    Permalink

    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

    Permalink

Value Members

  1. object implicits

    Permalink

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

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

    import io.radanalytics.silex.rdd.cascade.implicits._
    
    rdd.cascadePartitions(cascadingFunction)

Ungrouped