A unified stream interface that can work across Java and Spark streams.
Interface Summary Interface Description MAccumulator<IN,OUT>Base interface for accumulators that can work across local and distributed streams. MCounterAccumulator<T>Accumulator for
MDoubleAccumulatorAccumulator for doubles MDoubleStreamA facade for double stream classes, such as Java's
MLongAccumulatorAccumulator for longs MMapAccumulator<K,V>Accumulator for Maps MMultiCounterAccumulator<K1,K2>An accumulator for
MPairStream<T,U>A facade for stream classes which contain key-value pairs. MStatisticsAccumulatorAccumulator for calculating descriptive statistics MStream<T>A facade for stream classes, such as Java's
Class Summary Class Description ReusableJavaStream<T> ShuffleIterator<T>The type Shuffle iterator. ShuffleSpliterator<T>The type Shuffle spliterator. StreamingContextProvides methods for creating
MAccumulatorswithin a given context, i.e.
StreamsConvenience methods for creating and manipulating Java streams
Enum Summary Enum Description StorageLevel