Package org.apache.flink.api.common

Class TaskInfoImpl

java.lang.Object

org.apache.flink.api.common.TaskInfoImpl

All Implemented Interfaces:

TaskInfo

@Internal
public class TaskInfoImpl
extends Object
implements TaskInfo

The default implementation of TaskInfo.

Constructor Summary

Constructors

Constructor	Description
TaskInfoImpl(String taskName, int maxNumberOfParallelSubtasks, int indexOfSubtask, int numberOfParallelSubtasks, int attemptNumber)
TaskInfoImpl(String taskName, int maxNumberOfParallelSubtasks, int indexOfSubtask, int numberOfParallelSubtasks, int attemptNumber, String allocationIDAsString)

Method Summary

Modifier and Type	Method	Description
String	getAllocationIDAsString()	Returns the allocation id for where this task is executed.
int	getAttemptNumber()	Gets the attempt number of this parallel subtask.
int	getIndexOfThisSubtask()	Gets the number of this parallel subtask.
int	getMaxNumberOfParallelSubtasks()	Gets the max parallelism aka the max number of subtasks.
int	getNumberOfParallelSubtasks()	Gets the parallelism with which the parallel task runs.
String	getTaskName()	Gets the task name.
String	getTaskNameWithSubtasks()	Returns the name of the task, appended with the subtask indicator, such as "MyTask (3/6)#1", where 3 would be (TaskInfo.getIndexOfThisSubtask() + 1), and 6 would be TaskInfo.getNumberOfParallelSubtasks(), and 1 would be TaskInfo.getAttemptNumber().

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskInfoImpl

public TaskInfoImpl(String taskName,
                    int maxNumberOfParallelSubtasks,
                    int indexOfSubtask,
                    int numberOfParallelSubtasks,
                    int attemptNumber)

TaskInfoImpl

public TaskInfoImpl(String taskName,
                    int maxNumberOfParallelSubtasks,
                    int indexOfSubtask,
                    int numberOfParallelSubtasks,
                    int attemptNumber,
                    String allocationIDAsString)

Method Detail

getTaskName

public String getTaskName()

Description copied from interface: TaskInfo

Gets the task name.

Specified by:

getTaskName in interface TaskInfo

Returns:

The task name.

getMaxNumberOfParallelSubtasks

public int getMaxNumberOfParallelSubtasks()

Description copied from interface: TaskInfo

Gets the max parallelism aka the max number of subtasks.

Specified by:

getMaxNumberOfParallelSubtasks in interface TaskInfo

Returns:

The max parallelism.

getIndexOfThisSubtask

public int getIndexOfThisSubtask()

Description copied from interface: TaskInfo

Gets the number of this parallel subtask. The numbering starts from 0 and goes up to parallelism-1 (parallelism as returned by TaskInfo.getNumberOfParallelSubtasks()).

Specified by:

getIndexOfThisSubtask in interface TaskInfo

Returns:

The index of the parallel subtask.

getNumberOfParallelSubtasks

public int getNumberOfParallelSubtasks()

Description copied from interface: TaskInfo

Gets the parallelism with which the parallel task runs.

Specified by:

getNumberOfParallelSubtasks in interface TaskInfo

Returns:

The parallelism with which the parallel task runs.

getAttemptNumber

public int getAttemptNumber()

Description copied from interface: TaskInfo

Gets the attempt number of this parallel subtask. First attempt is numbered 0. The attempt number corresponds to the number of times this task has been restarted(after failure/cancellation) since the job was initially started.

Specified by:

getAttemptNumber in interface TaskInfo

Returns:

The attempt number of the subtask.

getTaskNameWithSubtasks

public String getTaskNameWithSubtasks()

Description copied from interface: TaskInfo

Returns the name of the task, appended with the subtask indicator, such as "MyTask (3/6)#1", where 3 would be (TaskInfo.getIndexOfThisSubtask() + 1), and 6 would be TaskInfo.getNumberOfParallelSubtasks(), and 1 would be TaskInfo.getAttemptNumber().

Specified by:

getTaskNameWithSubtasks in interface TaskInfo

Returns:

The name of the task, with subtask indicator.

getAllocationIDAsString

public String getAllocationIDAsString()

Description copied from interface: TaskInfo

Returns the allocation id for where this task is executed.

Specified by:

getAllocationIDAsString in interface TaskInfo

Returns:

The allocation id for where this task is executed.