public class RDDFunctions<T>
extends Object
implements scala.Serializable
Constructor and Description |
---|
RDDFunctions(RDD<T> self,
scala.reflect.ClassTag<T> evidence$1) |
Modifier and Type | Method and Description |
---|---|
static <T> RDDFunctions<T> |
fromRDD(RDD<T> rdd,
scala.reflect.ClassTag<T> evidence$3)
Implicit conversion from an RDD to RDDFunctions.
|
RDD<Object> |
sliding(int windowSize)
Returns a RDD from grouping items of its parent RDD in fixed size blocks by passing a sliding
window over them.
|
<U> U |
treeAggregate(U zeroValue,
scala.Function2<U,T,U> seqOp,
scala.Function2<U,U,U> combOp,
int depth,
scala.reflect.ClassTag<U> evidence$2)
Aggregates the elements of this RDD in a multi-level tree pattern.
|
T |
treeReduce(scala.Function2<T,T,T> f,
int depth)
Reduces the elements of this RDD in a multi-level tree pattern.
|
public static <T> RDDFunctions<T> fromRDD(RDD<T> rdd, scala.reflect.ClassTag<T> evidence$3)
public RDD<Object> sliding(int windowSize)
public T treeReduce(scala.Function2<T,T,T> f, int depth)
depth
- suggested depth of the tree (default: 2)RDD.reduce(scala.Function2<T, T, T>)
public <U> U treeAggregate(U zeroValue, scala.Function2<U,T,U> seqOp, scala.Function2<U,U,U> combOp, int depth, scala.reflect.ClassTag<U> evidence$2)
depth
- suggested depth of the tree (default: 2)RDD.aggregate(U, scala.Function2<U, T, U>, scala.Function2<U, U, U>, scala.reflect.ClassTag<U>)