com.basho.riak.client.core.operations

Class SecondaryIndexQueryOperation

java.lang.Object

com.basho.riak.client.core.FutureOperation<T,U,S>

com.basho.riak.client.core.operations.PBFutureOperation<ReturnType,ResponseType,QueryInfoType>

com.basho.riak.client.core.PBStreamingFutureOperation<SecondaryIndexQueryOperation.Response,Object,SecondaryIndexQueryOperation.Query>

com.basho.riak.client.core.operations.SecondaryIndexQueryOperation

All Implemented Interfaces:

RiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query>, StreamingRiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query>, Future<SecondaryIndexQueryOperation.Response>

public class SecondaryIndexQueryOperation
extends PBStreamingFutureOperation<SecondaryIndexQueryOperation.Response,Object,SecondaryIndexQueryOperation.Query>

Since:

2.0

Author:

Brian Roach , Alex Moore

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SecondaryIndexQueryOperation.Builder Builder that constructs a QueryOperation.
static class	SecondaryIndexQueryOperation.Query
static class	SecondaryIndexQueryOperation.Response

Field Summary

Fields inherited from class com.basho.riak.client.core.operations.PBFutureOperation

reqBuilder, reqMessageCode

Method Summary

Modifier and Type	Method and Description
protected SecondaryIndexQueryOperation.Response	convert(List<Object> rawResponse)
protected Object	decode(RiakMessage rawMessage)
protected boolean	done(Object msg) Detect when the streaming operation is finished
SecondaryIndexQueryOperation.Query	getQueryInfo() Returns information related to the operation performed.
protected SecondaryIndexQueryOperation.Response	processStreamingChunk(Object rawResponseChunk)

Methods inherited from class com.basho.riak.client.core.PBStreamingFutureOperation

getResultsQueue, processMessage

Methods inherited from class com.basho.riak.client.core.operations.PBFutureOperation

createChannelMessage

Methods inherited from class com.basho.riak.client.core.FutureOperation

addListener, await, await, cancel, cause, channelMessage, checkAndGetSingleResponse, get, get, getNow, isCancelled, isDone, isSuccess, processBatchMessage, removeListener, setComplete, setResponse

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.basho.riak.client.core.RiakFuture

addListener, await, await, cancel, cause, get, get, getNow, isCancelled, isDone, isSuccess, removeListener

Method Detail

convert

protected SecondaryIndexQueryOperation.Response convert(List<Object> rawResponse)

Specified by:

convert in class FutureOperation<SecondaryIndexQueryOperation.Response,Object,SecondaryIndexQueryOperation.Query>

decode

protected Object decode(RiakMessage rawMessage)

Overrides:

decode in class PBFutureOperation<SecondaryIndexQueryOperation.Response,Object,SecondaryIndexQueryOperation.Query>

done

protected boolean done(Object msg)

Description copied from class: FutureOperation

Detect when the streaming operation is finished

Overrides:

done in class FutureOperation<SecondaryIndexQueryOperation.Response,Object,SecondaryIndexQueryOperation.Query>

Parameters:

msg - raw message

Returns:

returns true if this is the last message in the streaming operation

getQueryInfo

public SecondaryIndexQueryOperation.Query getQueryInfo()

Description copied from interface: RiakFuture

Returns information related to the operation performed.

Useful in async operations when you want to know what operation this future refers to.

Specified by:

getQueryInfo in interface RiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query>

Specified by:

getQueryInfo in class FutureOperation<SecondaryIndexQueryOperation.Response,Object,SecondaryIndexQueryOperation.Query>

Returns:

Information pertaining to the operation attached to this future.

processStreamingChunk

protected SecondaryIndexQueryOperation.Response processStreamingChunk(Object rawResponseChunk)

Specified by:

processStreamingChunk in class PBStreamingFutureOperation<SecondaryIndexQueryOperation.Response,Object,SecondaryIndexQueryOperation.Query>