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:

AsIsRiakCommand, GenericRiakCommand, MultiDelete, MultiFetch, 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

Modifier and Type	Method and Description
protected T	execute(RiakCluster cluster)
protected T	execute(RiakCluster cluster, long timeout, TimeUnit unit)
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

execute

protected final T execute(RiakCluster cluster,
                          long timeout,
                          TimeUnit unit)
                   throws ExecutionException,
                          InterruptedException,
                          TimeoutException

Throws:

ExecutionException

InterruptedException

TimeoutException

executeAsync

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