All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type |
Method and Description |
static ExecutorState |
executionStarted(String uuid,
Set<Integer> recentlyDemotedBrokers,
Set<Integer> recentlyRemovedBrokers) |
ExecutionTaskTracker.ExecutionTasksSummary |
executionTasksSummary() |
Map<String,Object> |
getJsonStructure(boolean verbose)
Return an object that can be further used to encode into JSON
|
String |
getPlaintext() |
static ExecutorState |
noTaskInProgress(Set<Integer> recentlyDemotedBrokers,
Set<Integer> recentlyRemovedBrokers) |
int |
numFinishedMovements(ExecutionTask.TaskType type) |
long |
numTotalInterBrokerDataToMove() |
long |
numTotalIntraBrokerDataToMove() |
int |
numTotalMovements(ExecutionTask.TaskType type) |
static ExecutorState |
operationInProgress(ExecutorState.State state,
ExecutionTaskTracker.ExecutionTasksSummary executionTasksSummary,
int maximumConcurrentInterBrokerPartitionMovementsPerBroker,
int maximumConcurrentIntraBrokerPartitionMovementsPerBroker,
int maximumConcurrentLeaderMovements,
String uuid,
Set<Integer> recentlyDemotedBrokers,
Set<Integer> recentlyRemovedBrokers) |
Set<Integer> |
recentlyDemotedBrokers() |
Set<Integer> |
recentlyRemovedBrokers() |
ExecutorState.State |
state() |
String |
uuid() |