Package | Description |
---|---|
com.basho.riak.client.api |
Contains the main RiakClient used to query Riak.
|
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 |
Modifier and Type | Method and Description |
---|---|
protected T |
RiakCommand.execute(RiakCluster cluster) |
protected abstract RiakFuture<T,S> |
RiakCommand.executeAsync(RiakCluster cluster) |
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<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 | 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) |
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 |
---|---|
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 | Method and Description |
---|---|
RiakCluster |
RiakCluster.Builder.build()
Instantiates the
RiakCluster |
Copyright © 2014. All rights reserved.