voldemort.server.rebalance.async
Class RebalanceAsyncOperation

java.lang.Object
  voldemort.server.protocol.admin.AsyncOperation
      voldemort.server.rebalance.async.RebalanceAsyncOperation

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

StealerBasedRebalanceAsyncOperation

public abstract class RebalanceAsyncOperation
extends AsyncOperation

Field Summary

protected AdminClient	adminClient
protected java.util.concurrent.ExecutorService	executors
protected static org.apache.log4j.Logger	logger
protected MetadataStore	metadataStore
protected Rebalancer	rebalancer
protected VoldemortConfig	voldemortConfig

Fields inherited from class voldemort.server.protocol.admin.AsyncOperation

status

Constructor Summary

RebalanceAsyncOperation(Rebalancer rebalancer, VoldemortConfig voldemortConfig, MetadataStore metadataStore, int requestId, java.lang.String operationString)

Method Summary

protected java.util.concurrent.ExecutorService	createExecutors(int numThreads)
protected void	waitForShutdown()

Methods inherited from class voldemort.server.protocol.admin.AsyncOperation

getStatus, markComplete, operate, run, stop, toString, updateStatus

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

logger

protected static final org.apache.log4j.Logger logger

voldemortConfig

protected final VoldemortConfig voldemortConfig

metadataStore

protected final MetadataStore metadataStore

adminClient

protected AdminClient adminClient

executors

protected final java.util.concurrent.ExecutorService executors

rebalancer

protected Rebalancer rebalancer

Constructor Detail

RebalanceAsyncOperation

public RebalanceAsyncOperation(Rebalancer rebalancer,
                               VoldemortConfig voldemortConfig,
                               MetadataStore metadataStore,
                               int requestId,
                               java.lang.String operationString)

Method Detail

createExecutors

protected java.util.concurrent.ExecutorService createExecutors(int numThreads)

waitForShutdown

protected void waitForShutdown()