Package | Description |
---|---|
com.basho.riak.client.api.commands.datatypes |
Commands for manipulating CRDTs in Riak.
|
com.basho.riak.client.api.commands.indexes |
Commands for performing secondary index (2i) queries in Riak.
|
com.basho.riak.client.api.commands.kv |
Commands for storing, fetching, and deleting objects.
|
com.basho.riak.client.api.commands.mapreduce |
Commands for Map-Reduce in Riak.
|
com.basho.riak.client.api.convert | |
com.basho.riak.client.core.netty | |
com.basho.riak.client.core.operations |
Modifier and Type | Method and Description |
---|---|
Location |
FetchDatatype.getLocation() |
Modifier and Type | Method and Description |
---|---|
protected FutureOperation<DtUpdateOperation.Response,?,Location> |
UpdateDatatype.buildCoreOperation() |
Constructor and Description |
---|
Builder(Location location)
Construct a builder for a FetchSet command.
|
Builder(Location location)
Construct a Builder for a FetchMap command.
|
Builder(Location location)
Construct a builder for a FetchHll command.
|
Builder(Location location) |
Builder(Location location)
Construct a builder for a FetchCounter command.
|
Builder(Location location,
CounterUpdate update)
Construct a Builder for an UpdateCounter command.
|
Builder(Location location,
HllUpdate update)
Construct a Builder for an UpdateHll command.
|
Builder(Location location,
MapUpdate update)
Construct a Builder for an UpdateMap command.
|
Builder(Location location,
SetUpdate update)
Construct a Builder for an UpdateSet command.
|
Modifier and Type | Method and Description |
---|---|
Location |
SecondaryIndexQuery.Response.Entry.getRiakObjectLocation()
Get the location for this entry.
|
Modifier and Type | Method and Description |
---|---|
protected E |
SecondaryIndexQuery.Response.createEntry(Location location,
SecondaryIndexQueryOperation.Response.Entry coreEntry,
SecondaryIndexQuery.IndexConverter<T> converter) |
Constructor and Description |
---|
Entry(Location riakObjectLocation,
BinaryValue indexKey,
SecondaryIndexQuery.IndexConverter<T> converter) |
Modifier and Type | Field and Description |
---|---|
protected Location |
KvBuilderBase.location |
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) |
Iterator<Location> |
ListKeys.Response.iterator() |
Modifier and Type | Method and Description |
---|---|
protected FetchValue.Builder |
MultiFetch.createBaseBuilderType(Location location) |
protected DeleteValue.Builder |
MultiDelete.createBaseBuilderType(Location location) |
protected FullBucketRead.Response.Entry |
FullBucketRead.Response.createEntry(Location location,
SecondaryIndexQueryOperation.Response.Entry coreEntry,
SecondaryIndexQuery.IndexConverter<BinaryValue> converter) |
StoreValue.Builder |
StoreValue.Builder.withLocation(Location location)
Set the location to store the object.
|
Modifier and Type | Method and Description |
---|---|
protected FetchValue.Response |
FetchValue.convertResponse(FutureOperation<FetchOperation.Response,?,Location> request,
FetchOperation.Response coreResponse) |
protected StoreValue.Response |
StoreValue.convertResponse(FutureOperation<StoreOperation.Response,?,Location> request,
StoreOperation.Response coreResponse) |
protected MultiFetch.Response |
MultiFetch.createResponseType(List<RiakFuture<FetchValue.Response,Location>> riakFutures) |
protected MultiDelete.Response |
MultiDelete.createResponseType(List<RiakFuture<Void,Location>> riakFutures) |
Constructor and Description |
---|
Builder(Location location)
Construct a Builder for an UpdateValue command.
|
Builder(Location location)
Constructs a builder for a FetchValue operation using the supplied location.
|
Builder(Location location)
Construct a Builder for a DeleteValue command.
|
Entry(Location location) |
Entry(Location location,
FetchValue.Response fetchedResponse) |
KvBuilderBase(Location location) |
Modifier and Type | Method and Description |
---|---|
BucketKeyMapReduce.Builder |
BucketKeyMapReduce.Builder.withLocation(Location location)
Adds a new location to the collection of MapReduce inputs.
|
BucketKeyMapReduce.Builder |
BucketKeyMapReduce.Builder.withLocation(Location location,
String keyData)
Adds a new location + key to the collection of MapReduce inputs.
|
Modifier and Type | Method and Description |
---|---|
String |
StringConverter.toDomain(RiakObject obj,
Location location) |
RiakObject |
PassThroughConverter.toDomain(RiakObject obj,
Location location) |
T |
Converter.toDomain(RiakObject obj,
Location location)
Converts from a RiakObject to a domain object.
|
Constructor and Description |
---|
StoreValueHealthCheck(Location location,
BinaryValue value) |
Modifier and Type | Method and Description |
---|---|
Location |
StoreOperation.getQueryInfo() |
Location |
FetchOperation.getQueryInfo() |
Location |
DtUpdateOperation.getQueryInfo() |
Location |
DtFetchOperation.getQueryInfo() |
Location |
DeleteOperation.getQueryInfo() |
Constructor and Description |
---|
Builder(Location location)
Constructs a builder for a StoreOperation
|
Builder(Location location)
Construct a FetchOperation that will retrieve an object from Riak stored
at the provided Location.
|
Builder(Location location)
Construct a builder for a DtUpdateOperation.
|
Builder(Location location)
Construct a Builder for a DtFetchOperation
|
Builder(Location location)
Construct a builder for a DeleteOperation.
|
Copyright © 2016. All rights reserved.