voldemort.store.routed.action
Class AbstractReadRepair<K,V,PD extends PipelineData<K,V>>

java.lang.Object
  voldemort.store.routed.action.AbstractAction<K,V,PD>
      voldemort.store.routed.action.AbstractReadRepair<K,V,PD>

All Implemented Interfaces:

Action

Direct Known Subclasses:

GetAllReadRepair, ReadRepair

public abstract class AbstractReadRepair<K,V,PD extends PipelineData<K,V>>
extends AbstractAction<K,V,PD>

Field Summary

Fields inherited from class voldemort.store.routed.action.AbstractAction

completeEvent, logger, pipelineData

Constructor Summary

AbstractReadRepair(PD pipelineData, Pipeline.Event completeEvent, int preferred, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, ReadRepairer<ByteArray,byte[]> readRepairer)

Method Summary

void	execute(Pipeline pipeline) Executes some portion of the overall logic in the routing pipeline.
protected void	insertNodeValue(Node node, ByteArray key, java.util.List<Versioned<byte[]>> value)
protected abstract void	insertNodeValues()

Methods inherited from class voldemort.store.routed.action.AbstractAction

handleResponseError, handleResponseError

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractReadRepair

public AbstractReadRepair(PD pipelineData,
                          Pipeline.Event completeEvent,
                          int preferred,
                          long timeoutMs,
                          java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores,
                          ReadRepairer<ByteArray,byte[]> readRepairer)

Method Detail

insertNodeValues

protected abstract void insertNodeValues()

insertNodeValue

protected void insertNodeValue(Node node,
                               ByteArray key,
                               java.util.List<Versioned<byte[]>> value)

execute

public void execute(Pipeline pipeline)

Description copied from interface: Action

Executes some portion of the overall logic in the routing pipeline.

Parameters:

pipeline - Pipeline instance of which this action is a part, used for adding events to the event queue or getting the Pipeline.Operation that resulted in the action being called