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>

Field Summary

boolean

enableHintedHandoff

Fields inherited from class voldemort.store.routed.action.AbstractKeyBasedAction

key

Fields inherited from class voldemort.store.routed.action.AbstractAction

completeEvent, logger, pipelineData

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)

Method Summary

void	execute(Pipeline pipeline) Executes some portion of the overall logic in the routing pipeline.
boolean	isHintedHandoffEnabled()

Methods inherited from class voldemort.store.routed.action.AbstractAction

handleResponseError, handleResponseError

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

enableHintedHandoff

public boolean enableHintedHandoff

Constructor Detail

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)

Method Detail

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