public class ExecutionTaskTracker
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
ExecutionTaskTracker.ExecutionTasksSummary |
public void markTaskState(ExecutionTask task, ExecutionTask.State newState)
task
- The task to update.newState
- New execution state of the task.public void addTasksToTrace(java.util.Collection<ExecutionTask> tasks, ExecutionTask.TaskType taskType)
tasks
- New tasks to add.taskType
- Task type of new tasks.public void clear()
public void setStopRequested()
public int numRemainingInterBrokerPartitionMovements()
public long remainingInterBrokerDataToMoveInMB()
public int numFinishedInterBrokerPartitionMovements()
public long finishedInterBrokerDataMovementInMB()
public java.util.Set<ExecutionTask> inExecutionTasks(java.util.Collection<ExecutionTask.TaskType> types)
public long inExecutionInterBrokerDataMovementInMB()
public int numRemainingLeadershipMovements()
public int numFinishedLeadershipMovements()
public int numRemainingIntraBrokerPartitionMovements()
public long remainingIntraBrokerDataToMoveInMB()
public int numFinishedIntraBrokerPartitionMovements()
public long finishedIntraBrokerDataToMoveInMB()
public long inExecutionIntraBrokerDataMovementInMB()
public ExecutionTaskTracker.ExecutionTasksSummary getExecutionTasksSummary(java.util.Set<ExecutionTask.TaskType> taskTypesToGetFullList)