Uses of Interface
org.apache.flink.api.common.accumulators.Accumulator

Packages that use Accumulator

Package	Description
org.apache.flink.api.common.accumulators
org.apache.flink.api.common.functions
org.apache.flink.api.common.functions.util

Uses of Accumulator in org.apache.flink.api.common.accumulators

Subinterfaces of Accumulator in org.apache.flink.api.common.accumulators

Modifier and Type	Interface	Description
interface	SimpleAccumulator<T extends Serializable>	Similar to Accumulator, but the type of items to add and the result value must be the same.

Classes in org.apache.flink.api.common.accumulators that implement Accumulator

Modifier and Type	Class	Description
class	AverageAccumulator	An accumulator that computes the average value.
class	DoubleCounter	An accumulator that sums up double values.
class	DoubleMaximum	An accumulator that finds the maximum double value.
class	DoubleMinimum	An accumulator that finds the minimum double value.
class	Histogram	Histogram accumulator, which builds a histogram in a distributed manner.
class	IntCounter	An accumulator that sums up Integer values.
class	IntMaximum	An accumulator that finds the maximum integer value.
class	IntMinimum	An accumulator that finds the minimum integer value.
class	ListAccumulator<T>	This accumulator stores a collection of objects.
class	LongCounter	An accumulator that sums up long values.
class	LongMaximum	An accumulator that finds the maximum long value.
class	LongMinimum	An accumulator that finds the minimum long value.
class	SerializedListAccumulator<T>	This accumulator stores a collection of objects in serialized form, so that the stored objects are not affected by modifications to the original objects.

Methods in org.apache.flink.api.common.accumulators that return Accumulator

Modifier and Type	Method	Description
Accumulator<V,R>	Accumulator.clone()	Duplicates the accumulator.
Accumulator<Integer,TreeMap<Integer,Integer>>	Histogram.clone()
Accumulator<T,ArrayList<T>>	ListAccumulator.clone()

Methods in org.apache.flink.api.common.accumulators that return types with arguments of type Accumulator

Modifier and Type	Method	Description
static Map<String,Accumulator<?,?>>	AccumulatorHelper.copy(Map<String,Accumulator<?,?>> accumulators)

Methods in org.apache.flink.api.common.accumulators with parameters of type Accumulator

Modifier and Type	Method	Description
void	Accumulator.merge(Accumulator<V,R> other)	Used by system internally to merge the collected parts of an accumulator at the end of the job.
void	AverageAccumulator.merge(Accumulator<Double,Double> other)
void	DoubleCounter.merge(Accumulator<Double,Double> other)
void	DoubleMaximum.merge(Accumulator<Double,Double> other)
void	DoubleMinimum.merge(Accumulator<Double,Double> other)
void	Histogram.merge(Accumulator<Integer,TreeMap<Integer,Integer>> other)
void	IntCounter.merge(Accumulator<Integer,Integer> other)
void	IntMaximum.merge(Accumulator<Integer,Integer> other)
void	IntMinimum.merge(Accumulator<Integer,Integer> other)
void	ListAccumulator.merge(Accumulator<T,ArrayList<T>> other)
void	LongCounter.merge(Accumulator<Long,Long> other)
void	LongMaximum.merge(Accumulator<Long,Long> other)
void	LongMinimum.merge(Accumulator<Long,Long> other)
void	SerializedListAccumulator.merge(Accumulator<T,ArrayList<byte[]>> other)

Method parameters in org.apache.flink.api.common.accumulators with type arguments of type Accumulator

Modifier and Type	Method	Description
static void	AccumulatorHelper.compareAccumulatorTypes(Object name, Class<? extends Accumulator> first, Class<? extends Accumulator> second)	Compare both classes and throw UnsupportedOperationException if they differ.
static Map<String,Accumulator<?,?>>	AccumulatorHelper.copy(Map<String,Accumulator<?,?>> accumulators)
static void	AccumulatorHelper.mergeInto(Map<String,OptionalFailure<Accumulator<?,?>>> target, Map<String,Accumulator<?,?>> toMerge)	Merge two collections of accumulators.
static Map<String,OptionalFailure<Object>>	AccumulatorHelper.toResultMap(Map<String,Accumulator<?,?>> accumulators)	Transform the Map with accumulators into a Map containing only the results.

Uses of Accumulator in org.apache.flink.api.common.functions

Methods in org.apache.flink.api.common.functions that return Accumulator

Modifier and Type	Method	Description
<V,A extends Serializable> Accumulator<V,A>	RuntimeContext.getAccumulator(String name)	Get an existing accumulator object.

Methods in org.apache.flink.api.common.functions with parameters of type Accumulator

Modifier and Type	Method	Description
<V,A extends Serializable> void	RuntimeContext.addAccumulator(String name, Accumulator<V,A> accumulator)	Add this accumulator.

Uses of Accumulator in org.apache.flink.api.common.functions.util

Methods in org.apache.flink.api.common.functions.util that return Accumulator

Modifier and Type	Method	Description
<V,A extends Serializable> Accumulator<V,A>	AbstractRuntimeUDFContext.getAccumulator(String name)

Methods in org.apache.flink.api.common.functions.util with parameters of type Accumulator

Modifier and Type	Method	Description
<V,A extends Serializable> void	AbstractRuntimeUDFContext.addAccumulator(String name, Accumulator<V,A> accumulator)

Constructor parameters in org.apache.flink.api.common.functions.util with type arguments of type Accumulator

Constructor	Description
AbstractRuntimeUDFContext(TaskInfo taskInfo, UserCodeClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Accumulator<?,?>> accumulators, Map<String,Future<Path>> cpTasks, org.apache.flink.metrics.groups.OperatorMetricGroup metrics)