voldemort.store.routed.action
Class PerformParallelDeleteRequests<V,PD extends BasicPipelineData<V>>
java.lang.Object
voldemort.store.routed.action.AbstractAction<K,V,PD>
voldemort.store.routed.action.AbstractKeyBasedAction<ByteArray,V,PD>
voldemort.store.routed.action.PerformParallelDeleteRequests<V,PD>
- All Implemented Interfaces:
- Action
public class PerformParallelDeleteRequests<V,PD extends BasicPipelineData<V>>
- extends AbstractKeyBasedAction<ByteArray,V,PD>
|
Constructor Summary |
PerformParallelDeleteRequests(PD pipelineData,
Pipeline.Event completeEvent,
ByteArray key,
FailureDetector failureDetector,
int preferred,
int required,
long timeoutMs,
java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores,
HintedHandoff hintedHandoff,
Version version)
|
|
Method Summary |
void |
execute(Pipeline pipeline)
Executes some portion of the overall logic in the routing pipeline. |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PerformParallelDeleteRequests
public PerformParallelDeleteRequests(PD pipelineData,
Pipeline.Event completeEvent,
ByteArray key,
FailureDetector failureDetector,
int preferred,
int required,
long timeoutMs,
java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores,
HintedHandoff hintedHandoff,
Version version)
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