com.basho.riak.client.api

Class RiakCommand<T,S>

java.lang.Object

com.basho.riak.client.api.RiakCommand<T,S>

Type Parameters:

T - The response type

S - The query info type

Direct Known Subclasses:

DeleteIndex, DeleteValue, FetchBucketProperties, FetchDatatype, FetchIndex, FetchSchema, FetchValue, ListBuckets, ListKeys, MapReduce, MultiFetch, Search, SecondaryIndexQuery, StoreBucketProperties, StoreIndex, StoreSchema, StoreValue, UpdateDatatype, UpdateValue

public abstract class RiakCommand<T,S>
extends Object

The base class for all Riak Commands.

All the commands the RiakClient can execute extend this class.

Client Commands

Fetching, storing and deleting objects

• FetchValue
• MultiFetch
• StoreValue
• UpdateValue
• DeleteValue

Listing keys in a namespace

• ListKeys

Secondary index (2i) commands

• RawIndexQuery
• BinIndexQuery
• IntIndexQuery
• BigIntIndexQuery

Fetching and storing datatypes (CRDTs)

• FetchCounter
• FetchSet
• FetchMap
• UpdateCounter
• UpdateSet
• UpdateMap

Querying and modifying buckets

• FetchBucketProperties
• StoreBucketProperties
• ListBuckets

Search commands

• Search
• FetchIndex
• StoreIndex
• DeleteIndex
• FetchSchema
• StoreSchema

Map-Reduce

• BucketMapReduce
• BucketKeyMapReduce
• IndexMapReduce
• SearchMapReduce

Since:

2.0

Author:

Dave Rusek, Brian Roach

Constructor Summary

Constructors

Constructor and Description
RiakCommand()

Method Summary

Methods

Modifier and Type	Method and Description
protected T	execute(RiakCluster cluster)
protected abstract RiakFuture<T,S>	executeAsync(RiakCluster cluster)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RiakCommand

public RiakCommand()

Method Detail

execute

protected final T execute(RiakCluster cluster)
                   throws ExecutionException,
                          InterruptedException

Throws:

ExecutionException

InterruptedException

executeAsync

protected abstract RiakFuture<T,S> executeAsync(RiakCluster cluster)