voldemort.store.routed
Class GetAllPipelineData
java.lang.Object
voldemort.store.routed.PipelineData<java.lang.Iterable<ByteArray>,java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>>>
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.
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 |
GetAllPipelineData
public GetAllPipelineData()
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