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.builders |
These builders provide a fluid API for creating instances of some immutable
(or mainly immutable classes) that have a large number of
constructor parameters.
|
com.basho.riak.client.http.request |
Riak request classes for the legacy HTTP REST client, consider using the high-level
IRiakClient |
com.basho.riak.client.operations |
The interfaces/classes that model the set of operations for talking to Riak.
|
com.basho.riak.client.raw |
The raw interfaces/classes exist to provide unified access to any underlying transport clients for Riak
|
com.basho.riak.client.raw.http |
Classes for adapting the http.
RiakClient to the
RawClient interface |
Modifier and Type | Method and Description |
---|---|
Quorum |
TunableCAPProps.getDW() |
Quorum |
LazyBucketProperties.getDW() |
Quorum |
DefaultBucketProperties.getDW() |
Quorum |
DefaultBucket.getDW() |
Quorum |
BucketProperties.getDW()
The default
dw quorum for this bucket. |
Quorum |
TunableCAPProps.getPR() |
Quorum |
LazyBucketProperties.getPR() |
Quorum |
DefaultBucketProperties.getPR() |
Quorum |
DefaultBucket.getPR() |
Quorum |
BucketProperties.getPR()
The default
pr quorum for this bucket. |
Quorum |
TunableCAPProps.getPW() |
Quorum |
LazyBucketProperties.getPW() |
Quorum |
DefaultBucketProperties.getPW() |
Quorum |
DefaultBucket.getPW() |
Quorum |
BucketProperties.getPW()
The default
pw quorum for this bucket. |
Quorum |
TunableCAPProps.getR() |
Quorum |
LazyBucketProperties.getR() |
Quorum |
DefaultBucketProperties.getR() |
Quorum |
DefaultBucket.getR() |
Quorum |
BucketProperties.getR()
The default
r quorum for this bucket. |
Quorum |
TunableCAPProps.getRW() |
Quorum |
LazyBucketProperties.getRW() |
Quorum |
DefaultBucketProperties.getRW() |
Quorum |
DefaultBucket.getRW() |
Quorum |
BucketProperties.getRW()
The default
rw quorum for this bucket. |
Quorum |
TunableCAPProps.getW() |
Quorum |
LazyBucketProperties.getW() |
Quorum |
DefaultBucketProperties.getW() |
Quorum |
DefaultBucket.getW() |
Quorum |
BucketProperties.getW()
The default
w quorum for this bucket. |
Constructor and Description |
---|
TunableCAPProps(Quorum r,
Quorum w,
Quorum dw,
Quorum rw,
Quorum pr,
Quorum pw,
Boolean basicQuorum,
Boolean notFoundOK)
Create an instance to wrap the given set of CAP properties
|
Modifier and Type | Method and Description |
---|---|
BucketPropertiesBuilder |
BucketPropertiesBuilder.dw(Quorum dw) |
BucketPropertiesBuilder |
BucketPropertiesBuilder.pr(Quorum pr) |
BucketPropertiesBuilder |
BucketPropertiesBuilder.pw(Quorum pw) |
BucketPropertiesBuilder |
BucketPropertiesBuilder.r(Quorum r) |
BucketPropertiesBuilder |
BucketPropertiesBuilder.rw(Quorum rw) |
BucketPropertiesBuilder |
BucketPropertiesBuilder.w(Quorum w) |
Modifier and Type | Method and Description |
---|---|
static RequestMeta |
RequestMeta.writeParams(Quorum w,
Quorum dw)
Use the given w and dw params for store or delete operations.
|
Modifier and Type | Method and Description |
---|---|
StoreObject<T> |
StoreObject.dw(Quorum dw)
The durable write quorum for this store operation
|
DeleteObject |
DeleteObject.dw(Quorum dw) |
CounterObject |
CounterObject.dw(Quorum dw)
The durable write quorum for an increment operation
|
StoreObject<T> |
StoreObject.pr(Quorum pr)
The pr for the pre-store fetch
|
MultiFetchObject<T> |
MultiFetchObject.pr(Quorum pr) |
FetchObject<T> |
FetchObject.pr(Quorum pr) |
DeleteObject |
DeleteObject.pr(Quorum pr) |
CounterObject |
CounterObject.pr(Quorum pr)
The pr for a fetch operation
|
StoreObject<T> |
StoreObject.pw(Quorum pw)
Set the primary write quorum for the store operation, takes precedence
over w.
|
DeleteObject |
DeleteObject.pw(Quorum pw) |
CounterObject |
CounterObject.pw(Quorum pw)
Set the primary write quorum for an increment operation, takes precedence
over w.
|
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
|
MultiFetchObject<T> |
MultiFetchObject.r(Quorum r)
The read quorum for this fetch operation
|
FetchObject<T> |
FetchObject.r(Quorum r)
The read quorum for this fetch operation
|
DeleteObject |
DeleteObject.r(Quorum r) |
CounterObject |
CounterObject.r(Quorum r)
Set the read quorum for a fetch operation
|
DeleteObject |
DeleteObject.rw(Quorum rw)
The read_write quorum for the delete operation
|
StoreObject<T> |
StoreObject.w(Quorum w)
Set the write quorum for the store operation
|
DeleteObject |
DeleteObject.w(Quorum w) |
CounterObject |
CounterObject.w(Quorum w)
Set the write quorum for an increment operation
|
Modifier and Type | Method and Description |
---|---|
Quorum |
StoreMeta.getDw()
The durable write quorum
|
Quorum |
DeleteMeta.getDw() |
Quorum |
FetchMeta.getPr() |
Quorum |
DeleteMeta.getPr() |
Quorum |
StoreMeta.getPw()
Get the value for the pw parameter
|
Quorum |
DeleteMeta.getPw() |
Quorum |
FetchMeta.getR() |
Quorum |
DeleteMeta.getR() |
Quorum |
DeleteMeta.getRw() |
Quorum |
StoreMeta.getW()
The write quorum
|
Quorum |
DeleteMeta.getW() |
Modifier and Type | Method and Description |
---|---|
StoreMeta.Builder |
StoreMeta.Builder.dw(Quorum dw) |
DeleteMeta.Builder |
DeleteMeta.Builder.dw(Quorum dw) |
FetchMeta.Builder |
FetchMeta.Builder.pr(Quorum pr) |
DeleteMeta.Builder |
DeleteMeta.Builder.pr(Quorum pr) |
StoreMeta.Builder |
StoreMeta.Builder.pw(Quorum pw) |
DeleteMeta.Builder |
DeleteMeta.Builder.pw(Quorum pw) |
FetchMeta.Builder |
FetchMeta.Builder.r(Quorum r) |
DeleteMeta.Builder |
DeleteMeta.Builder.r(Quorum r) |
DeleteMeta.Builder |
DeleteMeta.Builder.rw(Quorum rw) |
StoreMeta.Builder |
StoreMeta.Builder.w(Quorum w) |
DeleteMeta.Builder |
DeleteMeta.Builder.w(Quorum w) |
Constructor and Description |
---|
DeleteMeta(Quorum r,
Quorum pr,
Quorum w,
Quorum dw,
Quorum pw,
Quorum rw,
VClock vclock,
Integer timeout)
Any of the parameters may be null.
|
FetchMeta(Quorum r,
Quorum pr,
Boolean notFoundOK,
Boolean basicQuorum,
Boolean headOnly,
Boolean returnDeletedVClock,
Date ifModifiedSince,
VClock ifModifiedVClock,
Integer timeout)
Create a fetch meta with the specified parameters for a conditional fetch
with the either API
|
StoreMeta(Quorum w,
Quorum dw,
Quorum pw,
Boolean returnBody,
Boolean returnHead,
Boolean ifNoneMatch,
Boolean ifNotModified,
Boolean asis,
Integer timeout)
Create a StoreMeta, accepts
null s for any parameter |
Modifier and Type | Method and Description |
---|---|
Quorum |
QuorumDeserializer.deserialize(com.fasterxml.jackson.core.JsonParser jp,
com.fasterxml.jackson.databind.DeserializationContext ctxt) |
Copyright © 2014. All Rights Reserved.