org.apache.beam.runners.spark.aggregators

Class AggAccumParam

java.lang.Object

org.apache.beam.runners.spark.aggregators.AggAccumParam

All Implemented Interfaces:

java.io.Serializable, org.apache.spark.AccumulableParam<NamedAggregators,NamedAggregators>, org.apache.spark.AccumulatorParam<NamedAggregators>

public class AggAccumParam
extends java.lang.Object
implements org.apache.spark.AccumulatorParam<NamedAggregators>

Aggregator accumulator param.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.spark.AccumulatorParam

org.apache.spark.AccumulatorParam.DoubleAccumulatorParam$, org.apache.spark.AccumulatorParam.FloatAccumulatorParam$, org.apache.spark.AccumulatorParam.IntAccumulatorParam$, org.apache.spark.AccumulatorParam.LongAccumulatorParam$

Constructor Summary

Constructors

Constructor and Description
AggAccumParam()

Method Summary

Modifier and Type	Method and Description
NamedAggregators	addAccumulator(NamedAggregators current, NamedAggregators added)
NamedAggregators	addInPlace(NamedAggregators current, NamedAggregators added)
NamedAggregators	zero(NamedAggregators initialValue)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AggAccumParam

public AggAccumParam()

Method Detail

addAccumulator

public NamedAggregators addAccumulator(NamedAggregators current,
                                       NamedAggregators added)

Specified by:

addAccumulator in interface org.apache.spark.AccumulableParam<NamedAggregators,NamedAggregators>

Specified by:

addAccumulator in interface org.apache.spark.AccumulatorParam<NamedAggregators>

addInPlace

public NamedAggregators addInPlace(NamedAggregators current,
                                   NamedAggregators added)

Specified by:

addInPlace in interface org.apache.spark.AccumulableParam<NamedAggregators,NamedAggregators>

zero

public NamedAggregators zero(NamedAggregators initialValue)

Specified by:

zero in interface org.apache.spark.AccumulableParam<NamedAggregators,NamedAggregators>