@NotThreadSafe public abstract class AbstractExecutorReplicaMovement extends Object
Executor
Modifier and Type | Field and Description |
---|---|
protected org.apache.kafka.clients.admin.ConfluentAdmin |
_adminClient |
protected SbkAdminUtils |
_adminUtils |
protected ExecutionTaskManager |
_executionTaskManager |
protected Set<Integer> |
_recentlyDemotedBrokers |
protected Set<Integer> |
_recentlyRemovedBrokers |
protected AtomicBoolean |
_stopRequested |
protected com.linkedin.kafka.cruisecontrol.executor.ReplicationThrottleHelper |
_throttleHelper |
protected String |
_uuid |
protected static org.slf4j.Logger |
LOG |
Constructor and Description |
---|
AbstractExecutorReplicaMovement(String executionUuid,
ExecutionTaskManager executionTaskManager,
Set<Integer> recentlyDemotedBrokers,
Set<Integer> recentlyRemovedBrokers,
com.linkedin.kafka.cruisecontrol.executor.ReplicationThrottleHelper throttleHelper,
org.apache.kafka.clients.admin.ConfluentAdmin adminClient,
SbkAdminUtils adminUtils,
AtomicBoolean stopRequested) |
Modifier and Type | Method and Description |
---|---|
void |
maybeReexecuteTasks()
Conditionally re-executes the on-going tasks
|
abstract void |
move(Executor.ExecutionTaskWaiter taskWaiter)
Moves the replicas according to the specific movement
|
protected static final org.slf4j.Logger LOG
protected final String _uuid
protected final ExecutionTaskManager _executionTaskManager
protected final com.linkedin.kafka.cruisecontrol.executor.ReplicationThrottleHelper _throttleHelper
protected final org.apache.kafka.clients.admin.ConfluentAdmin _adminClient
protected final SbkAdminUtils _adminUtils
protected final AtomicBoolean _stopRequested
public AbstractExecutorReplicaMovement(String executionUuid, ExecutionTaskManager executionTaskManager, Set<Integer> recentlyDemotedBrokers, Set<Integer> recentlyRemovedBrokers, com.linkedin.kafka.cruisecontrol.executor.ReplicationThrottleHelper throttleHelper, org.apache.kafka.clients.admin.ConfluentAdmin adminClient, SbkAdminUtils adminUtils, AtomicBoolean stopRequested)
public abstract void move(Executor.ExecutionTaskWaiter taskWaiter) throws InterruptedException
taskWaiter
- InterruptedException
public void maybeReexecuteTasks()