voldemort.server.scheduler.slop
Class BlockingSlopPusherJob

java.lang.Object
  voldemort.server.scheduler.slop.SlopPusherJob
      voldemort.server.scheduler.slop.BlockingSlopPusherJob

All Implemented Interfaces:

java.lang.Runnable

public class BlockingSlopPusherJob
extends SlopPusherJob
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

Fields inherited from class voldemort.server.scheduler.slop.SlopPusherJob

failureDetector, metadataStore, repairPermits, storeRepo, voldemortConfig

Constructor Summary

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

Method Summary

org.apache.log4j.Logger	getLogger()
void	run() Loop over entries in the slop table and attempt to push them to the deserving server

Methods inherited from class voldemort.server.scheduler.slop.SlopPusherJob

handleDeadSlop, isSlopDead

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

getLogger

public org.apache.log4j.Logger getLogger()

Specified by:

getLogger in class SlopPusherJob