Package org.apache.beam.runners.spark.aggregators

Provides internal utilities for implementing Beam aggregators using Spark accumulators.

See: Description

Interface Summary

Interface	Description
NamedAggregators.State<InputT,InterT,OutputT>

Class Summary

Class	Description
AggAccumParam	Aggregator accumulator param.
AggregatorsAccumulator	For resilience, Accumulators are required to be wrapped in a Singleton.
AggregatorsAccumulator.AccumulatorCheckpointingSparkListener	Spark Listener which checkpoints NamedAggregators values for fault-tolerance.
NamedAggregators	This class wraps a map of named aggregators.

Package org.apache.beam.runners.spark.aggregators Description

Provides internal utilities for implementing Beam aggregators using Spark accumulators.