| Class | Description |
|---|---|
| AssignIndexFunction<T> |
A Function2 used to assign each element in a RDD an index (integer key).
|
| BalancedPartitioner |
This is a custom partitioner (used in conjunction with
AssignIndexFunction to repartition a RDD. |
| MapTupleToPairFlatMap<T,U> |
This is a simple function used to convert a
JavaRDD<Tuple2<T,U>> to a JavaPairRDD<T,U> via a
{JavaRDD.mappartitionsToPair()} call. |