public class BrokerRemovalOptions
extends java.lang.Object
BrokerRemovalPhaseExecutor
.
Callers are expected to set the #proposals
variable when the removal plan is computed.Modifier and Type | Field and Description |
---|---|
java.util.Optional<java.lang.Long> |
brokerEpoch |
java.util.Set<java.lang.Integer> |
brokersToRemove |
OperationProgress |
operationProgress |
PlanComputationOptions |
planComputationOptions |
BrokerRemovalCallback |
progressCallback |
java.util.Set<ExecutionProposal> |
proposals |
java.util.concurrent.atomic.AtomicReference<Executor.ReservationHandle> |
reservationHandle |
java.lang.String |
uid |
Constructor and Description |
---|
BrokerRemovalOptions(java.util.Set<java.lang.Integer> brokersToRemove,
java.util.Optional<java.lang.Long> brokerEpoch,
BrokerRemovalCallback progressCallback,
java.lang.String uid,
PlanComputationOptions planComputationOptions,
OperationProgress operationProgress) |
Modifier and Type | Method and Description |
---|---|
void |
setProposals(java.util.Set<ExecutionProposal> proposals) |
public final java.util.Set<java.lang.Integer> brokersToRemove
public final java.util.Optional<java.lang.Long> brokerEpoch
public final BrokerRemovalCallback progressCallback
public final java.lang.String uid
public final PlanComputationOptions planComputationOptions
public final OperationProgress operationProgress
public final java.util.concurrent.atomic.AtomicReference<Executor.ReservationHandle> reservationHandle
public java.util.Set<ExecutionProposal> proposals
public BrokerRemovalOptions(java.util.Set<java.lang.Integer> brokersToRemove, java.util.Optional<java.lang.Long> brokerEpoch, BrokerRemovalCallback progressCallback, java.lang.String uid, PlanComputationOptions planComputationOptions, OperationProgress operationProgress)
brokersToRemove
- - the IDs of the brokers to remove. This is currently limited to onebrokerEpoch
- - the epoch of the broker to remove, needed for the shutdown requestprogressCallback
- - the callback to invoke when there is progress made on the removaluid
- - a unique identifier of this specific operationplanComputationOptions
- - the options to use for the removal plan computationpublic void setProposals(java.util.Set<ExecutionProposal> proposals)