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 and Description
TaskInformation(JobVertexID jobVertexId, String taskName, int numberOfSubtasks, int maxNumberOfSubtaks, String invokableClassName, Configuration taskConfiguration)

Method Summary

Modifier and Type	Method and Description
String	getInvokableClassName()
JobVertexID	getJobVertexId()
int	getMaxNumberOfSubtaks()
int	getNumberOfSubtasks()
Configuration	getTaskConfiguration()
String	getTaskName()

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskInformation

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

Method Detail

getJobVertexId

public JobVertexID getJobVertexId()

getTaskName

public String getTaskName()

getNumberOfSubtasks

public int getNumberOfSubtasks()

getMaxNumberOfSubtaks

public int getMaxNumberOfSubtaks()

getInvokableClassName

public String getInvokableClassName()

getTaskConfiguration

public Configuration getTaskConfiguration()