Constructor and Description |
---|
TaskInfo(String taskName,
int numberOfKeyGroups,
int indexOfSubtask,
int numberOfParallelSubtasks,
int attemptNumber) |
Modifier and Type | Method and Description |
---|---|
int |
getAttemptNumber()
Gets the attempt number of this parallel subtask.
|
int |
getIndexOfThisSubtask()
Gets the number of this parallel subtask.
|
int |
getNumberOfKeyGroups()
Gets the number of key groups aka the max parallelism aka the max number of subtasks.
|
int |
getNumberOfParallelSubtasks()
Gets the parallelism with which the parallel task runs.
|
String |
getTaskName()
Returns the name of the task
|
String |
getTaskNameWithSubtasks()
Returns the name of the task, appended with the subtask indicator, such as "MyTask (3/6)",
where 3 would be (
getIndexOfThisSubtask() + 1), and 6 would be
getNumberOfParallelSubtasks() . |
public TaskInfo(String taskName, int numberOfKeyGroups, int indexOfSubtask, int numberOfParallelSubtasks, int attemptNumber)
public String getTaskName()
public int getNumberOfKeyGroups()
public int getIndexOfThisSubtask()
getNumberOfParallelSubtasks()
).public int getNumberOfParallelSubtasks()
public int getAttemptNumber()
public String getTaskNameWithSubtasks()
getIndexOfThisSubtask()
+ 1), and 6 would be
getNumberOfParallelSubtasks()
.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.