voldemort.store.routed
Class GetAllPipelineData

java.lang.Object
  extended by voldemort.store.routed.PipelineData<java.lang.Iterable<ByteArray>,java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>>
      extended by voldemort.store.routed.GetAllPipelineData

public class GetAllPipelineData
extends PipelineData<java.lang.Iterable<ByteArray>,java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>>

This is used only by the "get all" operation as it includes data specific only to that operation.


Field Summary
 
Fields inherited from class voldemort.store.routed.PipelineData
failedNodes, failures, fatalError, replicationSet, stats, storeName
 
Constructor Summary
GetAllPipelineData()
           
 
Method Summary
 java.util.Map<ByteArray,java.util.List<Node>> getKeyToExtraNodesMap()
           
 java.util.Map<ByteArray,java.util.HashSet<java.lang.Integer>> getKeyToZoneResponse()
           
 java.util.Map<Node,java.util.List<ByteArray>> getNodeToKeysMap()
           
 java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>> getResult()
           
 org.apache.commons.lang.mutable.MutableInt getSuccessCount(ByteArray key)
           
 java.util.Map<ByteArray,byte[]> getTransforms()
           
 java.lang.Integer getZonesRequired()
           
 void setKeyToExtraNodesMap(java.util.Map<ByteArray,java.util.List<Node>> keyToExtraNodesMap)
           
 void setNodeToKeysMap(java.util.Map<Node,java.util.List<ByteArray>> nodeToKeysMap)
           
 void setTransforms(java.util.Map<ByteArray,byte[]> transforms)
           
 void setZonesRequired(java.lang.Integer zonesRequired)
           
 
Methods inherited from class voldemort.store.routed.PipelineData
addFailedNode, getFailedNodes, getFailures, getFatalError, getReplicationSet, getResponses, getStoreName, recordFailure, reportException, setFatalError, setReplicationSet, setStats, setStoreName
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

GetAllPipelineData

public GetAllPipelineData()
Method Detail

getKeyToZoneResponse

public java.util.Map<ByteArray,java.util.HashSet<java.lang.Integer>> getKeyToZoneResponse()

getResult

public java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>> getResult()

getNodeToKeysMap

public java.util.Map<Node,java.util.List<ByteArray>> getNodeToKeysMap()

setNodeToKeysMap

public void setNodeToKeysMap(java.util.Map<Node,java.util.List<ByteArray>> nodeToKeysMap)

getKeyToExtraNodesMap

public java.util.Map<ByteArray,java.util.List<Node>> getKeyToExtraNodesMap()

getTransforms

public java.util.Map<ByteArray,byte[]> getTransforms()

setTransforms

public void setTransforms(java.util.Map<ByteArray,byte[]> transforms)

setKeyToExtraNodesMap

public void setKeyToExtraNodesMap(java.util.Map<ByteArray,java.util.List<Node>> keyToExtraNodesMap)

getSuccessCount

public org.apache.commons.lang.mutable.MutableInt getSuccessCount(ByteArray key)

setZonesRequired

public void setZonesRequired(java.lang.Integer zonesRequired)

getZonesRequired

public java.lang.Integer getZonesRequired()


Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu