Uses of Interface
com.gengoai.stream.MCounterAccumulator
-
Packages that use MCounterAccumulator 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 MCounterAccumulator in com.gengoai.stream
Methods in com.gengoai.stream that return MCounterAccumulator Modifier and Type Method Description <E> MCounterAccumulator<E>StreamingContext. counterAccumulator()Creates a new Counter accumulator.abstract <E> MCounterAccumulator<E>StreamingContext. counterAccumulator(String name)Creates a new Counter accumulator. -
Uses of MCounterAccumulator in com.gengoai.stream.local
Classes in com.gengoai.stream.local that implement MCounterAccumulator Modifier and Type Class Description classLocalMCounterAccumulator<IN>An implementation of aMCounterAccumulatorfor local streamsMethods in com.gengoai.stream.local that return MCounterAccumulator Modifier and Type Method Description <E> MCounterAccumulator<E>LocalStreamingContext. counterAccumulator(String name) -
Uses of MCounterAccumulator in com.gengoai.stream.spark
Classes in com.gengoai.stream.spark that implement MCounterAccumulator Modifier and Type Class Description classSparkMCounterAccumulator<E>Counter accumulator implementation for Spark streamsMethods in com.gengoai.stream.spark that return MCounterAccumulator Modifier and Type Method Description <E> MCounterAccumulator<E>SparkStreamingContext. counterAccumulator(String name)
-