Package org.apache.flink.runtime.accumulators

Class AccumulatorSnapshot

java.lang.Object

org.apache.flink.runtime.accumulators.AccumulatorSnapshot

All Implemented Interfaces:

Serializable

public class AccumulatorSnapshot
extends Object
implements Serializable

This class encapsulates a map of accumulators for a single task. 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	Description
AccumulatorSnapshot(JobID jobID, ExecutionAttemptID executionAttemptID, Map<String,Accumulator<?,?>> userAccumulators)

Method Summary

Modifier and Type	Method	Description
Map<String,Accumulator<?,?>>	deserializeUserAccumulators(ClassLoader classLoader)	Gets the user-defined accumulators values.
ExecutionAttemptID	getExecutionAttemptID()
JobID	getJobID()

Methods inherited from class java.lang.Object

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

Constructor Detail

AccumulatorSnapshot

public AccumulatorSnapshot(JobID jobID,
                           ExecutionAttemptID executionAttemptID,
                           Map<String,Accumulator<?,?>> userAccumulators)
                    throws IOException

Throws:

IOException

Method Detail

getJobID

public JobID getJobID()

getExecutionAttemptID

public ExecutionAttemptID getExecutionAttemptID()

deserializeUserAccumulators

public Map<String,Accumulator<?,?>> deserializeUserAccumulators(ClassLoader classLoader)
                                                                     throws IOException,
                                                                            ClassNotFoundException

Gets the user-defined accumulators values.

Returns:

the serialized map

Throws:

IOException

ClassNotFoundException