voldemort.store.routed.action
Class PerformSerialRequests<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.PerformSerialRequests<V,PD>
- All Implemented Interfaces:
- Action
public class PerformSerialRequests<V,PD extends BasicPipelineData<V>>
- extends AbstractKeyBasedAction<ByteArray,V,PD>
|
Constructor Summary |
PerformSerialRequests(PD pipelineData,
Pipeline.Event completeEvent,
ByteArray key,
FailureDetector failureDetector,
java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> stores,
int preferred,
int required,
StoreRequest<V> storeRequest,
Pipeline.Event insufficientSuccessesEvent)
|
|
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 |
PerformSerialRequests
public PerformSerialRequests(PD pipelineData,
Pipeline.Event completeEvent,
ByteArray key,
FailureDetector failureDetector,
java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> stores,
int preferred,
int required,
StoreRequest<V> storeRequest,
Pipeline.Event insufficientSuccessesEvent)
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