public interface DataBalanceEngineContext
Modifier and Type | Method and Description |
---|---|
Set<Integer> |
brokersBeingAdded()
Returns a {#@link Set} of broker ids representing the brokers being added to the cluster
as part of a #
MultiBrokerAdditionOperation |
BalancerStatusTracker |
getBalancerStatusTracker() |
Map<Integer,BrokerAdditionStateManager> |
getBrokerAdditionsStateManagers()
Return the #
BrokerAdditionStateManager s for the active broker addition operations |
Map<ImmutableSet<Integer>,BrokerRemovalStateTracker> |
getBrokerRemovalsStateTrackers()
Return the #
BrokerRemovalStateTracker for the active broker removal operations |
EvenClusterLoadStateManager |
getEvenClusterLoadStateManager() |
ApiStatePersistenceStore |
getPersistenceStore()
Return persistence store associated with this DataBalanceEngineContext.
|
void |
putBrokerStateManager(BrokerAdditionStateManager stateManager) |
ApiStatePersistenceStore getPersistenceStore()
Map<ImmutableSet<Integer>,BrokerRemovalStateTracker> getBrokerRemovalsStateTrackers()
BrokerRemovalStateTracker
for the active broker removal operationsMap<Integer,BrokerAdditionStateManager> getBrokerAdditionsStateManagers()
BrokerAdditionStateManager
s for the active broker addition operationsBalancerStatusTracker getBalancerStatusTracker()
EvenClusterLoadStateManager getEvenClusterLoadStateManager()
void putBrokerStateManager(BrokerAdditionStateManager stateManager)
Set<Integer> brokersBeingAdded()
MultiBrokerAdditionOperation