Package com.gengoai.stream.spark
Class SparkMStatisticsAccumulator
- java.lang.Object
-
- com.gengoai.stream.spark.SparkMAccumulator<Double,EnhancedDoubleStatistics>
-
- com.gengoai.stream.spark.SparkMStatisticsAccumulator
-
- All Implemented Interfaces:
MAccumulator<Double,EnhancedDoubleStatistics>
,MStatisticsAccumulator
,Serializable
public class SparkMStatisticsAccumulator extends SparkMAccumulator<Double,EnhancedDoubleStatistics> implements MStatisticsAccumulator
An implementation of a
MStatisticsAccumulator
for Spark streams- Author:
- David B. Bracewell
- See Also:
- Serialized Form
-
-
Field Summary
-
Fields inherited from class com.gengoai.stream.spark.SparkMAccumulator
accumulatorV2
-
-
Constructor Summary
Constructors Constructor Description SparkMStatisticsAccumulator(String name)
Instantiates a new SparkMStatisticsAccumulator.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
add(double value)
Adds a value to the statistics accumulator.void
combine(EnhancedDoubleStatistics statistics)
Combines the given statistics with this one.-
Methods inherited from class com.gengoai.stream.spark.SparkMAccumulator
add, isZero, merge, name, register, reset, value
-
-
-
-
Constructor Detail
-
SparkMStatisticsAccumulator
public SparkMStatisticsAccumulator(String name)
Instantiates a new SparkMStatisticsAccumulator.- Parameters:
name
- the name of the accumulator
-
-
Method Detail
-
add
public void add(double value)
Description copied from interface:MStatisticsAccumulator
Adds a value to the statistics accumulator.- Specified by:
add
in interfaceMStatisticsAccumulator
- Parameters:
value
- the value to add
-
combine
public void combine(EnhancedDoubleStatistics statistics)
Description copied from interface:MStatisticsAccumulator
Combines the given statistics with this one.- Specified by:
combine
in interfaceMStatisticsAccumulator
- Parameters:
statistics
- the statistics to combine
-
-