com.basho.riak.client.api

Class StreamableRiakCommand<R extends StreamableRiakCommand.StreamableResponse,I,CoreR,CoreI>

java.lang.Object

com.basho.riak.client.api.RiakCommand<R,I>

com.basho.riak.client.api.GenericRiakCommand<R,I,CoreR,CoreI>

com.basho.riak.client.api.StreamableRiakCommand<R,I,CoreR,CoreI>

Direct Known Subclasses:

SecondaryIndexQuery, StreamableRiakCommand.StreamableRiakCommandWithSameInfo

public abstract class StreamableRiakCommand<R extends StreamableRiakCommand.StreamableResponse,I,CoreR,CoreI>
extends GenericRiakCommand<R,I,CoreR,CoreI>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StreamableRiakCommand.StreamableResponse<T,S>
static class	StreamableRiakCommand.StreamableRiakCommandWithSameInfo<R extends StreamableRiakCommand.StreamableResponse,I,CoreR>

Nested classes/interfaces inherited from class com.basho.riak.client.api.GenericRiakCommand

GenericRiakCommand.GenericRiakCommandWithSameInfo<R,I,CoreR>

Constructor Summary

Constructors

Constructor and Description
StreamableRiakCommand()

Method Summary

Modifier and Type	Method and Description
protected FutureOperation<CoreR,?,CoreI>	buildCoreOperation()
protected abstract PBStreamingFutureOperation<CoreR,?,CoreI>	buildCoreOperation(boolean streamResults)
protected abstract R	createResponse(int timeout, StreamingRiakFuture<CoreR,CoreI> coreFuture)
protected RiakFuture<R,I>	executeAsyncStreaming(RiakCluster cluster, int timeout)

Methods inherited from class com.basho.riak.client.api.GenericRiakCommand

convertInfo, convertResponse, executeAsync

Methods inherited from class com.basho.riak.client.api.RiakCommand

execute, execute

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamableRiakCommand

public StreamableRiakCommand()

Method Detail

createResponse

protected abstract R createResponse(int timeout,
                                    StreamingRiakFuture<CoreR,CoreI> coreFuture)

buildCoreOperation

protected abstract PBStreamingFutureOperation<CoreR,?,CoreI> buildCoreOperation(boolean streamResults)

buildCoreOperation

protected final FutureOperation<CoreR,?,CoreI> buildCoreOperation()

Specified by:

buildCoreOperation in class GenericRiakCommand<R extends StreamableRiakCommand.StreamableResponse,I,CoreR,CoreI>

executeAsyncStreaming

protected final RiakFuture<R,I> executeAsyncStreaming(RiakCluster cluster,
                                                      int timeout)