org.apache.flink.runtime.messages.accumulators

Class AccumulatorResultsFound

java.lang.Object

org.apache.flink.runtime.messages.accumulators.AccumulatorResultsFound

All Implemented Interfaces:

Serializable, AccumulatorMessage, AccumulatorResultsResponse, scala.Equals, scala.Product

public class AccumulatorResultsFound
extends Object
implements AccumulatorResultsResponse, scala.Product, scala.Serializable

Contains the retrieved accumulator results from the job manager. This response is triggered by RequestAccumulatorResults.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AccumulatorResultsFound(JobID jobID, Map<String,SerializedValue<Object>> result)

Method Summary

Modifier and Type	Method and Description
JobID	jobID() ID of the job that the accumulator belongs to
Map<String,SerializedValue<Object>>	result()

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

AccumulatorResultsFound

public AccumulatorResultsFound(JobID jobID,
                               Map<String,SerializedValue<Object>> result)

Method Detail

jobID

public JobID jobID()

Description copied from interface: AccumulatorMessage

ID of the job that the accumulator belongs to

Specified by:

jobID in interface AccumulatorMessage

result

public Map<String,SerializedValue<Object>> result()