org.apache.flink.runtime.accumulators

Class AccumulatorEvent

java.lang.Object

org.apache.flink.runtime.accumulators.AccumulatorEvent

All Implemented Interfaces:

Serializable

public class AccumulatorEvent
extends Object
implements Serializable

This class encapsulates a map of accumulators for a single job. It is used for the transfer from TaskManagers to the JobManager and from the JobManager to the Client.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AccumulatorEvent()
AccumulatorEvent(JobID jobID, Map<String,Accumulator<?,?>> accumulators)

Method Summary

Modifier and Type	Method and Description
Map<String,Accumulator<?,?>>	getAccumulators(ClassLoader loader)
JobID	getJobID()

Methods inherited from class java.lang.Object

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

Constructor Detail

AccumulatorEvent

public AccumulatorEvent()

AccumulatorEvent

public AccumulatorEvent(JobID jobID,
                        Map<String,Accumulator<?,?>> accumulators)

Method Detail

getJobID

public JobID getJobID()

getAccumulators

public Map<String,Accumulator<?,?>> getAccumulators(ClassLoader loader)