Interface | Description |
---|---|
Executor.ExecutionTaskWaiter | |
ExecutorNotifier |
For sending notification about executor completion status.
|
Class | Description |
---|---|
AbstractExecutorReplicaMovement |
An abstract class that defines an interface for replica movements.
|
BrokerExecutionTaskTracker |
A simple class to be used for tracking the number of ongoing partition movements for all brokers in the cluster, abstracted away from
a simple Map.
|
ExecutionMetricsReporter |
This class aims at encapsulating all execution related metrics to achieve the following:
- single stop for checking what kind of metrics are available and how they are calculated.
|
ExecutionProposal |
The execution proposal corresponding to a particular partition.
|
ExecutionTask |
A class that wraps the execution information of a balancing proposal
The task state machine is the following:
|
ExecutionTaskGenerationIdUtils | |
ExecutionTaskManager |
The class that helps track the execution status for the balancing.
|
ExecutionTaskPlanner |
The class holds the execution of balance proposals for rebalance.
|
ExecutionTaskTracker |
A class for tracking the (1) dead tasks, (2) aborting/aborted tasks, (3) in progress tasks, and (4) pending tasks.
|
ExecutionTaskTracker.ExecutionTasksSummary | |
Executor |
Executor for Kafka GoalOptimizer.
|
Executor.PartitionReplicas | |
ExecutorInterBrokerReplicaMovement |
An abstraction over the inter-broker replica movements that are done as part of an
Executor execution. |
ExecutorIntraBrokerReplicaMovement |
An abstraction over the intra-broker replica movements that are done as part of an
Executor execution. |
ExecutorLeadershipReplicaMovement |
An abstraction over the leadership movements that are done as part of an
Executor execution. |
ExecutorMetricsHandle |
Takes care of metrics sampling pre and post the proposals execution starts.
|
ExecutorNoopNotifier |
A no-op notifier for executor.
|
ExecutorNotification |
A class to encapsulate notification information sent to requester associated with an execution.
|
ExecutorReservationHandle |
A helper auto closeable class for acquiring the Executor's reservation.
|
ExecutorState |
Enum | Description |
---|---|
ExecutionTask.State |
The state of a balancing proposal.
|
ExecutionTask.TaskType | |
ExecutorNotification.ActionAgent | |
ExecutorState.State |