voldemort.store.routed.action
Class GetAllReadRepair
java.lang.Object
voldemort.store.routed.action.AbstractAction<K,V,PD>
voldemort.store.routed.action.AbstractReadRepair<java.lang.Iterable<ByteArray>,java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>,GetAllPipelineData>
voldemort.store.routed.action.GetAllReadRepair
- All Implemented Interfaces:
- Action
public class GetAllReadRepair
- extends AbstractReadRepair<java.lang.Iterable<ByteArray>,java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>,GetAllPipelineData>
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
GetAllReadRepair
public GetAllReadRepair(GetAllPipelineData pipelineData,
Pipeline.Event completeEvent,
int preferred,
long timeoutMs,
java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores,
ReadRepairer<ByteArray,byte[]> readRepairer)
insertNodeValues
protected void insertNodeValues()
- Specified by:
insertNodeValues
in class AbstractReadRepair<java.lang.Iterable<ByteArray>,java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>,GetAllPipelineData>
Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu