Package com.gengoai.stream.local

Class Summary

Class	Description
AbstractLocalMPairStream<K,V>
LocalDefaultMPairStream<K,V>
LocalInMemoryMStream<T>	The type Local in memory m stream.
LocalMAccumulator<IN,OUT>	Abstract base for local accumulators.
LocalMCounterAccumulator<IN>	An implementation of a MCounterAccumulator for local streams
LocalMDoubleAccumulator	An implementation of a MDoubleAccumulator for local streams
LocalMDoubleStream
LocalMListAccumulator<E>	An implementation of a MAccumulator that accumulates values in lists for local streams
LocalMLongAccumulator	An implementation of a MLongAccumulator for local streams
LocalMMapAccumulator<K,V>	An implementation of a MMapAccumulator for local streams
LocalMMultiCounterAccumulator<K1,K2>	An implementation of a MMultiCounterAccumulator for local streams
LocalMSetAccumulator<E>	An implementation of a MAccumulator that accumulates values in a set for local streams
LocalMStatisticsAccumulator	An implementation of a MStatisticsAccumulator for local streams
LocalReusableMStream<T>	The type Local reusable m stream.
LocalStreamingContext	Represents a local streaming context using Java's built-in streams