voldemort.server.rebalance.async
Class StealerBasedRebalanceAsyncOperation

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

All Implemented Interfaces:

java.lang.Runnable

public class StealerBasedRebalanceAsyncOperation
extends RebalanceAsyncOperation

Individual rebalancing operation run on the server side as an async operation. This is run on the stealer node

Field Summary

Fields inherited from class voldemort.server.rebalance.async.RebalanceAsyncOperation

adminClient, executors, logger, metadataStore, rebalancer, voldemortConfig

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

status

Constructor Summary

StealerBasedRebalanceAsyncOperation(Rebalancer rebalancer, VoldemortConfig voldemortConfig, MetadataStore metadataStore, int requestId, RebalanceTaskInfo stealInfo)

Method Summary

void	operate()
void	stop()

Methods inherited from class voldemort.server.rebalance.async.RebalanceAsyncOperation

createExecutors, waitForShutdown

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

getStatus, markComplete, run, toString, updateStatus

Methods inherited from class java.lang.Object

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

Constructor Detail

StealerBasedRebalanceAsyncOperation

public StealerBasedRebalanceAsyncOperation(Rebalancer rebalancer,
                                           VoldemortConfig voldemortConfig,
                                           MetadataStore metadataStore,
                                           int requestId,
                                           RebalanceTaskInfo stealInfo)

Method Detail

operate

public void operate()
             throws java.lang.Exception

Specified by:

operate in class AsyncOperation

Throws:

java.lang.Exception

stop

public void stop()

Specified by:

stop in class AsyncOperation