Package | Description |
---|---|
com.basho.riak.client.bucket |
A bucket is a namespace abstraction provided by Riak, the API uses
Bucket as the primary way to interact
with data stored in Riak. |
com.basho.riak.client.operations |
The interfaces/classes that model the set of operations for talking to Riak.
|
Modifier and Type | Method and Description |
---|---|
StoreObject<IRiakObject> |
DefaultBucket.store(String key,
byte[] value)
Convenience method to create a RiakObject with a payload of
application/octect-stream
|
StoreObject<IRiakObject> |
Bucket.store(String key,
byte[] value)
Creates a
StoreObject that will store a new IRiakObject . |
StoreObject<IRiakObject> |
DefaultBucket.store(String key,
String value)
Convenience methods will create an
IRiakObject with
value as the data payload and
text/plain:charset=utf-8 as the contentType |
StoreObject<IRiakObject> |
Bucket.store(String key,
String value)
Creates a
StoreObject that will store a new IRiakObject . |
<T> StoreObject<T> |
DefaultBucket.store(String key,
T o)
Store an instance of
T in Riak. |
<T> StoreObject<T> |
Bucket.store(String key,
T o)
|
<T> StoreObject<T> |
DefaultBucket.store(T o)
Store an instance of
T in Riak. |
<T> StoreObject<T> |
Bucket.store(T o)
|
Modifier and Type | Method and Description |
---|---|
StoreObject<T> |
StoreObject.asis(boolean asis)
If you don't know what this is or what it does, you should not
be using it.
|
StoreObject<T> |
StoreObject.basicQuorum(boolean basicQuorum)
fail early if a quorum of error/notfounds are reached before a successful
read (for the pre-store fetch)
|
StoreObject<T> |
StoreObject.dw(int dw)
The durable write quorum for this store operation
|
StoreObject<T> |
StoreObject.dw(Quora dw)
The durable write quorum for this store operation
|
StoreObject<T> |
StoreObject.dw(Quorum dw)
The durable write quorum for this store operation
|
StoreObject<T> |
StoreObject.ifNoneMatch(boolean ifNoneMatch)
Default is false (i.e.
|
StoreObject<T> |
StoreObject.ifNotModified(boolean ifNotModified)
Default is false (i.e.
|
StoreObject<T> |
StoreObject.notFoundOK(boolean notFoundOK)
if notfound_ok counts towards r count (for the pre-store fetch)
|
StoreObject<T> |
StoreObject.pr(int pr)
The pr for the pre-store fetch
|
StoreObject<T> |
StoreObject.pr(Quora pr)
The pr for the pre-store fetch
|
StoreObject<T> |
StoreObject.pr(Quorum pr)
The pr for the pre-store fetch
|
StoreObject<T> |
StoreObject.pw(int pw)
Set the primary write quorum for the store operation, takes precedence
over w.
|
StoreObject<T> |
StoreObject.pw(Quora pw)
Set the primary write quorum for the store operation, takes precedence
over w.
|
StoreObject<T> |
StoreObject.pw(Quorum pw)
Set the primary write quorum for the store operation, takes precedence
over w.
|
StoreObject<T> |
StoreObject.r(int r)
A store performs a fetch first (to get a vclock and resolve any conflicts), set the read quorum for the fetch
|
StoreObject<T> |
StoreObject.r(Quora r)
A store performs a fetch first (to get a vclock and resolve any conflicts), set the read quorum for the fetch
|
StoreObject<T> |
StoreObject.r(Quorum r)
A store performs a fetch first (to get a vclock and resolve any conflicts), set the read quorum for the fetch
|
StoreObject<T> |
StoreObject.returnBody(boolean returnBody)
Should the store operation return a response body?
|
StoreObject<T> |
StoreObject.returnDeletedVClock(boolean returnDeletedVClock)
If the object has just been deleted, there maybe a tombstone value
vclock, set to true to have this returned in the pre-store fetch.
|
StoreObject<T> |
StoreObject.timeout(int timeout)
Set an operation timeout in milliseconds to be sent to Riak
As of 1.4 Riak allows a timeout to be sent for get, put, and delete operations.
|
StoreObject<T> |
StoreObject.w(int w)
Set the write quorum for the store operation
|
StoreObject<T> |
StoreObject.w(Quora w)
Set the write quorum for the store operation
|
StoreObject<T> |
StoreObject.w(Quorum w)
Set the write quorum for the store operation
|
StoreObject<T> |
StoreObject.withConverter(Converter<T> converter)
The
Converter to use |
StoreObject<T> |
StoreObject.withMutator(Mutation<T> mutation)
The
Mutation to apply to the value retrieved from the fetch operation |
StoreObject<T> |
StoreObject.withoutFetch()
Eliminates fetching the existing value before storing the current one.
|
StoreObject<T> |
StoreObject.withResolver(ConflictResolver<T> resolver)
The
ConflictResolver to use on any sibling results returned from the fetch (and store if returnBody is true)
NOTE: since it is used for fetch and after store must be reusable. |
StoreObject<T> |
StoreObject.withRetrier(Retrier retrier)
The
Retrier to use for the fetch and store operations. |
StoreObject<T> |
StoreObject.withValue(T value)
Creates a
ClobberMutation that applies value |
Copyright © 2014. All Rights Reserved.