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>
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AbstractReadRepair
public AbstractReadRepair(PD pipelineData,
Pipeline.Event completeEvent,
int preferred,
long timeoutMs,
java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores,
ReadRepairer<ByteArray,byte[]> readRepairer)
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
Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu