Uses of Interface
com.gengoai.stream.MStatisticsAccumulator
-
Packages that use MStatisticsAccumulator 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 MStatisticsAccumulator in com.gengoai.stream
Methods in com.gengoai.stream that return MStatisticsAccumulator Modifier and Type Method Description MStatisticsAccumulator
StreamingContext. statisticsAccumulator()
Creates a new statistics accumulatorabstract MStatisticsAccumulator
StreamingContext. statisticsAccumulator(String name)
Creates a new statistics accumulator -
Uses of MStatisticsAccumulator in com.gengoai.stream.local
Classes in com.gengoai.stream.local that implement MStatisticsAccumulator Modifier and Type Class Description class
LocalMStatisticsAccumulator
An implementation of aMStatisticsAccumulator
for local streamsMethods in com.gengoai.stream.local that return MStatisticsAccumulator Modifier and Type Method Description MStatisticsAccumulator
LocalStreamingContext. statisticsAccumulator(String name)
-
Uses of MStatisticsAccumulator in com.gengoai.stream.spark
Classes in com.gengoai.stream.spark that implement MStatisticsAccumulator Modifier and Type Class Description class
SparkMStatisticsAccumulator
An implementation of aMStatisticsAccumulator
for Spark streamsMethods in com.gengoai.stream.spark that return MStatisticsAccumulator Modifier and Type Method Description MStatisticsAccumulator
SparkStreamingContext. statisticsAccumulator(String name)
-