public class ExecutionTaskTracker extends Object
Modifier and Type | Class and Description |
---|---|
static class |
ExecutionTaskTracker.ExecutionTasksSummary |
Modifier and Type | Method and Description |
---|---|
void |
addTasksToTrace(Collection<ExecutionTask> tasks,
ExecutionTask.TaskType taskType)
Add new tasks to ExecutionTaskTracker to trace their execution.
|
void |
clear()
Clear the replica action and leader action tasks.
|
long |
finishedInterBrokerDataMovementInMB() |
ExecutionTaskTracker.ExecutionTasksSummary |
getExecutionTasksSummary(Set<ExecutionTask.TaskType> taskTypesToGetFullList) |
long |
inExecutionInterBrokerDataMovementInMB() |
Set<ExecutionTask> |
inExecutionTasks(Collection<ExecutionTask.TaskType> types) |
void |
markTaskState(ExecutionTask task,
ExecutionTask.State newState)
Update the execution state of the task.
|
int |
numFinishedInterBrokerPartitionMovements() |
int |
numFinishedIntraBrokerPartitionMovements() |
int |
numFinishedLeadershipMovements() |
int |
numInterBrokerPartitionMovementsToBeRetried()
Returns the number of inter-broker tasks that are yet to be retried
|
int |
numIntraBrokerPartitionMovementsToBeRetried()
Returns the number of intra-broker tasks that are yet to be retried
|
int |
numLeadershipMovementsToBeRetried()
Returns the number of leadership movement tasks that are yet to be retried
|
int |
numPendingInterBrokerPartitionMovements()
Returns the number of pending inter-broker tasks that have not yet been executed
|
int |
numPendingIntraBrokerPartitionMovements()
Returns the number of pending intra-broker tasks that have not yet been executed
|
int |
numPendingLeadershipMovements()
Returns the number of pending leadership movement tasks that have not yet been executed
|
int |
numRemainingInterBrokerPartitionMovements()
Returns the total number of inter-broker tasks that are left to be executed
|
int |
numRemainingIntraBrokerPartitionMovements()
Returns the total number of intra-broker tasks that are left to be executed
|
int |
numRemainingLeadershipMovements()
Returns the total number of inter-broker tasks that are left to be executed
|
Map<Integer,Long> |
remainingInterBrokerDataToMoveByDestinationBroker() |
long |
remainingInterBrokerDataToMoveInMB() |
void |
setStopRequested() |
Set<ExecutionTask> |
tasksToBeRetried(ExecutionTask.TaskType type) |
public void markTaskState(ExecutionTask task, ExecutionTask.State newState)
task
- The task to update.newState
- New execution state of the task.public Set<ExecutionTask> tasksToBeRetried(ExecutionTask.TaskType type)
ExecutionTask.TaskType
type
tasks that are in a ExecutionTask.State.TO_RETRY
statepublic void addTasksToTrace(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 int numPendingInterBrokerPartitionMovements()
public int numInterBrokerPartitionMovementsToBeRetried()
public long remainingInterBrokerDataToMoveInMB()
public Map<Integer,Long> remainingInterBrokerDataToMoveByDestinationBroker()
public int numFinishedInterBrokerPartitionMovements()
public long finishedInterBrokerDataMovementInMB()
public Set<ExecutionTask> inExecutionTasks(Collection<ExecutionTask.TaskType> types)
public long inExecutionInterBrokerDataMovementInMB()
public int numRemainingLeadershipMovements()
public int numPendingLeadershipMovements()
public int numLeadershipMovementsToBeRetried()
public int numFinishedLeadershipMovements()
public int numRemainingIntraBrokerPartitionMovements()
public int numPendingIntraBrokerPartitionMovements()
public int numIntraBrokerPartitionMovementsToBeRetried()
public int numFinishedIntraBrokerPartitionMovements()
public ExecutionTaskTracker.ExecutionTasksSummary getExecutionTasksSummary(Set<ExecutionTask.TaskType> taskTypesToGetFullList)