Uses of Interface
com.gengoai.stream.MMapAccumulator

Packages that use MMapAccumulator

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 MMapAccumulator in com.gengoai.stream

Methods in com.gengoai.stream that return MMapAccumulator

Modifier and Type	Method	Description
<K,V> MMapAccumulator<K,V>	StreamingContext.mapAccumulator()	Creates a new map accumulator
abstract <K,V> MMapAccumulator<K,V>	StreamingContext.mapAccumulator(String name)	Creates a new map accumulator

Uses of MMapAccumulator in com.gengoai.stream.local

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

Modifier and Type	Class	Description
class	LocalMMapAccumulator<K,V>	An implementation of a MMapAccumulator for local streams

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

Modifier and Type	Method	Description
<K,V> MMapAccumulator<K,V>	LocalStreamingContext.mapAccumulator(String name)

Uses of MMapAccumulator in com.gengoai.stream.spark

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

Modifier and Type	Class	Description
class	SparkMMapAccumulator<K,V>	An implementation of a MMapAccumulator for Spark streams

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

Modifier and Type	Method	Description
<K,V> MMapAccumulator<K,V>	SparkStreamingContext.mapAccumulator(String name)