public static class ExecutionTaskTracker.ExecutionTasksSummary extends Object
Modifier and Type | Method and Description |
---|---|
Map<ExecutionTask.TaskType,Map<ExecutionTask.State,Set<ExecutionTask>>> |
filteredTasksByState() |
long |
finishedInterBrokerDataMovementInMB() |
long |
finishedIntraBrokerDataMovementInMB() |
long |
inExecutionInterBrokerDataMovementInMB() |
long |
inExecutionIntraBrokerDataMovementInMB() |
long |
remainingInterBrokerDataToMoveInMB() |
long |
remainingIntraBrokerDataToMoveInMB() |
String |
summarize(ExecutionTask.TaskType type)
Returns a string representation of the given
TaskType movements. |
Map<ExecutionTask.TaskType,Map<ExecutionTask.State,Integer>> |
taskStat() |
public long finishedInterBrokerDataMovementInMB()
public long finishedIntraBrokerDataMovementInMB()
public long inExecutionInterBrokerDataMovementInMB()
public long inExecutionIntraBrokerDataMovementInMB()
public long remainingInterBrokerDataToMoveInMB()
public long remainingIntraBrokerDataToMoveInMB()
public Map<ExecutionTask.TaskType,Map<ExecutionTask.State,Integer>> taskStat()
public String summarize(ExecutionTask.TaskType type)
TaskType
movements.
e.g "For leadership movements - 5 tasks cancelled, 3 completed, ..."public Map<ExecutionTask.TaskType,Map<ExecutionTask.State,Set<ExecutionTask>>> filteredTasksByState()