org.apache.flink.runtime.messages.accumulators

Class AccumulatorResultsErroneous

java.lang.Object

org.apache.flink.runtime.messages.accumulators.AccumulatorResultsErroneous

All Implemented Interfaces:

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

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

Denotes that the accumulator results for jobID could be obtained from the JobManager because of an exception.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AccumulatorResultsErroneous(JobID jobID, Exception cause)

Method Summary

Modifier and Type	Method and Description
Exception	cause()
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

AccumulatorResultsErroneous

public AccumulatorResultsErroneous(JobID jobID,
                                   Exception cause)

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

cause

public Exception cause()