Uses of Class
com.gengoai.stream.local.LocalMAccumulator

Packages that use LocalMAccumulator

Package	Description
com.gengoai.stream.local
com.gengoai.stream.spark

Uses of LocalMAccumulator in com.gengoai.stream.local

Subclasses of LocalMAccumulator in com.gengoai.stream.local

Modifier and Type	Class	Description
class	LocalMCounterAccumulator<IN>	An implementation of a MCounterAccumulator for local streams
class	LocalMDoubleAccumulator	An implementation of a MDoubleAccumulator for local streams
class	LocalMListAccumulator<E>	An implementation of a MAccumulator that accumulates values in lists for local streams
class	LocalMLongAccumulator	An implementation of a MLongAccumulator for local streams
class	LocalMMapAccumulator<K,V>	An implementation of a MMapAccumulator for local streams
class	LocalMMultiCounterAccumulator<K1,K2>	An implementation of a MMultiCounterAccumulator for local streams
class	LocalMSetAccumulator<E>	An implementation of a MAccumulator that accumulates values in a set for local streams
class	LocalMStatisticsAccumulator	An implementation of a MStatisticsAccumulator for local streams

Methods in com.gengoai.stream.local that return LocalMAccumulator

Modifier and Type	Method	Description
LocalMAccumulator<IN,Counter<IN>>	LocalMCounterAccumulator.copy()
LocalMAccumulator<Double,Double>	LocalMDoubleAccumulator.copy()
LocalMAccumulator<E,List<E>>	LocalMListAccumulator.copy()
LocalMAccumulator<Long,Long>	LocalMLongAccumulator.copy()
LocalMAccumulator<Tuple2<K,V>,Map<K,V>>	LocalMMapAccumulator.copy()
LocalMAccumulator<Tuple2<K1,K2>,MultiCounter<K1,K2>>	LocalMMultiCounterAccumulator.copy()
LocalMAccumulator<E,Set<E>>	LocalMSetAccumulator.copy()
LocalMAccumulator<Double,EnhancedDoubleStatistics>	LocalMStatisticsAccumulator.copy()

Uses of LocalMAccumulator in com.gengoai.stream.spark

Fields in com.gengoai.stream.spark declared as LocalMAccumulator

Modifier and Type	Field	Description
LocalMAccumulator<IN,OUT>	AccumulatorV2Wrapper.accumulator	The Accumulator.

Constructors in com.gengoai.stream.spark with parameters of type LocalMAccumulator

Constructor	Description
AccumulatorV2Wrapper(LocalMAccumulator<IN,OUT> accumulator)	Instantiates a new AccumulatorV2Wrapper.
SparkMAccumulator(LocalMAccumulator<IN,OUT> localMAccumulator)	Instantiates a new Spark m accumulator by wrapping a local accumulator.