public class ExecutorState
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
ExecutorState.State |
Modifier and Type | Method and Description |
---|---|
static ExecutorState |
executionStarted(java.lang.String uuid,
java.util.Set<java.lang.Integer> recentlyDemotedBrokers,
java.util.Set<java.lang.Integer> recentlyRemovedBrokers) |
ExecutionTaskTracker.ExecutionTasksSummary |
executionTasksSummary() |
java.util.Map<java.lang.String,java.lang.Object> |
getJsonStructure(boolean verbose)
Return an object that can be further used to encode into JSON
|
java.lang.String |
getPlaintext() |
static ExecutorState |
noTaskInProgress(java.util.Set<java.lang.Integer> recentlyDemotedBrokers,
java.util.Set<java.lang.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,
java.lang.String uuid,
java.util.Set<java.lang.Integer> recentlyDemotedBrokers,
java.util.Set<java.lang.Integer> recentlyRemovedBrokers) |
java.util.Set<java.lang.Integer> |
recentlyDemotedBrokers() |
java.util.Set<java.lang.Integer> |
recentlyRemovedBrokers() |
ExecutorState.State |
state() |
java.lang.String |
uuid() |
public static ExecutorState noTaskInProgress(java.util.Set<java.lang.Integer> recentlyDemotedBrokers, java.util.Set<java.lang.Integer> recentlyRemovedBrokers)
recentlyDemotedBrokers
- Recently demoted broker IDs.recentlyRemovedBrokers
- Recently removed broker IDs.public static ExecutorState executionStarted(java.lang.String uuid, java.util.Set<java.lang.Integer> recentlyDemotedBrokers, java.util.Set<java.lang.Integer> recentlyRemovedBrokers)
uuid
- UUID of the current execution.recentlyDemotedBrokers
- Recently demoted broker IDs.recentlyRemovedBrokers
- Recently removed broker IDs.public static ExecutorState operationInProgress(ExecutorState.State state, ExecutionTaskTracker.ExecutionTasksSummary executionTasksSummary, int maximumConcurrentInterBrokerPartitionMovementsPerBroker, int maximumConcurrentIntraBrokerPartitionMovementsPerBroker, int maximumConcurrentLeaderMovements, java.lang.String uuid, java.util.Set<java.lang.Integer> recentlyDemotedBrokers, java.util.Set<java.lang.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.recentlyDemotedBrokers
- Recently demoted broker IDs.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 long numTotalIntraBrokerDataToMove()
public java.lang.String uuid()
public java.util.Set<java.lang.Integer> recentlyDemotedBrokers()
public java.util.Set<java.lang.Integer> recentlyRemovedBrokers()
public ExecutionTaskTracker.ExecutionTasksSummary executionTasksSummary()
public java.util.Map<java.lang.String,java.lang.Object> getJsonStructure(boolean verbose)
public java.lang.String getPlaintext()