voldemort.store.routed.action
Class ReadRepair<PD extends BasicPipelineData<java.util.List<Versioned<byte[]>>>>

java.lang.Object
  voldemort.store.routed.action.AbstractAction<K,V,PD>
      voldemort.store.routed.action.AbstractReadRepair<ByteArray,java.util.List<Versioned<byte[]>>,PD>
          voldemort.store.routed.action.ReadRepair<PD>

All Implemented Interfaces:

Action

public class ReadRepair<PD extends BasicPipelineData<java.util.List<Versioned<byte[]>>>>
extends AbstractReadRepair<ByteArray,java.util.List<Versioned<byte[]>>,PD>

Field Summary

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

completeEvent, logger, pipelineData

Constructor Summary

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

Method Summary

protected void

insertNodeValues()

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

execute, insertNodeValue

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

ReadRepair

public ReadRepair(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 void insertNodeValues()

Specified by:

insertNodeValues in class AbstractReadRepair<ByteArray,java.util.List<Versioned<byte[]>>,PD extends BasicPipelineData<java.util.List<Versioned<byte[]>>>>