public class BrokerRemovalFuture
extends java.lang.Object
Constructor and Description |
---|
BrokerRemovalFuture(java.util.concurrent.atomic.AtomicReference<Executor.ReservationHandle> reservationHandle,
java.util.concurrent.CompletableFuture<java.lang.Void> initialFuture,
java.util.concurrent.CompletableFuture<java.util.concurrent.Future<?>> chainedFutures) |
Modifier and Type | Method and Description |
---|---|
boolean |
cancel()
Attempt to cancel the broker removal operation future.
|
void |
execute(java.time.Duration duration)
Executes the broker removal
|
public BrokerRemovalFuture(java.util.concurrent.atomic.AtomicReference<Executor.ReservationHandle> reservationHandle, java.util.concurrent.CompletableFuture<java.lang.Void> initialFuture, java.util.concurrent.CompletableFuture<java.util.concurrent.Future<?>> chainedFutures)
chainedFutures
- a #Future
consisting of the full broker removal operation -
the plan computation/shutdown operation and then the underlying reassignments executionpublic void execute(java.time.Duration duration) throws java.lang.Throwable
java.lang.Throwable
public boolean cancel()