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.timeseries | |
com.basho.riak.client.core | |
com.basho.riak.client.core.netty | |
com.basho.riak.client.core.operations | |
com.basho.riak.client.core.operations.ts |
Modifier and Type | Method and Description |
---|---|
protected FutureOperation<CoreR,?,CoreI> |
StreamableRiakCommand.buildCoreOperation() |
protected abstract FutureOperation<CoreR,?,CoreI> |
GenericRiakCommand.buildCoreOperation() |
protected abstract FutureOperation<R,?,I> |
AsIsRiakCommand.buildCoreOperation() |
Modifier and Type | Method and Description |
---|---|
protected abstract R |
GenericRiakCommand.convertResponse(FutureOperation<CoreR,?,CoreI> request,
CoreR coreResponse) |
Modifier and Type | Method and Description |
---|---|
protected ListBuckets.Response |
ListBuckets.convertResponse(FutureOperation<ListBucketsOperation.Response,?,BinaryValue> request,
ListBucketsOperation.Response coreResponse) |
Modifier and Type | Method and Description |
---|---|
protected FutureOperation<DtUpdateOperation.Response,?,Location> |
UpdateDatatype.buildCoreOperation() |
Modifier and Type | Method and Description |
---|---|
protected S |
SecondaryIndexQuery.convertResponse(FutureOperation<SecondaryIndexQueryOperation.Response,?,SecondaryIndexQueryOperation.Query> request,
SecondaryIndexQueryOperation.Response coreResponse) |
Modifier and Type | Method and Description |
---|---|
protected CoveragePlan.Response |
CoveragePlan.convertResponse(FutureOperation<CoveragePlanOperation.Response,?,Namespace> request,
CoveragePlanOperation.Response coreResponse) |
protected FetchValue.Response |
FetchValue.convertResponse(FutureOperation<FetchOperation.Response,?,Location> request,
FetchOperation.Response coreResponse) |
protected ListKeys.Response |
ListKeys.convertResponse(FutureOperation<ListKeysOperation.Response,?,Namespace> request,
ListKeysOperation.Response coreResponse) |
protected StoreValue.Response |
StoreValue.convertResponse(FutureOperation<StoreOperation.Response,?,Location> request,
StoreOperation.Response coreResponse) |
Modifier and Type | Method and Description |
---|---|
protected MapReduce.Response |
MapReduce.convertResponse(FutureOperation<MapReduceOperation.Response,?,BinaryValue> request,
MapReduceOperation.Response coreResponse) |
Modifier and Type | Method and Description |
---|---|
protected FutureOperation<Void,?,String> |
Delete.buildCoreOperation() |
protected FutureOperation<Void,?,String> |
CreateTable.buildCoreOperation() |
protected FutureOperation<CoveragePlanResult,?,String> |
CoveragePlan.buildCoreOperation() |
Modifier and Type | Class and Description |
---|---|
class |
PBStreamingFutureOperation<ReturnType,ResponseType,QueryInfoType> |
Modifier and Type | Method and Description |
---|---|
boolean |
RiakNode.execute(FutureOperation operation)
Submits the operation to be executed on this node.
|
<V,S> RiakFuture<V,S> |
RiakCluster.execute(FutureOperation<V,?,S> operation) |
boolean |
NodeManager.executeOnNode(FutureOperation operation,
RiakNode previousNode) |
boolean |
DefaultNodeManager.executeOnNode(FutureOperation operation,
RiakNode previousNode) |
void |
RiakCluster.operationComplete(FutureOperation operation,
int remainingRetries) |
void |
OperationRetrier.operationComplete(FutureOperation operation,
int remainingRetries) |
void |
RiakCluster.operationFailed(FutureOperation operation,
int remainingRetries) |
void |
OperationRetrier.operationFailed(FutureOperation operation,
int remainingRetries) |
Modifier and Type | Method and Description |
---|---|
protected FutureOperation<?,?,?> |
StoreValueHealthCheck.buildOperation() |
protected FutureOperation<?,?,?> |
PingHealthCheck.buildOperation() |
protected abstract FutureOperation<?,?,?> |
HealthCheckDecoder.buildOperation() |
Modifier and Type | Method and Description |
---|---|
protected void |
RiakOperationEncoder.encode(io.netty.channel.ChannelHandlerContext ctx,
FutureOperation operation,
List<Object> out) |
Modifier and Type | Class and Description |
---|---|
class |
CoveragePlanOperation
An operation to retrieve a coverage plan from Riak.
|
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 |
MapReduceOperation
A Map/Reduce Operation on Riak.
|
class |
PBFutureOperation<T,U,S>
An abstract PB operation that introduces generic encoding/decoding
|
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 |
TTBFutureOperation<T,S>
An abstract TTB operation that introduces generic encoding/decoding
|
class |
YzDeleteIndexOperation |
class |
YzFetchIndexOperation |
class |
YzGetSchemaOperation |
class |
YzPutIndexOperation |
class |
YzPutSchemaOperation |
Modifier and Type | Class and Description |
---|---|
class |
CreateTableOperation
An operation to create a Riak Time Series table according to the provided definition.
|
class |
DescribeTableOperation
An operation to query a table definition from Riak Time Series.
|
class |
ListKeysOperation |
class |
QueryOperation
An operation to query data from a Riak Time Series table.
|
Copyright © 2016. All rights reserved.