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