|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectvoldemort.store.AbstractStore<ByteArray,byte[],byte[]>
voldemort.store.routed.RoutedStore
voldemort.store.routed.PipelineRoutedStore
public class PipelineRoutedStore
A Store which multiplexes requests to different internal Stores
Field Summary | |
---|---|
protected HintedHandoffStrategy |
handoffStrategy
|
protected java.util.Map<java.lang.Integer,NonblockingStore> |
nonblockingSlopStores
|
protected java.util.Map<java.lang.Integer,NonblockingStore> |
nonblockingStores
|
protected java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> |
slopStores
|
Fields inherited from class voldemort.store.routed.RoutedStore |
---|
failureDetector, innerStores, logger, readRepairer, repairReads, routingStrategy, storeDef, time, timeoutConfig |
Constructor Summary | |
---|---|
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 |
Method Summary | |
---|---|
void |
close()
Close the store. |
boolean |
delete(ByteArray key,
Version version)
Delete all entries prior to the given version |
protected boolean |
delete(ByteArray key,
Version version,
long deleteOpTimeout)
|
boolean |
delete(CompositeVoldemortRequest<ByteArray,byte[]> request)
Delete all entries prior to the given version |
java.util.List<Versioned<byte[]>> |
get(ByteArray key,
byte[] transforms)
Get the value associated with the given key |
java.util.List<Versioned<byte[]>> |
get(ByteArray key,
byte[] transforms,
long getOpTimeout)
|
java.util.List<Versioned<byte[]>> |
get(CompositeVoldemortRequest<ByteArray,byte[]> request)
Get the value associated with the given key |
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>> |
getAll(CompositeVoldemortRequest<ByteArray,byte[]> request)
Get the values associated with the given keys and returns them in a Map of keys to a list of versioned values. |
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>> |
getAll(java.lang.Iterable<ByteArray> keys,
java.util.Map<ByteArray,byte[]> transforms)
Get the values associated with the given keys and returns them in a Map of keys to a list of versioned values. |
java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>> |
getAll(java.lang.Iterable<ByteArray> keys,
java.util.Map<ByteArray,byte[]> transforms,
long getAllOpTimeoutInMs)
|
java.util.List<Version> |
getVersions(ByteArray key)
Get the versions associated with the given key. |
boolean |
isHintedHandoffEnabled()
|
static boolean |
isSlopableFailure(java.lang.Object response)
|
void |
put(ByteArray key,
Versioned<byte[]> versioned,
byte[] transforms)
Associate the value with the key and version in this store |
void |
put(ByteArray key,
Versioned<byte[]> versioned,
byte[] transforms,
long putOpTimeoutInMs)
|
void |
put(CompositeVoldemortRequest<ByteArray,byte[]> request)
Associate the value with the key and version in this store |
Methods inherited from class voldemort.store.routed.RoutedStore |
---|
getCapability, getInnerStores, updateRoutingStrategy |
Methods inherited from class voldemort.store.AbstractStore |
---|
getName |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected final java.util.Map<java.lang.Integer,NonblockingStore> nonblockingStores
protected final java.util.Map<java.lang.Integer,Store<ByteArray,Slop,byte[]>> slopStores
protected final java.util.Map<java.lang.Integer,NonblockingStore> nonblockingSlopStores
protected final HintedHandoffStrategy handoffStrategy
Constructor Detail |
---|
public 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)
innerStores
- The mapping of node to clientnonblockingStores
- slopStores
- The stores for hintsnonblockingSlopStores
- cluster
- Cluster definitionstoreDef
- Store definitionMethod Detail |
---|
public java.util.List<Versioned<byte[]>> get(ByteArray key, byte[] transforms)
Store
get
in interface Store<ByteArray,byte[],byte[]>
get
in class AbstractStore<ByteArray,byte[],byte[]>
key
- The key to check for
public java.util.List<Versioned<byte[]>> get(ByteArray key, byte[] transforms, long getOpTimeout)
public java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>> getAll(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms) throws VoldemortException
Store
getAll
in interface Store<ByteArray,byte[],byte[]>
getAll
in class AbstractStore<ByteArray,byte[],byte[]>
keys
- The keys to check for.
VoldemortException
public java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>> getAll(java.lang.Iterable<ByteArray> keys, java.util.Map<ByteArray,byte[]> transforms, long getAllOpTimeoutInMs) throws VoldemortException
VoldemortException
public java.util.List<Version> getVersions(ByteArray key)
Store
getVersions
in interface Store<ByteArray,byte[],byte[]>
getVersions
in class AbstractStore<ByteArray,byte[],byte[]>
key
- The key to retrieve the versions for
public boolean delete(ByteArray key, Version version) throws VoldemortException
Store
delete
in interface Store<ByteArray,byte[],byte[]>
delete
in class AbstractStore<ByteArray,byte[],byte[]>
key
- The key to deleteversion
- The current value of the key
VoldemortException
protected boolean delete(ByteArray key, Version version, long deleteOpTimeout) throws VoldemortException
VoldemortException
public boolean isHintedHandoffEnabled()
public void put(ByteArray key, Versioned<byte[]> versioned, byte[] transforms) throws VoldemortException
Store
put
in interface Store<ByteArray,byte[],byte[]>
put
in class AbstractStore<ByteArray,byte[],byte[]>
key
- The key to useversioned
- The value to store and its version.
VoldemortException
public void put(ByteArray key, Versioned<byte[]> versioned, byte[] transforms, long putOpTimeoutInMs) throws VoldemortException
VoldemortException
public void close()
Store
close
in interface Store<ByteArray,byte[],byte[]>
close
in class RoutedStore
public java.util.List<Versioned<byte[]>> get(CompositeVoldemortRequest<ByteArray,byte[]> request) throws VoldemortException
Store
get
in interface Store<ByteArray,byte[],byte[]>
get
in class AbstractStore<ByteArray,byte[],byte[]>
request
- Contains the key to check for and associated transforms
VoldemortException
public java.util.Map<ByteArray,java.util.List<Versioned<byte[]>>> getAll(CompositeVoldemortRequest<ByteArray,byte[]> request) throws VoldemortException
Store
getAll
in interface Store<ByteArray,byte[],byte[]>
getAll
in class AbstractStore<ByteArray,byte[],byte[]>
request
- Contains the keys to check for.
VoldemortException
public void put(CompositeVoldemortRequest<ByteArray,byte[]> request) throws VoldemortException
Store
put
in interface Store<ByteArray,byte[],byte[]>
put
in class AbstractStore<ByteArray,byte[],byte[]>
request
- Contains the key to use along with the value and version
to use.
VoldemortException
public boolean delete(CompositeVoldemortRequest<ByteArray,byte[]> request) throws VoldemortException
Store
delete
in interface Store<ByteArray,byte[],byte[]>
delete
in class AbstractStore<ByteArray,byte[],byte[]>
request
- Contains the key to delete and current version of the key
VoldemortException
public static boolean isSlopableFailure(java.lang.Object response)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |