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.buckets |
Commands used to query and modify buckets in Riak.
|
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.commands.search |
Commands used for Riak search.
|
com.basho.riak.client.core | |
com.basho.riak.client.core.operations |
Modifier and Type | Method and Description |
---|---|
protected abstract RiakFuture<T,S> |
RiakCommand.executeAsync(RiakCluster cluster) |
<T,S> RiakFuture<T,S> |
RiakClient.executeAsync(RiakCommand<T,S> command)
Execute a RiakCommand asynchronously.
|
Modifier and Type | Class and Description |
---|---|
class |
CoreFutureAdapter<T2,S2,T,S> |
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) |
Modifier and Type | Method and Description |
---|---|
protected RiakFuture<Void,Namespace> |
StoreBucketProperties.executeAsync(RiakCluster cluster) |
protected RiakFuture<ListBuckets.Response,BinaryValue> |
ListBuckets.executeAsync(RiakCluster cluster) |
protected RiakFuture<FetchBucketPropsOperation.Response,Namespace> |
FetchBucketProperties.executeAsync(RiakCluster cluster) |
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) |
Modifier and Type | Class and Description |
---|---|
protected class |
BigIntIndexQuery.BigIntQueryFuture |
protected class |
BinIndexQuery.BinQueryFuture |
protected class |
IntIndexQuery.IntQueryFuture |
protected class |
RawIndexQuery.RawQueryFuture |
Modifier and Type | Method and Description |
---|---|
protected RiakFuture<RawIndexQuery.Response,RawIndexQuery> |
RawIndexQuery.executeAsync(RiakCluster cluster) |
protected RiakFuture<IntIndexQuery.Response,IntIndexQuery> |
IntIndexQuery.executeAsync(RiakCluster cluster) |
protected RiakFuture<BinIndexQuery.Response,BinIndexQuery> |
BinIndexQuery.executeAsync(RiakCluster cluster) |
protected RiakFuture<BigIntIndexQuery.Response,BigIntIndexQuery> |
BigIntIndexQuery.executeAsync(RiakCluster cluster) |
protected RiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query> |
SecondaryIndexQuery.executeCoreAsync(RiakCluster cluster) |
Constructor and Description |
---|
BigIntIndexQuery.BigIntQueryFuture(RiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query> coreFuture) |
BinIndexQuery.BinQueryFuture(RiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query> coreFuture) |
IntIndexQuery.IntQueryFuture(RiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query> coreFuture) |
RawIndexQuery.RawQueryFuture(RiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query> coreFuture) |
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<ListKeys.Response,Namespace> |
ListKeys.executeAsync(RiakCluster cluster) |
protected RiakFuture<FetchValue.Response,Location> |
FetchValue.executeAsync(RiakCluster cluster) |
protected RiakFuture<Void,Location> |
DeleteValue.executeAsync(RiakCluster cluster) |
Modifier and Type | Method and Description |
---|---|
List<RiakFuture<FetchValue.Response,Location>> |
MultiFetch.Response.getResponses() |
Iterator<RiakFuture<FetchValue.Response,Location>> |
MultiFetch.Response.iterator() |
Modifier and Type | Method and Description |
---|---|
protected RiakFuture<MapReduce.Response,BinaryValue> |
MapReduce.executeAsync(RiakCluster cluster) |
Modifier and Type | Method and Description |
---|---|
protected RiakFuture<Void,YokozunaSchema> |
StoreSchema.executeAsync(RiakCluster cluster) |
protected RiakFuture<Void,YokozunaIndex> |
StoreIndex.executeAsync(RiakCluster cluster) |
protected RiakFuture<SearchOperation.Response,BinaryValue> |
Search.executeAsync(RiakCluster cluster) |
protected RiakFuture<YzGetSchemaOperation.Response,String> |
FetchSchema.executeAsync(RiakCluster cluster) |
protected RiakFuture<YzFetchIndexOperation.Response,String> |
FetchIndex.executeAsync(RiakCluster cluster) |
protected RiakFuture<Void,String> |
DeleteIndex.executeAsync(RiakCluster cluster) |
Modifier and Type | Class and Description |
---|---|
class |
FutureOperation<T,U,S> |
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 |
---|---|
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 |
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 |
YzDeleteIndexOperation |
class |
YzFetchIndexOperation |
class |
YzGetSchemaOperation |
class |
YzPutIndexOperation |
class |
YzPutSchemaOperation |
Copyright © 2014. All rights reserved.