Interface | Description |
---|---|
ExecutorNotifier |
For sending notification about executor completion status.
|
Class | Description |
---|---|
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:
|
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.
|
ExecutorNoopNotifier |
A no-op notifier for executor.
|
ExecutorNotification |
A class to encapsulate notification information sent to requester associated with an execution.
|
ExecutorState |
Enum | Description |
---|---|
ExecutionTask.State | |
ExecutionTask.TaskType | |
ExecutorNotification.ActionAgent | |
ExecutorState.State |