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 |
---|---|
protected RiakFuture<UpdateSet.Response,Location> |
UpdateSet.executeAsync(RiakCluster cluster) |
protected RiakFuture<UpdateMap.Response,Location> |
UpdateMap.executeAsync(RiakCluster cluster) |
protected RiakFuture<UpdateCounter.Response,Location> |
UpdateCounter.executeAsync(RiakCluster cluster) |
protected RiakFuture<FetchSet.Response,Location> |
FetchSet.executeAsync(RiakCluster cluster) |
protected RiakFuture<FetchMap.Response,Location> |
FetchMap.executeAsync(RiakCluster cluster) |
protected RiakFuture<FetchCounter.Response,Location> |
FetchCounter.executeAsync(RiakCluster cluster) |
Constructor and Description |
---|
FetchCounter.Builder(Location location)
Construct a builder for a FetchCounter command.
|
FetchDatatype.Builder(Location location) |
FetchMap.Builder(Location location)
Construct a Builder for a FetchMap command.
|
FetchSet.Builder(Location location)
Construct a builder for a FetchSet command.
|
UpdateCounter.Builder(Location location,
CounterUpdate update)
Construct a Builder for an UpdateCounter command.
|
UpdateMap.Builder(Location location,
MapUpdate update)
Construct a Builder for an UpdateMap command.
|
UpdateSet.Builder(Location location,
SetUpdate update)
Construct a Builder for an UpdateSet command.
|
Modifier and Type | Method and Description |
---|---|
protected Location |
SecondaryIndexQuery.Response.getLocationFromCoreEntry(SecondaryIndexQueryOperation.Response.Entry e) |
Location |
SecondaryIndexQuery.Response.Entry.getRiakObjectLocation()
Get the location for this entry.
|
Constructor and Description |
---|
BigIntIndexQuery.Response.Entry(Location riakObjectLocation,
BinaryValue indexKey,
SecondaryIndexQuery.IndexConverter<BigInteger> converter) |
BinIndexQuery.Response.Entry(Location riakObjectLocation,
BinaryValue indexKey,
SecondaryIndexQuery.IndexConverter<String> converter) |
IntIndexQuery.Response.Entry(Location riakObjectLocation,
BinaryValue indexKey,
SecondaryIndexQuery.IndexConverter<Long> converter) |
RawIndexQuery.Response.Entry(Location riakObjectLocation,
BinaryValue indexKey,
SecondaryIndexQuery.IndexConverter<BinaryValue> converter) |
SecondaryIndexQuery.Response.Entry(Location riakObjectLocation,
BinaryValue indexKey,
SecondaryIndexQuery.IndexConverter<T> converter) |
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<MultiFetch.Response,List<Location>> |
MultiFetch.executeAsync(RiakCluster cluster) |
protected RiakFuture<FetchValue.Response,Location> |
FetchValue.executeAsync(RiakCluster cluster) |
protected RiakFuture<Void,Location> |
DeleteValue.executeAsync(RiakCluster cluster) |
List<RiakFuture<FetchValue.Response,Location>> |
MultiFetch.Response.getResponses() |
Iterator<RiakFuture<FetchValue.Response,Location>> |
MultiFetch.Response.iterator() |
Iterator<Location> |
ListKeys.Response.iterator() |
Modifier and Type | Method and Description |
---|---|
MultiFetch.Builder |
MultiFetch.Builder.addLocation(Location location)
Add a location to the list of locations to retrieve as part of
this multifetch operation.
|
MultiFetch.Builder |
MultiFetch.Builder.addLocations(Location... location)
Add a list of Locations to the list of locations to retrieve as part of
this multifetch operation.
|
StoreValue.Builder |
StoreValue.Builder.withLocation(Location location)
Set the location to store the object.
|
Modifier and Type | Method and Description |
---|---|
MultiFetch.Builder |
MultiFetch.Builder.addLocations(Iterable<Location> location)
Add a set of keys to the list of Locations to retrieve as part of
this multifetch operation.
|
Constructor and Description |
---|
DeleteValue.Builder(Location location)
Construct a Builder for a DeleteValue command.
|
FetchValue.Builder(Location location)
Constructs a builder for a FetchValue operation using the supplied location.
|
UpdateValue.Builder(Location location)
Construct a Builder for an UpdateValue command.
|
Modifier and Type | Method and Description |
---|---|
BucketKeyMapReduce.Builder |
BucketKeyMapReduce.Builder.withLocation(Location location) |
BucketKeyMapReduce.Builder |
BucketKeyMapReduce.Builder.withLocation(Location location,
String keyData) |
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 |
---|
DeleteOperation.Builder(Location location)
Construct a builder for a DeleteOperation.
|
DtFetchOperation.Builder(Location location)
Construct a Builder for a DtFetchOperaiton
|
DtUpdateOperation.Builder(Location location)
Construct a builder for a DtUpdateOperation.
|
FetchOperation.Builder(Location location)
Construct a FetchOperation that will retrieve an object from Riak stored
at the provided Location.
|
StoreOperation.Builder(Location location)
Constructs a builder for a StoreOperation
|
Copyright © 2014. All rights reserved.