Uses of Interface
com.gengoai.stream.MMultiCounterAccumulator

Packages that use MMultiCounterAccumulator

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

Methods in com.gengoai.stream that return MMultiCounterAccumulator

Modifier and Type	Method	Description
<K1,K2> MMultiCounterAccumulator<K1,K2>	StreamingContext.multiCounterAccumulator()	Creates a new MultiCounter accumulator
abstract <K1,K2> MMultiCounterAccumulator<K1,K2>	StreamingContext.multiCounterAccumulator(String name)	Creates a new MultiCounter accumulator

Uses of MMultiCounterAccumulator in com.gengoai.stream.local

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

Modifier and Type	Class	Description
class	LocalMMultiCounterAccumulator<K1,K2>	An implementation of a MMultiCounterAccumulator for local streams

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

Modifier and Type	Method	Description
<K1,K2> MMultiCounterAccumulator<K1,K2>	LocalStreamingContext.multiCounterAccumulator(String name)

Uses of MMultiCounterAccumulator in com.gengoai.stream.spark

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

Modifier and Type	Class	Description
class	SparkMMultiCounterAccumulator<K1,K2>	An implementation of a MMultiCounterAccumulator for Spark streams

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

Modifier and Type	Method	Description
<K1,K2> MMultiCounterAccumulator<K1,K2>	SparkStreamingContext.multiCounterAccumulator(String name)