Package com.gengoai.stream

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 Counters
MDoubleAccumulator	Accumulator for doubles
MDoubleStream	A facade for double stream classes, such as Java's DoubleStream and Spark's DoubleRDD objects.
MLongAccumulator	Accumulator for longs
MMapAccumulator<K,V>	Accumulator for Maps
MMultiCounterAccumulator<K1,K2>	An accumulator for MultiCounters
MPairStream<T,U>	A facade for stream classes which contain key-value pairs.
MStatisticsAccumulator	Accumulator for calculating descriptive statistics
MStream<T>	A facade for stream classes, such as Java's Stream and Spark's RDD objects.

Class Summary

Class	Description
ReusableJavaStream<T>
ShuffleIterator<T>	The type Shuffle iterator.
ShuffleSpliterator<T>	The type Shuffle spliterator.
StreamingContext	Provides methods for creating MStreams and MAccumulators within a given context, i.e.
Streams	Convenience methods for creating and manipulating Java streams

Enum Summary

Enum	Description
StorageLevel