org.apache.flink.runtime.messages.accumulators

Class RequestAccumulatorResults

java.lang.Object

org.apache.flink.runtime.messages.accumulators.RequestAccumulatorResults

All Implemented Interfaces:

Serializable, AccumulatorMessage, scala.Equals, scala.Product

public class RequestAccumulatorResults
extends Object
implements AccumulatorMessage, scala.Product, scala.Serializable

Requests the accumulator results of the job identified by jobID from the job manager. The result is sent back to the sender as a AccumulatorResultsResponse message.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RequestAccumulatorResults(JobID jobID)

Method Summary

Modifier and Type	Method and Description
JobID	jobID() ID of the job that the accumulator belongs to

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

RequestAccumulatorResults

public RequestAccumulatorResults(JobID jobID)

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