|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
IndexQueryRangeQuery implementationRawClients with
configClass Configurations?
Call before newClient.
RiakConnectionPool if acquire times out.BinIndex value to the set
IntIndex value to the set
RiakIndex to the new riak object's collection.
RiakIndex to the new riak object's collection.
KeyFilter to the inputs for the Map/Reduce job
KeyFilters to this map/reduce operations inputs
RiakLink to the new riak object's collection.
bucket / tag
.
bucket / tag
keep will be false
MapPhase to the query
ReducePhase to the query
ReducePhase
ReducePhase
ReducePhase
Callable that loops over a classes fields and pulls out the fields
for RiakUsermeta and RiakKeyoriginal value passed in
Charset
HttpClient to a map
HttpClient to a map
Charset
Callable.call() times before giving up and
throwing a RiakRetryFailedException There is no back off.
RiakOperation execute methods to give some measure of fault tolerance.
basho_lager_version value from the Riak stats reply
basho_stats_version value from the Riak stats reply
UnsupportedPropertyException will be thrown if called for that transport
VClock that wraps a byte[]WARNING: This class will be REMOVED in the next version.
from -
toUnsupportedPropertyException will be thrown if called for that transport
BinRangeQuery
BinIndexbitcask_version value from the Riak stats reply
WARNING: This class will be REMOVED in the next version.
RiakOperations.RawClient to execute the Map/Reduce query
Use IRiakClient.mapReduce() as a factory to create your map/reduce operation.
bucket to be executed by the specified RawClient.
BucketProperties.RiakBucketInfo
WARNING: This class will be REMOVED in the next version.
RiakBucketInfo
DomainBucket
DefaultRiakObject from this builders parameters
DomainBucketBuilder for the given Bucket and Class.
byte[], String charset
issues, especially since Java 5 is less cool than Java 6 in this respect.Member accessible if possible, throw
IllegalArgumentException is not.
WARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
newValue from apply(T)
RawClient that can be configured with a cluster of Riak clients
that connect to different Riak nodes.Configuration for a "cluster" of clients.cluster_info_version value from the Riak stats reply
WARNING: This class will be REMOVED in the next version.
IRiakClient
and IRiakObject classes required to store data
in Riak, start here.Bucket as the primary way to interact
with data stored in Riak.IRiakClientIRiakClientIRiakClientIRiakClientIRiakClientIRiakClientIRiakClientBucketMapReduceRiakClient to the
RawClient interfaceRiakClient to the
RawClient interfaceRawClients for Map/Reduce and Link Walking.RawClients for secondary
index querying.IRiakClientconnected_nodes value from the Riak Stats reply
WARNING: This class will be REMOVED in the next version.
IRiakObject and your domain types.HTTPClientAdapter for converting
between http.RiakClient value classes and RawClient value
classesRiakOperation for serializing/deserializing your domain objects to IRiakObjectWARNING: This class will be REMOVED in the next version.
coord_redirs_total value from the Riak Stats reply
object.
InputStream to an OutputStream in
blocks
InputStream to an OutputStream in
blocks
cpu_avg1 value from the Riak Stats reply
cpu_avg15 value from the Riak Stats reply
cpu_avg5 value from the Riak Stats reply
cpu_nprocs value from the Riak Stats reply
WriteBucket operation
to create a Bucket named for the passed String.
crypto_version value from the Riak stats reply
Bucket for creating RiakOperations
on k/v data and accessing BucketProperties.RiakOperations created by this instance will use the
RawClient and Retrier provided here.
BucketProperties.BucketPropertiesBuilder instead of calling this constructor directly
WARNING: This class will be REMOVED in the next version.
UnresolvedConflictException.IRiakObjectHTTPClientConfig.Builder for the
defaults.
DeleteObject operation that will delete the data at
o's RiakKey annotated field value on
execute().
DeleteObject operation that will delete the data at
key on execute().
o's
RiakKey annotated field.
key
RiakClient.delete(String, String, RequestMeta), except
throws on a non-200 or 404 response.
RiakClient, except only returning the HTTP response
RiakClient.delete(String, String, RequestMeta), except
throws on a non-200 or 404 response.
bucket/key
bucket/key using
deleteQuorum as the rw param
bucket/key using the parameters in
deleteMeta
bucket and key.
RiakClient.delete(String, String, RequestMeta).
RiakClient, except only returning the HTTP response
DeleteOperation that delegates to
client to delete key from bucket
using retrier to handle failures.
UnsupportedPropertyException will be thrown if called for that
transport
Bucket that is strongly typed and uses
a preset ConflictResolver, MutationProducer, Converter, r, w, dw, rw, Retrier,
returnBody etcDomainBucket for clazz Class objects
wrapped around bucket
It is recommended to use the DomainBucketBuilder rather than this
constructor.
DomainBucketDomainBucket that stores instance of clazz in bucket
UnsupportedPropertyException will be thrown if called for that transport
UnsupportedPropertyException will be thrown if called for that transport
DomainBucket
DomainBucket
UnsupportedPropertyException will be thrown if called for that transport
WARNING: This class will be REMOVED in the next version.
endsWith
WARNING: This class will be REMOVED in the next version.
equalTo
equalTo
equalTo
WARNING: This class will be REMOVED in the next version.
erlang_js_version value from the Riak stats reply
Retrier to call the specified
RawClient's delete with bucket, key and (if specified) the rest of the delete operation parameters.
bucket/key, convert it with
Converter and resolve any siblings with ConflictResolver
bucket/key, if item exists it is converted
with Converter and any siblings resolved with
ConflictResolver.
RawClient the operation was constructed with.
RawClient the operation was
constructed with.
executing_mappers value from the Riak Stats reply
FetchObject that returns the data at key
as an IRiakObject on execute().
FetchObject operation that returns the data at
key as an instance of type T on
execute().
FetchObject operation that returns the data at
o's annotated RiakKey field as an instance of type
T on execute().
FetchObject operation that returns the data at
o's annotated RiakKey field as an instance of type
T on execute().
FetchObject operation that returns the data at
key as an instance of type T on
execute().
FetchObject that returns the data at key
as an IRiakObject on execute().
key in this bucket as an instance of
T.
o's
RiakKey annotated field as an instance of
T.
RiakClient.fetch(String, String, RequestMeta), except it
returns the fetched object directly or throws if the response is not a
200, 304 or 404.
RiakClient, except only returning the HTTP response and
allows the response to be streamed.
RiakClient.fetch(String, String, RequestMeta), except it
returns the fetched object directly or throws if the response is not a
200, 304 or 404.
bucket/key
bukcet/key with read quorum
readQuorum
bucket/key with
fetchMeta
RiakObject (which can include sibling objects) stored
at bucket and key.
RiakClient.fetch(String, String)
followed by RiakObject.copyData(RiakObject)
RiakClient, except only returning the HTTP response and
allows the response to be streamed.
RiakClient.fetch(String, String, RequestMeta), except it
returns the all the fetched objects directly or throws if the response is
not a 200, 304 or 404.
RiakClient.fetch(String, String, RequestMeta), except it
returns the all the fetched objects directly or throws if the response is
not a 200, 304 or 404.
RiakOperation that gets a Bucket from Riak.RawClient.
FetchBucket operation, and return it.
FetchIndex operation for the given index name and type
RiakClient.fetchMeta(String, String, RequestMeta), except it
returns the fetched object metadata directly or throws if the response is
not a 200, 304 or 404.
RiakClient, except only returning the HTTP response
RiakClient.fetchMeta(String, String, RequestMeta), except it
returns the fetched object metadata directly or throws if the response is
not a 200, 304 or 404.
RiakClient.fetchMeta(String, String, RequestMeta) followed by
RiakObject.updateMeta(FetchResponse)
RiakClient, except only returning the HTTP response
client to fetch the data from bucket at
key using retrier
RiakObject.
WARNING: This class will be REMOVED in the next version.
RiakObject.
WARNING: This class will be REMOVED in the next version.
BucketPropertiesBuilder populated from the given
DefaultBucketProperties.
IRiakObject.
copyConfig
copyConfig
ClusterConfig.
domainObject to a JSON string and sets that as the
payload of a IRiakObject.
BucketPropertiesBuilder populated with my values.
Quora for the given name
RiakClient.getBucketSchema(String, RequestMeta), except
only returning the HTTP response.
RiakClient.getBucketSchema(String, RequestMeta), except
only returning the HTTP response.
Map of HTTP
headers.
Charset from a contentType string.
RiakClient.getClientId()
RiakClient.getClientId()
dw quorum for this bucket.
HttpClient used to make requests, which can be
configured.
HttpClient used to make requests, which can be
configured.
HttpClient used to make requests, which can be
configured.
HttpRequestBase used to make the HTTP request.
HttpMethod used to make the HTTP request.
VClock to use in a conditional fetch with the PB API.
domainObject by looking for a
RiakKey annotated field.
domainObject by looking for a
RiakKey annotated field.
RiakLinks from this object.
RiakObject#iterableLinks()) to iterate over the
collection of RiakLinks. Attempting to mutate the
collection will result in UnsupportedOperationException in
future versions. Use RiakObject#addLink() and RiakObject#removeLink() instead.
Use RiakObject.hasLinks(), RiakObject.numLinks() and RiakObject.hasLink(RiakLink)
to query state of links.
pr quorum for this bucket.
pw quorum for this bucket.
RequestMeta in the form: p1=v1&p2=v2
RequestMeta in the form: p1=v1&p2=v2
r quorum for this bucket.
RiakClient to which this map reduce job will be submitted to
when MapReduceBuilder.submit() is called.
RiakClient to which this map reduce job will be submitted to
when MapReduceBuilder.submit() is called.
RiakObject can be loosely attached to the RiakClient
from which retrieve it was retrieved.
RiakClient to which this map reduce job will be submitted to
when MapReduceBuilder.submit() is called.
IRiakObject (not a clone or copy, so treat it well)
rw quorum for this bucket.
maxSize, zero is limitless.
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbBucketProps
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbContent
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbDelReq
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbErrorResp
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbGetBucketReq
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbGetBucketResp
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbGetClientIdResp
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbGetReq
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbGetResp
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbGetServerInfoResp
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbLink
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbListBucketsResp
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbListKeysReq
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbListKeysResp
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbMapRedReq
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbMapRedResp
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbPair
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbPutReq
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbPutResp
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbSetBucketReq
-
- getSerializedSize() -
Method in class com.basho.riak.pbc.RPB.RpbSetClientIdReq
-
- getServerInfo() -
Method in class com.basho.riak.pbc.RiakClient
-
- getServerVersion() -
Method in class com.basho.riak.pbc.RPB.RpbGetServerInfoResp.Builder
-
- getServerVersion() -
Method in class com.basho.riak.pbc.RPB.RpbGetServerInfoResp
-
- getSiblings() -
Method in exception com.basho.riak.client.cap.UnresolvedConflictException
- Get the siblings that could not be resolved.
- getSiblings() -
Method in class com.basho.riak.client.http.response.FetchResponse
- Returns a collection of the Riak objects contained in the response.
- getSiblings() -
Method in class com.basho.riak.client.http.response.StoreResponse
-
- getSiblings() -
Method in interface com.basho.riak.client.http.response.WithBodyResponse
-
- getSiblings() -
Method in class com.basho.riak.client.response.FetchResponse
- Deprecated. Returns a collection of the Riak objects contained in the response.
- getSiblings() -
Method in class com.basho.riak.client.response.StoreResponse
- Deprecated.
- getSiblings() -
Method in interface com.basho.riak.client.response.WithBodyResponse
- Deprecated.
- getSmallVClock() -
Method in interface com.basho.riak.client.bucket.BucketProperties
- the small_vclock property for this bucket.
- getSmallVClock() -
Method in class com.basho.riak.client.bucket.DefaultBucket
-
- getSmallVClock() -
Method in class com.basho.riak.client.bucket.DefaultBucketProperties
-
- getSmallVClock() -
Method in class com.basho.riak.client.bucket.LazyBucketProperties
-
- getSmallVClock() -
Method in class com.basho.riak.client.bucket.VClockPruneProps
- the small_vclock property for this bucket.
- getSocketBufferSizeKb() -
Method in class com.basho.riak.client.raw.pbc.PBClientConfig
-
- getSource() -
Method in class com.basho.riak.client.query.functions.JSSourceFunction
-
- getStartBucket() -
Method in class com.basho.riak.client.raw.query.LinkWalkSpec
- The bucket of the object to walk from.
- getStartKey() -
Method in class com.basho.riak.client.raw.query.LinkWalkSpec
- The key of the object to walk from.
- getStatsUrl() -
Method in class com.basho.riak.client.http.RiakConfig
- The full URL of the Riak status (stats) resource, which is calculated by
combining the host and port from the Riak URL and the stats path.
- getStatusCode() -
Method in exception com.basho.riak.client.http.plain.RiakResponseException
-
- getStatusCode() -
Method in class com.basho.riak.client.http.response.DefaultHttpResponse
-
- getStatusCode() -
Method in interface com.basho.riak.client.http.response.HttpResponse
- Resulting status code from the HTTP request.
- getStatusCode() -
Method in class com.basho.riak.client.http.response.HttpResponseDecorator
-
- getStatusCode() -
Method in exception com.basho.riak.client.http.response.RiakResponseRuntimeException
-
- getStatusCode() -
Method in exception com.basho.riak.client.plain.RiakResponseException
- Deprecated.
- getStatusCode() -
Method in class com.basho.riak.client.response.DefaultHttpResponse
- Deprecated.
- getStatusCode() -
Method in interface com.basho.riak.client.response.HttpResponse
- Deprecated. Resulting status code from the HTTP request.
- getStatusCode() -
Method in class com.basho.riak.client.response.HttpResponseDecorator
- Deprecated.
- getStatusCode() -
Method in exception com.basho.riak.client.response.RiakResponseRuntimeException
- Deprecated.
- getSteps() -
Method in class com.basho.riak.client.http.response.WalkResponse
- Steps accumulated from link walking.
- getSteps() -
Method in class com.basho.riak.client.response.WalkResponse
- Deprecated. Steps accumulated from link walking.
- getStream() -
Method in exception com.basho.riak.client.http.plain.RiakResponseException
-
- getStream() -
Method in class com.basho.riak.client.http.response.DefaultHttpResponse
-
- getStream() -
Method in interface com.basho.riak.client.http.response.HttpResponse
- The HTTP response body as an input stream if isStreamed(); null otherwise
- getStream() -
Method in class com.basho.riak.client.http.response.HttpResponseDecorator
-
- getStream() -
Method in exception com.basho.riak.client.http.response.RiakResponseRuntimeException
-
- getStream() -
Method in class com.basho.riak.client.http.util.Multipart.Part
-
- getStream() -
Method in exception com.basho.riak.client.plain.RiakResponseException
- Deprecated.
- getStream() -
Method in class com.basho.riak.client.response.DefaultHttpResponse
- Deprecated.
- getStream() -
Method in interface com.basho.riak.client.response.HttpResponse
- Deprecated. The HTTP response body as an input stream if isStreamed(); null otherwise
- getStream() -
Method in class com.basho.riak.client.response.HttpResponseDecorator
- Deprecated.
- getStream() -
Method in exception com.basho.riak.client.response.RiakResponseRuntimeException
- Deprecated.
- getStream() -
Method in class com.basho.riak.client.util.Multipart.Part
- Deprecated.
- getString(int) -
Method in class org.json.JSONArray
- Get the string associated with an index.
- getString(String) -
Method in class org.json.JSONObject
- Get the string associated with a key.
- getSuffix() -
Method in class com.basho.riak.client.query.indexes.BinIndex
-
- getSuffix() -
Method in class com.basho.riak.client.query.indexes.IntIndex
-
- getSuffix() -
Method in class com.basho.riak.client.query.indexes.KeyIndex
-
- getSuffix() -
Method in class com.basho.riak.client.query.indexes.RiakIndex
-
- getSymbolicValue() -
Method in class com.basho.riak.client.cap.Quorum
- Get the Symbolic value of this quorum.
- getTag() -
Method in class com.basho.riak.client.http.RiakLink
-
- getTag() -
Method in class com.basho.riak.client.query.LinkPhase
- The tag for this link phase
- getTag() -
Method in class com.basho.riak.client.query.LinkWalkStep
-
- getTag() -
Method in class com.basho.riak.client.RiakLink
-
- getTag() -
Method in class com.basho.riak.pbc.RiakLink
-
- getTag() -
Method in class com.basho.riak.pbc.RPB.RpbLink.Builder
-
- getTag() -
Method in class com.basho.riak.pbc.RPB.RpbLink
-
- getTimeout() -
Method in class com.basho.riak.client.http.request.MapReduceBuilder
- Gets the currently assigned timeout
- getTimeout() -
Method in class com.basho.riak.client.http.RiakConfig
-
- getTimeout() -
Method in class com.basho.riak.client.raw.http.HTTPClientConfig
-
- getTimeout() -
Method in class com.basho.riak.client.request.MapReduceBuilder
- Deprecated. Gets the currently assigned timeout
- getTimeout() -
Method in class com.basho.riak.client.RiakConfig
- Deprecated.
- getTimeout() -
Method in class com.basho.riak.pbc.mapreduce.MapReduceBuilder
- Gets the currently assigned timeout
- getTotalMaximumConnections() -
Method in class com.basho.riak.client.raw.config.ClusterConfig
-
- getTransport() -
Method in exception com.basho.riak.client.bucket.UnsupportedPropertyException
-
- getTransport() -
Method in class com.basho.riak.client.DefaultRiakClient
-
- getTransport() -
Method in interface com.basho.riak.client.IRiakClient
- Optional method, the underlying transport.
- getTransport() -
Method in class com.basho.riak.client.raw.http.HTTPClientAdapter
-
- getTransport() -
Method in class com.basho.riak.client.raw.http.HTTPClusterClient
-
- getTransport() -
Method in class com.basho.riak.client.raw.pbc.PBClientAdapter
-
- getTransport() -
Method in class com.basho.riak.client.raw.pbc.PBClusterClient
-
- getTransport() -
Method in interface com.basho.riak.client.raw.RawClient
- The raw transport name.
- getType() -
Method in class com.basho.riak.client.convert.reflect.RiakIndexField
-
- getType() -
Method in class com.basho.riak.client.query.LinkPhase
-
- getType() -
Method in class com.basho.riak.client.query.MapPhase
-
- getType() -
Method in interface com.basho.riak.client.query.MapReducePhase
- The PhaseType of this
MapReducePhase implementation.
- getType() -
Method in class com.basho.riak.client.query.ReducePhase
-
- getUnchanged() -
Method in class com.basho.riak.pbc.RPB.RpbGetResp.Builder
-
- getUnchanged() -
Method in class com.basho.riak.pbc.RPB.RpbGetResp
-
- getUrl() -
Method in class com.basho.riak.client.http.RiakConfig
- The base URL used by a client to construct object URLs
- getUrl() -
Method in class com.basho.riak.client.raw.http.HTTPClientConfig
-
- getUrl() -
Method in class com.basho.riak.client.RiakConfig
- Deprecated. The base URL used by a client to construct object URLs
- getUsermeta(String) -
Method in class com.basho.riak.client.DefaultRiakObject
-
- getUsermeta() -
Method in class com.basho.riak.client.http.RiakObject
- Deprecated.
- getUsermeta(String) -
Method in interface com.basho.riak.client.IRiakObject
- Get the user meta data item for that key.
- getUsermeta() -
Method in class com.basho.riak.client.RiakObject
- Deprecated. Future versions will return an unmodifiable view of the user meta. Please use
RiakObject#addUsermeta(String, String),
RiakObject.removeUsermetaItem(String),
RiakObject.setUsermeta(Map),
RiakObject.hasUsermetaItem(String),
RiakObject.hasUsermeta() and
RiakObject.getUsermetaItem(String) to mutate and query the User meta collection
- getUsermeta() -
Method in class com.basho.riak.pbc.RiakObject
- Return a copy of the user meta data map (does not read or write through
to map backing RiakObject)
- getUsermeta(int) -
Method in class com.basho.riak.pbc.RPB.RpbContent.Builder
-
- getUsermeta(int) -
Method in class com.basho.riak.pbc.RPB.RpbContent
-
- getUsermetaCount() -
Method in class com.basho.riak.pbc.RPB.RpbContent.Builder
-
- getUsermetaCount() -
Method in class com.basho.riak.pbc.RPB.RpbContent
-
- getUsermetaData(T) -
Method in class com.basho.riak.client.convert.reflect.AnnotationHelper
-
- getUsermetaData(T) -
Method in class com.basho.riak.client.convert.reflect.AnnotationInfo
-
- getUsermetaData(T) -
Method in class com.basho.riak.client.convert.UsermetaConverter
-
- getUsermetaDataKey() -
Method in class com.basho.riak.client.convert.UsermetaField
-
- getUsermetaItem(String) -
Method in class com.basho.riak.client.http.RiakObject
-
- getUsermetaItem(String) -
Method in class com.basho.riak.client.RiakObject
- Deprecated. Get an item of user meta data.
- getUsermetaList() -
Method in class com.basho.riak.pbc.RPB.RpbContent.Builder
-
- getUsermetaList() -
Method in class com.basho.riak.pbc.RPB.RpbContent
-
- getValue() -
Method in enum com.basho.riak.client.cap.Quora
-
- getValue() -
Method in class com.basho.riak.client.DefaultRiakObject
-
- getValue() -
Method in class com.basho.riak.client.http.BinIndex
-
- getValue() -
Method in class com.basho.riak.client.http.IntIndex
-
- getValue() -
Method in class com.basho.riak.client.http.RiakIndex
-
- getValue() -
Method in class com.basho.riak.client.http.RiakObject
-
- getValue() -
Method in interface com.basho.riak.client.IRiakObject
- The value.
- getValue() -
Method in class com.basho.riak.client.raw.query.indexes.AbstractValueQuery
-
- getValue() -
Method in interface com.basho.riak.client.raw.query.indexes.ValueQuery
- The value to match
- getValue() -
Method in class com.basho.riak.client.RiakObject
- Deprecated. The object's value
- getValue() -
Method in class com.basho.riak.pbc.RiakObject
-
- getValue() -
Method in class com.basho.riak.pbc.RPB.RpbContent.Builder
-
- getValue() -
Method in class com.basho.riak.pbc.RPB.RpbContent
-
- getValue() -
Method in class com.basho.riak.pbc.RPB.RpbPair.Builder
-
- getValue() -
Method in class com.basho.riak.pbc.RPB.RpbPair
-
- getValueAsBytes() -
Method in class com.basho.riak.client.http.RiakObject
-
- getValueAsBytes() -
Method in class com.basho.riak.client.RiakObject
- Deprecated.
- getValueAsString() -
Method in class com.basho.riak.client.DefaultRiakObject
-
- getValueAsString() -
Method in interface com.basho.riak.client.IRiakObject
- Convenience method.
- getValueStream() -
Method in class com.basho.riak.client.http.RiakObject
-
- getValueStream() -
Method in class com.basho.riak.client.RiakObject
- Deprecated.
- getValueStreamLength() -
Method in class com.basho.riak.client.http.RiakObject
-
- getValueStreamLength() -
Method in class com.basho.riak.client.RiakObject
- Deprecated.
- getVClock() -
Method in class com.basho.riak.client.DefaultRiakObject
-
- getVclock() -
Method in class com.basho.riak.client.http.response.FetchResponse
-
- getVclock() -
Method in class com.basho.riak.client.http.response.StoreResponse
- The object's updated vclock or null if Riak didn't return one.
- getVclock() -
Method in interface com.basho.riak.client.http.response.WithBodyResponse
-
- getVclock() -
Method in class com.basho.riak.client.http.RiakObject
-
- getVClock() -
Method in interface com.basho.riak.client.IRiakObject
- This objects Vector Clock.
- getVClock() -
Method in class com.basho.riak.client.operations.FetchObject
-
- getVclock() -
Method in class com.basho.riak.client.raw.DeleteMeta
-
- getVclock() -
Method in class com.basho.riak.client.raw.RiakResponse
- Get the vector clock as a
VClock
- getVclock() -
Method in class com.basho.riak.client.response.StoreResponse
- Deprecated. The object's updated vclock or null if Riak didn't return one.
- getVclock() -
Method in class com.basho.riak.client.RiakObject
- Deprecated. The object's opaque vclock assigned by Riak
- getVClock() -
Method in class com.basho.riak.pbc.FetchResponse
-
- getVclock() -
Method in class com.basho.riak.pbc.RiakObject
-
- getVclock() -
Method in class com.basho.riak.pbc.RPB.RpbDelReq.Builder
-
- getVclock() -
Method in class com.basho.riak.pbc.RPB.RpbDelReq
-
- getVclock() -
Method in class com.basho.riak.pbc.RPB.RpbGetResp.Builder
-
- getVclock() -
Method in class com.basho.riak.pbc.RPB.RpbGetResp
-
- getVclock() -
Method in class com.basho.riak.pbc.RPB.RpbPutReq.Builder
-
- getVclock() -
Method in class com.basho.riak.pbc.RPB.RpbPutReq
-
- getVclock() -
Method in class com.basho.riak.pbc.RPB.RpbPutResp.Builder
-
- getVclock() -
Method in class com.basho.riak.pbc.RPB.RpbPutResp
-
- getVClockAsString() -
Method in class com.basho.riak.client.DefaultRiakObject
-
- getVClockAsString() -
Method in interface com.basho.riak.client.IRiakObject
- String copy of this object's vector clock.
- getVclockBytes() -
Method in class com.basho.riak.client.raw.RiakResponse
- Get the vector clock bytes
- getVtag() -
Method in class com.basho.riak.client.DefaultRiakObject
-
- getVtag() -
Method in class com.basho.riak.client.http.response.StoreResponse
- The object's updated etag or null if Riak didn't return one.
- getVtag() -
Method in class com.basho.riak.client.http.RiakObject
-
- getVtag() -
Method in interface com.basho.riak.client.IRiakObject
- If this object has a version tag (if it is one of a set of siblings)
- getVtag() -
Method in class com.basho.riak.client.response.StoreResponse
- Deprecated. The object's updated etag or null if Riak didn't return one.
- getVtag() -
Method in class com.basho.riak.client.RiakObject
- Deprecated. An entity tag for the object assigned by Riak
- getVtag() -
Method in class com.basho.riak.pbc.RiakObject
-
- getVtag() -
Method in class com.basho.riak.pbc.RPB.RpbContent.Builder
-
- getVtag() -
Method in class com.basho.riak.pbc.RPB.RpbContent
-
- getW() -
Method in interface com.basho.riak.client.bucket.BucketProperties
- The default
w quorum for this bucket.
- getW() -
Method in class com.basho.riak.client.bucket.DefaultBucket
-
- getW() -
Method in class com.basho.riak.client.bucket.DefaultBucketProperties
-
- getW() -
Method in class com.basho.riak.client.bucket.LazyBucketProperties
-
- getW() -
Method in class com.basho.riak.client.bucket.TunableCAPProps
-
- getW() -
Method in class com.basho.riak.client.raw.DeleteMeta
-
- getW() -
Method in class com.basho.riak.client.raw.StoreMeta
- The write quorum
- getW() -
Method in class com.basho.riak.pbc.RPB.RpbDelReq.Builder
-
- getW() -
Method in class com.basho.riak.pbc.RPB.RpbDelReq
-
- getW() -
Method in class com.basho.riak.pbc.RPB.RpbPutReq.Builder
-
- getW() -
Method in class com.basho.riak.pbc.RPB.RpbPutReq
-
- getWalkSpec() -
Method in class com.basho.riak.client.http.RiakObject.LinkBuilder
-
- getWalkSpec() -
Method in class com.basho.riak.client.RiakObject.LinkBuilder
- Deprecated.
- getYoungVClock() -
Method in interface com.basho.riak.client.bucket.BucketProperties
- The young_vclcok property for this bucket.
- getYoungVClock() -
Method in class com.basho.riak.client.bucket.DefaultBucket
-
- getYoungVClock() -
Method in class com.basho.riak.client.bucket.DefaultBucketProperties
-
- getYoungVClock() -
Method in class com.basho.riak.client.bucket.LazyBucketProperties
-
- getYoungVClock() -
Method in class com.basho.riak.client.bucket.VClockPruneProps
- The young_vclcok property for this bucket.
- gossipReceived() -
Method in class com.basho.riak.client.query.NodeStats
-
- GreaterThanFilter - Class in com.basho.riak.client.http.mapreduce.filter
-
- GreaterThanFilter(String) -
Constructor for class com.basho.riak.client.http.mapreduce.filter.GreaterThanFilter
-
- GreaterThanFilter(int) -
Constructor for class com.basho.riak.client.http.mapreduce.filter.GreaterThanFilter
-
- GreaterThanFilter(double) -
Constructor for class com.basho.riak.client.http.mapreduce.filter.GreaterThanFilter
-
- GreaterThanFilter - Class in com.basho.riak.client.mapreduce.filter
- Deprecated. with the addition of a protocol buffers client in 0.14 all the
existing REST client code should be in client.http.* this class
has therefore been moved. Please use
com.basho.riak.client.http.mapreduce.filter.GreaterThanFilter
instead.
WARNING: This class will be REMOVED in the next version.
- GreaterThanFilter(String) -
Constructor for class com.basho.riak.client.mapreduce.filter.GreaterThanFilter
- Deprecated.
- GreaterThanFilter(int) -
Constructor for class com.basho.riak.client.mapreduce.filter.GreaterThanFilter
- Deprecated.
- GreaterThanFilter(double) -
Constructor for class com.basho.riak.client.mapreduce.filter.GreaterThanFilter
- Deprecated.
- GreaterThanFilter - Class in com.basho.riak.client.query.filter
- Filters in keys that are greater than the configured value.
- GreaterThanFilter(String) -
Constructor for class com.basho.riak.client.query.filter.GreaterThanFilter
-
- GreaterThanFilter(int) -
Constructor for class com.basho.riak.client.query.filter.GreaterThanFilter
-
- GreaterThanFilter(double) -
Constructor for class com.basho.riak.client.query.filter.GreaterThanFilter
-
- GreaterThanOrEqualFilter - Class in com.basho.riak.client.http.mapreduce.filter
-
- GreaterThanOrEqualFilter(String) -
Constructor for class com.basho.riak.client.http.mapreduce.filter.GreaterThanOrEqualFilter
-
- GreaterThanOrEqualFilter(int) -
Constructor for class com.basho.riak.client.http.mapreduce.filter.GreaterThanOrEqualFilter
-
- GreaterThanOrEqualFilter(double) -
Constructor for class com.basho.riak.client.http.mapreduce.filter.GreaterThanOrEqualFilter
-
- GreaterThanOrEqualFilter - Class in com.basho.riak.client.mapreduce.filter
- Deprecated. with the addition of a protocol buffers client in 0.14 all the
existing REST client code should be in client.http.* this class
has therefore been moved. Please use
com.basho.riak.client.http.mapreduce.filter.GreaterThanOrEqualFilter
instead.
WARNING: This class will be REMOVED in the next version.
- GreaterThanOrEqualFilter(String) -
Constructor for class com.basho.riak.client.mapreduce.filter.GreaterThanOrEqualFilter
- Deprecated.
- GreaterThanOrEqualFilter(int) -
Constructor for class com.basho.riak.client.mapreduce.filter.GreaterThanOrEqualFilter
- Deprecated.
- GreaterThanOrEqualFilter(double) -
Constructor for class com.basho.riak.client.mapreduce.filter.GreaterThanOrEqualFilter
- Deprecated.
- GreaterThanOrEqualFilter - Class in com.basho.riak.client.query.filter
- Filter in keys that are >= to the configured value
- GreaterThanOrEqualFilter(String) -
Constructor for class com.basho.riak.client.query.filter.GreaterThanOrEqualFilter
-
- GreaterThanOrEqualFilter(int) -
Constructor for class com.basho.riak.client.query.filter.GreaterThanOrEqualFilter
-
- GreaterThanOrEqualFilter(double) -
Constructor for class com.basho.riak.client.query.filter.GreaterThanOrEqualFilter
-
- GT -
Static variable in class org.json.XML
- The Character '>'.
RiakIOException
RiakResponseException
RiakIOException
RiakResponseException
RiakLinks?
Iterator.hasNext().
Iterator.hasNext().
bucket/key
HTTPClientAdapter connecting to 127.0.0.1:8098/riak in a DefaultRiakClient
HTTPClientAdapter connecting to the given
url in a DefaultRiakClient
RiakClient in a DefaultRiakClient
RiakClient to the new RawClient interface.client
RiakClient.RiakClient(String) to create a RiakClient to
adapt
HTTPClientConfig.HTTPClientAdapter
RawClient instances from a given HTTPClusterConfigHTTPClusterClientClusterConfig that provides the generic typeWARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
HTTPClientAdapter instances configured by the
given HTTPClientConfig.index with value
index with value
start to
end
start to
end
MapReduce operation that takes a 2i index query as inputIndexQuerys with a way to write themselves.inets_version value from the Riak stats reply
WARNING: This class will be REMOVED in the next version.
IntIndexvalue in index
MapReduce.validate()w, dw, content-type, returnBody?)json represent a riak map/reduce timeout exception?
RiakLinks at call time.
UnmodifiableIterator view on the RiakLinks
UnmodifiableIterator view of the inputs for this Map/Reduce job.
KeyFilters for
this M/R operation.
WARNING: This class will be REMOVED in the next version.
JSBucketKeyFunction to a JsonGeneratorJSONArray to a list
JSONArray to a list
clazz from
JSON and instances of IRiakObject with a JSON payload from
instances of clazz
clazz from
JSON and instances of IRiakObject with a JSON payload from
instances of clazz
JSONObject to a map
JSONObject to a map
JSONString interface allows a toJSONString()
method so that a class can change the behavior of
JSONObject.toString(), JSONArray.toString(),
and JSONWriter.value(Object).JSSourceFunction to a JsonGeneratorkernel_version value from the Riak stats reply
Iterable view of the keys stored in this bucket.
RawClient.listKeys(String) operations return a
stream of keys.
BucketResponse in response to
RiakClient.streamBucket(String) request.
lager_version value from the Riak stats reply
UnsupportedPropertyException will be thrown if called for that transport.
FetchBucket.execute() from fetching the BucketProperties from Riak.
WriteBucket.execute() from fetching the BucketProperties from Riak
after storing any modifications made via this object.
WARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
maxSize when creating an unbounded pool
WARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
MapReducePhase implementation that models a Link Phasebucket / tag
.
bucket / tag
keep will be false
client, starting from startObject
LinkWalkSpec
provided.
LinkWalk operation, used internally.LinkWalk to model a step in a link walk operation.RiakClient.listBucket(String, RequestMeta), except throws on
a non-200 response
RiakClient, except only returning the HTTP response, and
if streamResponse==true, the response will be streamed back, so the user
is responsible for calling HttpResponseDecorator.close()
RiakClient.listBucket(String, RequestMeta), except throws on
a non-200 response
RiakClient, except only returning the HTTP response, and
if streamResponse==true, the response will be streamed back, so the user
is responsible for calling HttpResponseDecorator.close()
Iterator view of the all the Buckets in Riak
Iterator view of the keys for the bucket named
bucketName
May be backed by a stream or a collection.
WARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
luke_version value from the Riak stats reply
luwak_version value from the Riak stats reply
RiakClient, except only returning the HTTP response
MapReduce operation for a set of
bucket/key inputs.
MapReduce operation that has the supplied bucket as its input.
MapReduce operation that uses the supplied Riak Search
query as input.
MapReduce operation that uses the supplied
IndexQuery as input
RawClient to delegate to.
MapReduceSpec
RiakClient, except only returning the HTTP response
WARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
RiakClient.mapReduceOverBucket(String), except over a set
of objects instead of a bucket.
RiakClient.mapReduceOverBucket(String), except over a set
of objects instead of a bucket.
RiakClient.mapReduceOverBucket(String), except over a
riak-search query instead of a bucket.
JSONArray
WARNING: This class will be REMOVED in the next version.
JSONArray
IRiakClient#mapReduce(MapReduceSpec), used internally.WARNING: This class will be REMOVED in the next version.
mem_allocated value from the Riak Stats reply
memory_atom value from the Riak Stats reply
memory_atom_used value from the Riak Stats reply
memory_binary value from the Riak Stats reply
memory_code value from the Riak Stats reply
memory_ets value from the Riak Stats reply
memory_processes value from the Riak Stats reply
memory_processes_used value from the Riak Stats reply
memory_system value from the Riak Stats reply
memory_total value from the Riak Stats reply
mem_total value from the Riak Stats reply
merge_index_version value from the Riak stats reply
mochiweb_value value from the Riak stats reply
WARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
MutationProducer to provide the Mutation to use in store operations.
Mutation at will? Say if you are using a DomainBucket.NamedErlangFunctions from JSONNamedErlangFunction to a JsonGeneratorNamedJSFunction to a JsonGeneratorRawClient instance configured by config
config to generate an IRiakClient
instance.
HttpClient instance given a RiakConfig.
HttpClient instance given a RiakConfig.
Iterator.next().
Iterator.next().
node_put_fsm_objsize_95 value from the Riak Stats reply
node_put_fsm_objsize_99 value from the Riak Stats reply
node_get_fsm_objsize_mean value from the Riak Stats reply
node_put_fsm_objsize_median value from the Riak Stats reply
node_put_fsm_siblings_100 value from the Riak Stats reply
node_put_fsm_siblings_95 value from the Riak Stats reply
node_put_fsm_siblings_99 value from the Riak Stats reply
node_get_fsm_siblings_mean value from the Riak Stats reply
node_put_fsm_siblings_median value from the Riak Stats reply
node_get_fsm_time_100 value from the Riak Stats reply
node_get_fsm_time_95 value from the Riak Stats reply
node_get_fsm_time_99 value from the Riak Stats reply
node_get_fsm_time_mean value from the Riak Stats reply
node_get_fsm_time_median value from the Riak Stats reply
node_gets value from the Riak Stats reply
node_gets_total value from the Riak Stats reply
nodename value from the Riak stats reply
node_put_fsm_objsize_100 value from the Riak Stats reply
node_put_fsm_time_100 value from the Riak Stats reply
node_put_fsm_time_95 value from the Riak Stats reply
node_put_fsm_time_99 value from the Riak Stats reply
node_get_fsm_time_mean value from the Riak Stats reply
node_put_fsm_time_median value from the Riak Stats reply
node_puts value from the Riak Stats reply
node_puts_total value from the Riak Stats reply
/stats
operation.RuntimeException thrown by RiakFactory if it is unable to
find a RiakClientFactory to create a client for the given
configuration.MapReduce has been configured with no inputsMapReduce has been configured with no query phasesWARNING: This class will be REMOVED in the next version.
UnsupportedPropertyException will be thrown if called for that transport
NULL object than to use Java's null value.
RiakLinks does this object have.
RiakLinks does this RiakObject have?
UnsupportedPropertyException will be thrown if called for that transport
InputStream
containing contains a delimited listWARNING: This class will be REMOVED in the next version.
os_mon_version value from the Riak stats reply
json into a checked exception of the
most specific type it can manage.
List of
RiakIndexes from them
RiakLink.
RiakLink.
RiakObjects.
RiakObjects.
IRiakObject rather than domain types.pbc_active value from the Riak Stats reply
PBClientAdapter connected to 127.0.0.1:8087 in a DefaultRiakClient.
PBClientAdapter connected to host and
port in a DefaultRiakClient.
RiakClient client in a DefaultRiakClient.
pbc_connects value from the Riak Stats reply
pbc_connects_total value from the Riak Stats reply
RiakClient and adapts it to the RawClient
interface.RiakClient using
RiakClient.RiakClient(String, int)
RawClient
interface
PBClientConfig Has the following default values:
field
default
socketBufferSizeKb
16
host
127.0.0.1
port
8087
poolSize
0 (unlimited)
initialPoolSize
0
idleConnectionTTLMillis
1000 (idle connections will be closed after 1 second)
connectionWaitTimeoutMillis
1000 (if a connection cannot be acquired within this time and
exception is thrown)
ClusterClient that creates a collection of
PBClientAdapters from the given PBClientConfigRiakClientFactory implementation that creates PBClusterClient
s from the given PBClientConfigClusterConfig implementation that provides PBClientConfig as
the generic type.PBClientAdapters configured as per the PBClientConfig
given.RiakClient.ping()
RiakClient to a slightly less HTTP, more
Java-centric, interface.WARNING: This class will be REMOVED in the next version.
Semaphore with permits permits.
UnsupportedPropertyException will be thrown if called for that transport
UnsupportedPropertyException will be thrown if called for that transport
UnsupportedPropertyException will be thrown if called for that transport
public_key_version value from the Riak stats reply
UnsupportedPropertyException will be thrown if called for that transport
UnsupportedPropertyException will be thrown if called for that transport
UnsupportedPropertyException will be thrown if called for that transport
UnsupportedPropertyException will be thrown if called for that transport
DomainBucket
DomainBucket
read_repairs value from the Riak Stats reply
read_repairs_total value from the Riak Stats reply
BinIndex
BinIndex from this RiakObject.
IntIndex from this RiakObject.
RiakLink from this RiakObject.
RiakLink from this RiakObject.
WARNING: This class will be REMOVED in the next version.
Retrier to use on operations on the built DomainBucket
DomainBucket return a body?
riak_sysmon_version value from the Riak stats reply
BeanSerializerModifier that drops RiakKey and
RiakUsermeta annotated fields from the the set of fields that Jackson
will serializeDomainBucket strongly typed for IRiakObject.WARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
Please see also IRiakClient, IRiakObject for the new API
RawClient factoriesWARNING: This class will be REMOVED in the next version.
RiakConnections to be reused by RiakClient
The pool is designed to be threadsafe, and ideally to be used as a singleton.riak_core_version value from the Riak stats reply
WARNING: This class will be REMOVED in the next version.
RawClient of your choice.IRiakObjectRiakIORuntimeException.WARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
Module that customises Jackson's object
mapper so we can handle Riak annotations like RiakKey,
RiakUsermeta, and RiakLink correctly.riak_kv_version value from the Riak stats reply
WARNING: This class will be REMOVED in the next version.
Please see also IRiakClient, IRiakObject for the new API
DefaultRiakObjectCallable, hey, wait, maybe it *should* just be replaced with Callableriak_pipe_version value from the Riak stats reply
RiakResponseRuntimeExceptionWARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
riak_search_version value from the Riak stats reply
ring_creation_size value from the Riak Stats reply
ring_members value from the Riak Stats reply
ring_num_partitions value from the Riak Stats reply
ring_ownership value from the Riak stats reply
RiakClient.walk(String, String, String, RequestMeta).
RiakClient.walk(String, String, String, RequestMeta).
runtime_tools_version value from the Riak stats reply
UnsupportedPropertyException will be thrown if called for that transport
UnsupportedPropertyException will be thrown if called for that transport
DomainBucket
DomainBucket
sasl_version value from the Riak stats reply
MapReduce operation that uses a Riak Search query as input.RiakClient.setBucketSchema(String, RiakBucketInfo, RequestMeta),
except throws on a non-204 response.
RiakClient.setBucketSchema(String, com.basho.riak.client.http.RiakBucketInfo, RequestMeta)
RiakClient.setBucketSchema(String, RiakBucketInfo, RequestMeta),
except throws on a non-204 response.
RiakClient#setBucketSchema(String, com.basho.riak.client.http.RiakBucketInfo, RequestMeta)
key as the value of the RiakKey
annotated field of domainObject
WARNING: This class will be REMOVED in the next version.
HttpClientParams#CONNECTION_MANAGER_TIMEOUT,
HttpClientParams#SO_TIMEOUT,
HttpConnectionManagerParams#CONNECTION_TIMEOUT which sets the
timeout milliseconds for retrieving an HTTP connection and data over the
connection.
HttpClientParams#CONNECTION_MANAGER_TIMEOUT,
HttpClientParams#SO_TIMEOUT,
HttpConnectionManagerParams#CONNECTION_TIMEOUT which sets the
timeout milliseconds for retrieving an HTTP connection and data over the
connection.
WARNING: This class will be REMOVED in the next version.
skerl_version value from the Riak stats reply
UnsupportedPropertyException will be thrown if called for that transport
ssl_version value from the Riak stats reply
WARNING: This class will be REMOVED in the next version.
/stats (status) resource.
RiakClient.stats()
/stats operation on the node(s) this client
is connected to.
/stats operation on the node(s) this client
is connected to.
stdlib_version value from the Riak stats reply
storage_backend value from the Riak stats reply
StoreObject that will store a new IRiakObject.
StoreObject that will store a new IRiakObject.
StoreObject for storing o of type
T on execute().
StoreObject for storing o of type
T at key on execute().
IRiakObject with
value as the data payload and
text/plain:charset=utf-8 as the contentType
T in Riak.
T in Riak.
o in Riak.
RiakClient.store(RiakObject, RequestMeta), except throws on
a non-200 or 204 response and updates the passed in RiakObject
with new metadata from Riak.
RiakClient, except only returning the HTTP response
RiakClient.store(RiakObject, RequestMeta), except throws on
a non-200 or 204 response and updates the passed in RiakObject
with new metadata from Riak.
IRiakObject in Riak at the location
bucket/key
IRiakObject in Riak using the bucket default w/dw
and false for returnBody
RiakObject.
RiakClient.store(RiakObject, RequestMeta) followed by
RiakObject.updateMeta(StoreResponse)
RiakClient, except only returning the HTTP response
nulls for any parameter
nulls for any parameter
nulls for any parameter
bucket
at key.
WARNING: This class will be REMOVED in the next version.
RiakClient.stream(String, String, StreamHandler, RequestMeta).
RiakClient, except only returning the HTTP response
RiakClient.stream(String, String, StreamHandler, RequestMeta).
bucket and
key as a stream.
RiakClient, except only returning the HTTP response
RiakClient.listBucket(String, RequestMeta), except
streams the response, so the user must remember to call
HttpResponseDecorator.close() on the return value.
WARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
WARNING: This class will be REMOVED in the next version.
sys_driver_version value from the Riak stats reply
sys_global_heaps_size value from the Riak Stats reply
sys_heap_type value from the Riak stats reply
sys_logical_processors value from the Riak Stats reply
sys_otp_release value from the Riak stats reply
sys_process_count value from the Riak Stats reply
sys_smp_support value from the Riak Stats reply
sys_system_architecture value from the Riak stats reply
sys_system_version value from the Riak stats reply
sys_thread_pool_size value from the Riak Stats reply
sys_threads_enabled value from the Riak Stats reply
sys_wordsize value from the Riak Stats reply
Exception not declared in the method signature,
which can be particularly useful for throwing checked exceptions within a
RiakExceptionHandler.
Exception not declared in the method signature,
which can be particularly useful for throwing checked exceptions within a
RiakExceptionHandler.
value of riakObject to an instance
of T.
toJSONString method allows a class to produce its own JSON
serialization.
WARNING: This class will be REMOVED in the next version.
tokenNum token of the key when tokenized by separatorWARNING: This class will be REMOVED in the next version.
e to installed exception handler if there is
one or throw it.
e to installed exception handler if there is
one or throw it.
WARNING: This class will be REMOVED in the next version.
%hh sequences to single characters, and
convert plus to space.
UnsupportedOperationExceptionUnmodifiableIterator for the given delegate
quoted-string:
http://www.w3.org/Protocols/rfc2616/rfc2616-sec2.html#sec2.2
Does nothing if s is not quoted.
quoted-string:
http://www.w3.org/Protocols/rfc2616/rfc2616-sec2.html#sec2.2
Does nothing if s is not quoted.
Retrier.attempt(java.util.concurrent.Callable) when it finally fails.WriteBucket operation to update passed bucket.
BucketProperties provided.
WARNING: This class will be REMOVED in the next version.
RiakUsermetatrue or the value
false.
vnode_gets value from the Riak stats reply
vnode_gets_total value from the Riak Stats reply
vnode_index_deletes value from the Riak Stats reply
vnode_index_deletes_postings_total value from the Riak Stats reply
vnode_index_deletes_total value from the Riak Stats reply
vnode_index_reads value from the Riak stats reply
vnode_index_reads_total value from the Riak Stats reply
vnode_index_writes_postings value from the Riak stats reply
vnode_index_writes value from the Riak stats reply
vnode_index_writes_postings_total value from the Riak Stats reply
vnode_index_writes_total value from the Riak Stats reply
vnode_gets value from the Riak stats reply
vnode_puts_total value from the Riak Stats reply
vnode_index_deletes_postings value from the Riak Stats reply
UnsupportedPropertyException will be thrown if called for that transport
UnsupportedPropertyException will be thrown if called for that transport
DomainBucket
DomainBucket
RiakClient.walk(String, String, String, RequestMeta), except
throws on a non-200 or 404 response.
RiakClient, except only returning the HTTP response
LinkWalk operation that starts at startObject.
RiakClient.walk(String, String, String, RequestMeta), except
throws on a non-200 or 404 response.
RiakClient.walk(String, String, RiakWalkSpec)
RiakClient, except only returning the HTTP response
WARNING: This class will be REMOVED in the next version.
IRiakObjects.webmachine_version value from the Riak stats reply
WARNING: This class will be REMOVED in the next version.
Converter to use on fetch and store operations on the built DomainBucket
Converter to use to convert the data fetched to some other type
Converter to use
RawClient to delegate to.
RiakIndexes for the new riak object
long timestamp of milliseconds since the epoch to set as
the last modified date on this Riak object
RiakLinks for the new riak object
Mutation to apply to the value retrieved from the fetch operation
ConflictResolver the DomainBucket will use.
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.
Retrier to use for the fetch operation.
Retrier to use when executing this delete operation
Retrier to use
Retrier to use for the fetch and store operations.
HttpRequestRetryHandler
to be called when a request fails.
ClobberMutation that applies value
RiakOperation for creating/updating a Bucket.RawClient via the give Retrier.
RawClient via the give Retrier.
HttpRequestBase which can
be sent as an HTTP request.
HttpMethod which can be
sent as an HTTP request.
UnsupportedPropertyException will be thrown if called for that transport
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||