Uses of Interface
voldemort.store.nonblockingstore.NonblockingStore

Packages that use NonblockingStore
voldemort.store.nonblockingstore Non-blocking store which deals with async requests. 
voldemort.store.routed A store implmentation that handles routing to nodes, and repairing obsolete values detected on those nodes. 
voldemort.store.routed.action Classes representing various states for the state based routing stores. 
voldemort.store.slop A store implementation that falls back on storing values in additional nodes not in the preference list when nodes are unavailable. 
voldemort.store.socket A store implementation that works remotely over a tcp/ip socket interacting with a SocketServer on the the other side. 
 

Uses of NonblockingStore in voldemort.store.nonblockingstore
 

Classes in voldemort.store.nonblockingstore that implement NonblockingStore
 class ThreadPoolBasedNonblockingStoreImpl
           
 

Methods in voldemort.store.nonblockingstore with parameters of type NonblockingStore
 void NonblockingStoreRequest.submit(Node node, NonblockingStore store, NonblockingStoreCallback callback)
          Submits the request to the given NonblockingStore.
 

Uses of NonblockingStore in voldemort.store.routed
 

Fields in voldemort.store.routed with type parameters of type NonblockingStore
protected  java.util.Map<java.lang.Integer,NonblockingStore> PipelineRoutedStore.nonblockingSlopStores
           
protected  java.util.Map<java.lang.Integer,NonblockingStore> PipelineRoutedStore.nonblockingStores
           
 

Methods in voldemort.store.routed that return NonblockingStore
 NonblockingStore RoutedStoreFactory.toNonblockingStore(Store<ByteArray,byte[],byte[]> store)
           
 

Method parameters in voldemort.store.routed with type arguments of type NonblockingStore
 RoutedStore RoutedStoreFactory.create(Cluster cluster, StoreDefinition storeDefinition, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> nodeStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, FailureDetector failureDetector, RoutedStoreConfig routedStoreConfig)
           
 RoutedStore RoutedStoreFactory.create(Cluster cluster, StoreDefinition storeDefinition, java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> nodeStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, FailureDetector failureDetector, RoutedStoreConfig routedStoreConfig)
           
 

Constructor parameters in voldemort.store.routed with type arguments of type NonblockingStore
PipelineRoutedStore(java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> innerStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, Cluster cluster, StoreDefinition storeDef, FailureDetector failureDetector, boolean repairReads, TimeoutConfig timeoutConfig, int clientZoneId, boolean isJmxEnabled, int jmxId, ZoneAffinity zoneAffinity)
          Create a PipelineRoutedStore
PipelineRoutedStore(java.util.Map<java.lang.Integer,Store<ByteArray,byte[],byte[]>> innerStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, Cluster cluster, StoreDefinition storeDef, FailureDetector failureDetector, boolean repairReads, TimeoutConfig timeoutConfig, int clientZoneId, boolean isJmxEnabled, int jmxId, ZoneAffinity zoneAffinity)
          Create a PipelineRoutedStore
 

Uses of NonblockingStore in voldemort.store.routed.action
 

Constructor parameters in voldemort.store.routed.action with type arguments of type NonblockingStore
AbstractReadRepair(PD pipelineData, Pipeline.Event completeEvent, int preferred, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, ReadRepairer<ByteArray,byte[]> readRepairer)
           
GetAllReadRepair(GetAllPipelineData pipelineData, Pipeline.Event completeEvent, int preferred, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, ReadRepairer<ByteArray,byte[]> readRepairer)
           
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)
           
PerformParallelGetAllRequests(GetAllPipelineData pipelineData, Pipeline.Event completeEvent, FailureDetector failureDetector, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores)
           
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)
           
PerformParallelRequests(PD pipelineData, Pipeline.Event completeEvent, ByteArray key, byte[] transforms, FailureDetector failureDetector, int preferred, int required, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, Pipeline.Event insufficientSuccessesEvent, Pipeline.Event insufficientZonesEvent)
           
ReadRepair(PD pipelineData, Pipeline.Event completeEvent, int preferred, long timeoutMs, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores, ReadRepairer<ByteArray,byte[]> readRepairer)
           
 

Uses of NonblockingStore in voldemort.store.slop
 

Constructor parameters in voldemort.store.slop with type arguments of type NonblockingStore
HintedHandoff(FailureDetector failureDetector, java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores, java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores, HintedHandoffStrategy handoffStrategy, java.util.List<Node> failedNodes, long timeoutMs)
          Create a Hinted Handoff object
 

Uses of NonblockingStore in voldemort.store.socket
 

Classes in voldemort.store.socket that implement NonblockingStore
 class SocketStore
          The client implementation of a socket store--translates each request into a network operation to be handled by the socket server on the other side.
 



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