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$2)
Implicit conversion from an RDD to RDDFunctions.
|
RDD<Object> |
sliding(int windowSize)
sliding(Int, Int)* with step = 1. |
RDD<Object> |
sliding(int windowSize,
int step)
Returns an RDD from grouping items of its parent RDD in fixed size blocks by passing a sliding
window over them.
|
public static <T> RDDFunctions<T> fromRDD(RDD<T> rdd, scala.reflect.ClassTag<T> evidence$2)
public RDD<Object> sliding(int windowSize, int step)
windowSize
- (undocumented)step
- (undocumented)public RDD<Object> sliding(int windowSize)
sliding(Int, Int)*
with step = 1.windowSize
- (undocumented)