org.apache.flink.runtime.messages

Class ExecutionGraphMessages.ExecutionStateChanged

java.lang.Object

org.apache.flink.runtime.messages.ExecutionGraphMessages.ExecutionStateChanged

All Implemented Interfaces:

Serializable, RequiresLeaderSessionID, scala.Equals, scala.Product

Enclosing class:

ExecutionGraphMessages

public static class ExecutionGraphMessages.ExecutionStateChanged
extends Object
implements RequiresLeaderSessionID, scala.Product, scala.Serializable

Denotes the execution state change of an ExecutionVertex

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ExecutionStateChanged(JobID jobID, JobVertexID vertexID, String taskName, int totalNumberOfSubTasks, int subtaskIndex, ExecutionAttemptID executionID, ExecutionState newExecutionState, long timestamp, String optionalMessage)

Method Summary

Modifier and Type	Method and Description
ExecutionAttemptID	executionID()
JobID	jobID()
ExecutionState	newExecutionState()
String	optionalMessage()
int	subtaskIndex()
String	taskName()
long	timestamp()
String	toString()
int	totalNumberOfSubTasks()
JobVertexID	vertexID()

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

ExecutionStateChanged

public ExecutionStateChanged(JobID jobID,
                             JobVertexID vertexID,
                             String taskName,
                             int totalNumberOfSubTasks,
                             int subtaskIndex,
                             ExecutionAttemptID executionID,
                             ExecutionState newExecutionState,
                             long timestamp,
                             String optionalMessage)

Method Detail

jobID

public JobID jobID()

vertexID

public JobVertexID vertexID()

taskName

public String taskName()

totalNumberOfSubTasks

public int totalNumberOfSubTasks()

subtaskIndex

public int subtaskIndex()

executionID

public ExecutionAttemptID executionID()

newExecutionState

public ExecutionState newExecutionState()

timestamp

public long timestamp()

optionalMessage

public String optionalMessage()

toString

public String toString()

Overrides:

toString in class Object