Package

io.radanalytics.silex.rdd

cascade

Permalink

package cascade

Visibility

Public
All

Type Members

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.
class CascadeRDDFunctions[T] extends Serializable

Value Members

object implicits

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