Uses of Interface
com.gengoai.stream.MLongAccumulator
-
Packages that use MLongAccumulator 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 MLongAccumulator in com.gengoai.stream
Methods in com.gengoai.stream that return MLongAccumulator Modifier and Type Method Description MLongAccumulator
StreamingContext. longAccumulator()
Creates a new long accumulator with the initial value 0.MLongAccumulator
StreamingContext. longAccumulator(long initialValue)
Creates a new long accumulator with the given initial value.abstract MLongAccumulator
StreamingContext. longAccumulator(long initialValue, String name)
Creates a new long accumulator with the given initial value. -
Uses of MLongAccumulator in com.gengoai.stream.local
Classes in com.gengoai.stream.local that implement MLongAccumulator Modifier and Type Class Description class
LocalMLongAccumulator
An implementation of aMLongAccumulator
for local streamsMethods in com.gengoai.stream.local that return MLongAccumulator Modifier and Type Method Description MLongAccumulator
LocalStreamingContext. longAccumulator(long initialValue, String name)
-
Uses of MLongAccumulator in com.gengoai.stream.spark
Classes in com.gengoai.stream.spark that implement MLongAccumulator Modifier and Type Class Description class
SparkMLongAccumulator
An implementation of aMLongAccumulator
for spark streamsMethods in com.gengoai.stream.spark that return MLongAccumulator Modifier and Type Method Description MLongAccumulator
SparkStreamingContext. longAccumulator(long initialValue, String name)
-