voldemort.server.scheduler.slop
Class BlockingSlopPusherJob

java.lang.Object
  extended by voldemort.server.scheduler.slop.BlockingSlopPusherJob
All Implemented Interfaces:
java.lang.Runnable

public class BlockingSlopPusherJob
extends java.lang.Object
implements java.lang.Runnable

A task which goes through the slop table and attempts to push out all the slop to its rightful owner node


Field Summary
static java.lang.String TYPE_NAME
           
 
Constructor Summary
BlockingSlopPusherJob(StoreRepository storeRepo, MetadataStore metadataStore, FailureDetector failureDetector, VoldemortConfig voldemortConfig, ScanPermitWrapper repairPermits)
           
 
Method Summary
 void run()
          Loop over entries in the slop table and attempt to push them to the deserving server
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

TYPE_NAME

public static final java.lang.String TYPE_NAME
See Also:
Constant Field Values
Constructor Detail

BlockingSlopPusherJob

public BlockingSlopPusherJob(StoreRepository storeRepo,
                             MetadataStore metadataStore,
                             FailureDetector failureDetector,
                             VoldemortConfig voldemortConfig,
                             ScanPermitWrapper repairPermits)
Method Detail

run

public void run()
Loop over entries in the slop table and attempt to push them to the deserving server

Specified by:
run in interface java.lang.Runnable


Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu