Package | Description |
---|---|
com.basho.riak.client.api |
Contains the main RiakClient used to query Riak.
|
com.basho.riak.client.api.commands.kv |
Commands for storing, fetching, and deleting objects.
|
com.basho.riak.client.core |
Modifier and Type | Method and Description |
---|---|
RiakCluster |
RiakClient.getRiakCluster()
Get the RiakCluster being used by this client.
|
Modifier and Type | Method and Description |
---|---|
protected T |
RiakCommand.execute(RiakCluster cluster) |
protected T |
RiakCommand.execute(RiakCluster cluster,
long timeout,
TimeUnit unit) |
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) |
protected RiakFuture<R,I> |
StreamableRiakCommand.executeAsyncStreaming(RiakCluster cluster,
int timeout) |
Constructor and Description |
---|
RiakClient(RiakCluster cluster)
Create a new RiakClient to perform operations on the given cluster.
|
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 |
---|---|
RiakCluster |
RiakCluster.Builder.build()
Instantiates the
RiakCluster |
Copyright © 2016. All rights reserved.