voldemort.store.routed.action
Class PerformParallelPutRequests
java.lang.Object
voldemort.store.routed.action.AbstractAction<K,V,PD>
voldemort.store.routed.action.AbstractKeyBasedAction<ByteArray,java.lang.Void,PutPipelineData>
voldemort.store.routed.action.PerformParallelPutRequests
- All Implemented Interfaces:
- Action
public class PerformParallelPutRequests
- extends AbstractKeyBasedAction<ByteArray,java.lang.Void,PutPipelineData>
Constructor Summary |
PerformParallelPutRequests(PutPipelineData pipelineData,
Pipeline.Event completeEvent,
ByteArray key,
byte[] transforms,
FailureDetector failureDetector,
int preferred,
int required,
long timeoutMs,
java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores,
HintedHandoff hintedHandoff)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
enableHintedHandoff
public boolean enableHintedHandoff
PerformParallelPutRequests
public PerformParallelPutRequests(PutPipelineData pipelineData,
Pipeline.Event completeEvent,
ByteArray key,
byte[] transforms,
FailureDetector failureDetector,
int preferred,
int required,
long timeoutMs,
java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores,
HintedHandoff hintedHandoff)
isHintedHandoffEnabled
public boolean isHintedHandoffEnabled()
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