Package org.apache.flink.runtime.executiongraph

Class TaskInformation

java.lang.Object

org.apache.flink.runtime.executiongraph.TaskInformation

All Implemented Interfaces:

Serializable

public class TaskInformation
extends Object
implements Serializable

Container class for operator/task specific information which are stored at the ExecutionJobVertex. This information is shared by all sub tasks of this operator.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
TaskInformation(JobVertexID jobVertexId, String taskName, int numberOfSubtasks, int maxNumberOfSubtasks, String invokableClassName, Configuration taskConfiguration)

Method Summary

Modifier and Type	Method	Description
TaskInformation	deepCopy()
boolean	equals(Object o)
String	getInvokableClassName()
JobVertexID	getJobVertexId()
int	getMaxNumberOfSubtasks()
int	getNumberOfSubtasks()
Configuration	getTaskConfiguration()
String	getTaskName()
int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskInformation

public TaskInformation(JobVertexID jobVertexId,
                       String taskName,
                       int numberOfSubtasks,
                       int maxNumberOfSubtasks,
                       String invokableClassName,
                       Configuration taskConfiguration)

Method Detail

getJobVertexId

public JobVertexID getJobVertexId()

getTaskName

public String getTaskName()

getNumberOfSubtasks

public int getNumberOfSubtasks()

getMaxNumberOfSubtasks

public int getMaxNumberOfSubtasks()

getInvokableClassName

public String getInvokableClassName()

getTaskConfiguration

public Configuration getTaskConfiguration()

deepCopy

public TaskInformation deepCopy()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object