Uses of Interface
com.gengoai.stream.MAccumulator

Packages that use MAccumulator

Package	Description
com.gengoai.stream	A unified stream interface that can work across Java and Spark streams.
com.gengoai.stream.local
com.gengoai.stream.spark

Uses of MAccumulator in com.gengoai.stream

Subinterfaces of MAccumulator in com.gengoai.stream

Modifier and Type	Interface	Description
interface	MCounterAccumulator<T>	Accumulator for Counters
interface	MDoubleAccumulator	Accumulator for doubles
interface	MLongAccumulator	Accumulator for longs
interface	MMapAccumulator<K,V>	Accumulator for Maps
interface	MMultiCounterAccumulator<K1,K2>	An accumulator for MultiCounters
interface	MStatisticsAccumulator	Accumulator for calculating descriptive statistics

Methods in com.gengoai.stream that return MAccumulator

Modifier and Type	Method	Description
<E> MAccumulator<E,List<E>>	StreamingContext.listAccumulator()	Creates a list accumulator
abstract <E> MAccumulator<E,List<E>>	StreamingContext.listAccumulator(String name)	Creates a list accumulator
<E> MAccumulator<E,Set<E>>	StreamingContext.setAccumulator()	Creates a set accumulator
abstract <E> MAccumulator<E,Set<E>>	StreamingContext.setAccumulator(String name)	Creates a set accumulator

Methods in com.gengoai.stream with parameters of type MAccumulator

Modifier and Type	Method	Description
void	MAccumulator.merge(MAccumulator<IN,OUT> other)	Merges another accumulator with this one

Uses of MAccumulator in com.gengoai.stream.local

Classes in com.gengoai.stream.local that implement MAccumulator

Modifier and Type	Class	Description
class	LocalMAccumulator<IN,OUT>	Abstract base for local accumulators.
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 MAccumulator

Modifier and Type	Method	Description
<E> MAccumulator<E,List<E>>	LocalStreamingContext.listAccumulator(String name)
<E> MAccumulator<E,Set<E>>	LocalStreamingContext.setAccumulator(String name)

Methods in com.gengoai.stream.local with parameters of type MAccumulator

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

Uses of MAccumulator in com.gengoai.stream.spark

Classes in com.gengoai.stream.spark that implement MAccumulator

Modifier and Type	Class	Description
class	SparkMAccumulator<IN,OUT>	Generic accumulator for distributed Spark streams.
class	SparkMCounterAccumulator<E>	Counter accumulator implementation for Spark streams
class	SparkMDoubleAccumulator	An implementation of a MDoubleAccumulator for spark streams
class	SparkMLongAccumulator	An implementation of a MLongAccumulator for spark streams
class	SparkMMapAccumulator<K,V>	An implementation of a MMapAccumulator for Spark streams
class	SparkMMultiCounterAccumulator<K1,K2>	An implementation of a MMultiCounterAccumulator for Spark streams
class	SparkMStatisticsAccumulator	An implementation of a MStatisticsAccumulator for Spark streams

Methods in com.gengoai.stream.spark that return MAccumulator

Modifier and Type	Method	Description
<E> MAccumulator<E,List<E>>	SparkStreamingContext.listAccumulator(String name)
<E> MAccumulator<E,Set<E>>	SparkStreamingContext.setAccumulator(String name)

Methods in com.gengoai.stream.spark with parameters of type MAccumulator

Modifier and Type	Method	Description
void	SparkMAccumulator.merge(MAccumulator<IN,OUT> other)