voldemort.client.rebalance.task
Class StealerBasedRebalanceTask

java.lang.Object
  voldemort.client.rebalance.task.RebalanceTask
      voldemort.client.rebalance.task.StealerBasedRebalanceTask

All Implemented Interfaces:

java.lang.Runnable

public class StealerBasedRebalanceTask
extends RebalanceTask

Immutable class that executes a RebalanceTaskInfo instance on the rebalance client side. This is run from the stealer nodes perspective

Field Summary

Fields inherited from class voldemort.client.rebalance.task.RebalanceTask

adminClient, batchId, donorPermit, exception, INVALID_REBALANCE_ID, isComplete, loggerToUse, partitionStoreCount, permitAcquisitionTimeMs, progressBar, stealInfos, taskCompletionTimeMs, taskId

Constructor Summary

StealerBasedRebalanceTask(int batchId, int taskId, RebalanceTaskInfo stealInfo, java.util.concurrent.Semaphore donorPermit, AdminClient adminClient, RebalanceBatchPlanProgressBar progressBar, RebalanceScheduler scheduler)

Method Summary

void	run()
java.lang.String	toString()

Methods inherited from class voldemort.client.rebalance.task.RebalanceTask

acquirePermit, getError, getStealInfos, hasException, isComplete, permitAcquired, permitStart, taskDone, taskLog, taskStart

Methods inherited from class java.lang.Object

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

Constructor Detail

StealerBasedRebalanceTask

public StealerBasedRebalanceTask(int batchId,
                                 int taskId,
                                 RebalanceTaskInfo stealInfo,
                                 java.util.concurrent.Semaphore donorPermit,
                                 AdminClient adminClient,
                                 RebalanceBatchPlanProgressBar progressBar,
                                 RebalanceScheduler scheduler)

Method Detail

run

public void run()

toString

public java.lang.String toString()

Overrides:

toString in class RebalanceTask