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() |
long |
finishedIntraBrokerDataToMoveInMB() |
ExecutionTaskTracker.ExecutionTasksSummary |
getExecutionTasksSummary(Set<ExecutionTask.TaskType> taskTypesToGetFullList) |
long |
inExecutionInterBrokerDataMovementInMB() |
long |
inExecutionIntraBrokerDataMovementInMB() |
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
|
long |
remainingInterBrokerDataToMoveInMB() |
long |
remainingIntraBrokerDataToMoveInMB() |
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 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 long remainingIntraBrokerDataToMoveInMB()
public int numFinishedIntraBrokerPartitionMovements()
public long finishedIntraBrokerDataToMoveInMB()
public long inExecutionIntraBrokerDataMovementInMB()
public ExecutionTaskTracker.ExecutionTasksSummary getExecutionTasksSummary(Set<ExecutionTask.TaskType> taskTypesToGetFullList)