Package org.apache.flink.runtime.accumulators

Class AccumulatorRegistry

java.lang.Object

org.apache.flink.runtime.accumulators.AccumulatorRegistry

public class AccumulatorRegistry
extends Object

Main accumulator registry which encapsulates user-defined accumulators.

Field Summary

Fields

Modifier and Type	Field	Description
protected JobID	jobID
protected static org.slf4j.Logger	LOG
protected ExecutionAttemptID	taskID

Constructor Summary

Constructors

Constructor	Description
AccumulatorRegistry(JobID jobID, ExecutionAttemptID taskID)

Method Summary

Modifier and Type	Method	Description
AccumulatorSnapshot	getSnapshot()	Creates a snapshot of this accumulator registry.
Map<String,Accumulator<?,?>>	getUserMap()	Gets the map for user-defined accumulators.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

jobID

protected final JobID jobID

taskID

protected final ExecutionAttemptID taskID

Constructor Detail

AccumulatorRegistry

public AccumulatorRegistry(JobID jobID,
                           ExecutionAttemptID taskID)

Method Detail

getSnapshot

public AccumulatorSnapshot getSnapshot()

Creates a snapshot of this accumulator registry.

Returns:

a serialized accumulator map

getUserMap

public Map<String,Accumulator<?,?>> getUserMap()

Gets the map for user-defined accumulators.