Package | Description |
---|---|
com.basho.riak.client.api |
Contains the main RiakClient used to query Riak.
|
com.basho.riak.client.api.commands |
Support classes for commands.
|
com.basho.riak.client.api.commands.kv |
Commands for storing, fetching, and deleting objects.
|
com.basho.riak.client.core | |
com.basho.riak.client.core.netty | |
com.basho.riak.client.core.operations | |
com.basho.riak.client.core.operations.ts |
Modifier and Type | Method and Description |
---|---|
protected abstract RiakFuture<T,S> |
RiakCommand.executeAsync(RiakCluster cluster) |
protected RiakFuture<R,I> |
GenericRiakCommand.executeAsync(RiakCluster cluster) |
protected RiakFuture<R,I> |
AsIsRiakCommand.executeAsync(RiakCluster cluster) |
<T,S> RiakFuture<T,S> |
RiakClient.executeAsync(RiakCommand<T,S> command)
Execute a RiakCommand asynchronously.
|
protected RiakFuture<R,I> |
StreamableRiakCommand.executeAsyncStreaming(RiakCluster cluster,
int timeout) |
<I extends StreamableRiakCommand.StreamableResponse,S> |
RiakClient.executeAsyncStreaming(StreamableRiakCommand<I,S,?,?> command,
int timeoutMS)
Execute a StreamableRiakCommand asynchronously, and stream the results back before
the command
is done . |
Modifier and Type | Class and Description |
---|---|
class |
CoreFutureAdapter<T2,S2,T,S> |
class |
ImmediateCoreFutureAdapter<T2,S2,T,S>
Used when the converted response is available before the core future is complete.
|
static class |
ImmediateCoreFutureAdapter.SameQueryInfo<T2,S,T> |
class |
ListenableFuture<T,S>
The base class for RiakFutures returned to users.
|
Modifier and Type | Method and Description |
---|---|
void |
CoreFutureAdapter.handle(RiakFuture<T,S> f) |
Constructor and Description |
---|
CoreFutureAdapter(RiakFuture<T,S> coreFuture) |
ImmediateCoreFutureAdapter(RiakFuture<T,S> coreFuture,
T2 immediateResponse) |
SameQueryInfo(RiakFuture<T,S> coreFuture,
T2 immediateResponse) |
Modifier and Type | Method and Description |
---|---|
protected RiakFuture<UpdateValue.Response,Location> |
UpdateValue.executeAsync(RiakCluster cluster) |
protected RiakFuture<StoreValue.Response,Location> |
StoreValue.executeAsync(RiakCluster cluster) |
protected RiakFuture<FetchValue.Response,Location> |
FetchValue.executeAsync(RiakCluster cluster) |
protected RiakFuture<Void,Location> |
DeleteValue.executeAsync(RiakCluster cluster)
To ensure that this method is accessible by
MultiDelete.executeBaseCommandAsync(DeleteValue, RiakCluster)
it MUST be overrode. |
protected RiakFuture<Void,Location> |
MultiDelete.executeBaseCommandAsync(DeleteValue command,
RiakCluster cluster) |
protected RiakFuture<FetchValue.Response,Location> |
MultiFetch.executeBaseCommandAsync(FetchValue command,
RiakCluster cluster) |
Modifier and Type | Method and Description |
---|---|
protected MultiFetch.Response |
MultiFetch.createResponseType(List<RiakFuture<FetchValue.Response,Location>> riakFutures) |
protected MultiDelete.Response |
MultiDelete.createResponseType(List<RiakFuture<Void,Location>> riakFutures) |
Modifier and Type | Interface and Description |
---|---|
interface |
StreamingRiakFuture<ResultType,QueryInfoType>
The result of an asynchronous streaming (chunked) Riak operation.
|
Modifier and Type | Class and Description |
---|---|
class |
FutureOperation<T,U,S> |
class |
PBStreamingFutureOperation<ReturnType,ResponseType,QueryInfoType> |
Modifier and Type | Method and Description |
---|---|
<V,S> RiakFuture<V,S> |
RiakCluster.execute(FutureOperation<V,?,S> operation) |
Modifier and Type | Method and Description |
---|---|
void |
RiakFutureListener.handle(RiakFuture<T,S> f) |
Modifier and Type | Class and Description |
---|---|
static class |
HealthCheckDecoder.HealthCheckFuture |
Modifier and Type | Method and Description |
---|---|
RiakFuture<RiakMessage,Void> |
HealthCheckDecoder.getFuture() |
Modifier and Type | Class and Description |
---|---|
class |
CoveragePlanOperation
An operation to retrieve a coverage plan from Riak.
|
class |
DeleteOperation
An operation to delete a riak object
|
class |
DtFetchOperation |
class |
DtUpdateOperation |
class |
FetchBucketPropsOperation |
class |
FetchOperation
An operation used to fetch an object from Riak.
|
class |
ListBucketsOperation |
class |
ListKeysOperation |
class |
MapReduceOperation
A Map/Reduce Operation on Riak.
|
class |
PBFutureOperation<T,U,S>
An abstract PB operation that introduces generic encoding/decoding
|
class |
PingOperation |
class |
ResetBucketPropsOperation |
class |
SearchOperation
A Riak Search or Yokozuna query operation.
|
class |
SecondaryIndexQueryOperation |
class |
StoreBucketPropsOperation |
class |
StoreOperation
An operation to store a riak object
|
class |
TTBFutureOperation<T,S>
An abstract TTB operation that introduces generic encoding/decoding
|
class |
YzDeleteIndexOperation |
class |
YzFetchIndexOperation |
class |
YzGetSchemaOperation |
class |
YzPutIndexOperation |
class |
YzPutSchemaOperation |
Modifier and Type | Class and Description |
---|---|
class |
CreateTableOperation
An operation to create a Riak Time Series table according to the provided definition.
|
class |
DescribeTableOperation
An operation to query a table definition from Riak Time Series.
|
class |
QueryOperation
An operation to query data from a Riak Time Series table.
|
Copyright © 2016. All rights reserved.