org.apache.flink.runtime.accumulators

Class AccumulatorEvent

java.lang.Object

org.apache.flink.runtime.util.SerializedValue<Map<String,org.apache.flink.api.common.accumulators.Accumulator<?,?>>>

org.apache.flink.runtime.accumulators.AccumulatorEvent

All Implemented Interfaces:

Serializable

public class AccumulatorEvent
extends SerializedValue<Map<String,org.apache.flink.api.common.accumulators.Accumulator<?,?>>>

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(org.apache.flink.api.common.JobID jobID, Map<String,org.apache.flink.api.common.accumulators.Accumulator<?,?>> accumulators)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.common.JobID	getJobID()

Methods inherited from class org.apache.flink.runtime.util.SerializedValue

deserializeValue, equals, hashCode, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

AccumulatorEvent

public AccumulatorEvent(org.apache.flink.api.common.JobID jobID,
                        Map<String,org.apache.flink.api.common.accumulators.Accumulator<?,?>> accumulators)
                 throws IOException

Throws:

IOException

Method Detail

getJobID

public org.apache.flink.api.common.JobID getJobID()