public class ExecutorState extends Object
Modifier and Type | Class and Description |
---|---|
static class |
ExecutorState.State |
public static ExecutorState noTaskInProgress(Set<Integer> recentlyRemovedBrokers)
recentlyRemovedBrokers
- Recently removed broker IDs.public static ExecutorState executionStarted(String uuid, Set<Integer> recentlyRemovedBrokers)
uuid
- UUID of the current execution.recentlyRemovedBrokers
- Recently removed broker IDs.public static ExecutorState operationInProgress(ExecutorState.State state, ExecutionTaskTracker.ExecutionTasksSummary executionTasksSummary, int maximumConcurrentInterBrokerPartitionMovementsPerBroker, int maximumConcurrentIntraBrokerPartitionMovementsPerBroker, int maximumConcurrentLeaderMovements, String uuid, Set<Integer> recentlyRemovedBrokers)
state
- State of executor.executionTasksSummary
- Summary of the execution tasks.maximumConcurrentInterBrokerPartitionMovementsPerBroker
- Maximum concurrent inter-broker partition movement per broker.maximumConcurrentIntraBrokerPartitionMovementsPerBroker
- Maximum concurrent intra-broker partition movement per broker.maximumConcurrentLeaderMovements
- Maximum concurrent leader movements.uuid
- UUID of the current execution.recentlyRemovedBrokers
- Recently removed broker IDs.public ExecutorState.State state()
public int numTotalMovements(ExecutionTask.TaskType type)
public int numFinishedMovements(ExecutionTask.TaskType type)
public long numTotalInterBrokerDataToMove()
public String uuid()
public ExecutionTaskTracker.ExecutionTasksSummary executionTasksSummary()
public Map<String,Object> getJsonStructure(boolean verbose)
public String getPlaintext()