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, java.lang.String identifierString, 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, java.lang.String identifierString, 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, PerformDeleteHintedHandoff hintedHandoffAction, 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.