com.basho.riak.client.core.operations

Class FetchOperation

java.lang.Object

com.basho.riak.client.core.FutureOperation<FetchOperation.Response,com.basho.riak.protobuf.RiakKvPB.RpbGetResp,Location>

com.basho.riak.client.core.operations.FetchOperation

All Implemented Interfaces:

RiakFuture<FetchOperation.Response,Location>, Future<FetchOperation.Response>

public class FetchOperation
extends FutureOperation<FetchOperation.Response,com.basho.riak.protobuf.RiakKvPB.RpbGetResp,Location>

An operation used to fetch an object from Riak.

Since:

2.0

Author:

Brian Roach

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FetchOperation.Builder
protected static class	FetchOperation.KvResponseBase
static class	FetchOperation.Response

Method Summary

Methods

Modifier and Type	Method and Description
protected FetchOperation.Response	convert(List<com.basho.riak.protobuf.RiakKvPB.RpbGetResp> responses)
protected RiakMessage	createChannelMessage()
protected com.basho.riak.protobuf.RiakKvPB.RpbGetResp	decode(RiakMessage message)
Location	getQueryInfo() Returns information related to the operation performed.

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

addListener, await, await, cancel, cause, channelMessage, done, get, get, getNow, isCancelled, isDone, isSuccess, removeListener, setResponse

Methods inherited from class java.lang.Object

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

Method Detail

decode

protected com.basho.riak.protobuf.RiakKvPB.RpbGetResp decode(RiakMessage message)

Specified by:

decode in class FutureOperation<FetchOperation.Response,com.basho.riak.protobuf.RiakKvPB.RpbGetResp,Location>

convert

protected FetchOperation.Response convert(List<com.basho.riak.protobuf.RiakKvPB.RpbGetResp> responses)

Specified by:

convert in class FutureOperation<FetchOperation.Response,com.basho.riak.protobuf.RiakKvPB.RpbGetResp,Location>

createChannelMessage

protected RiakMessage createChannelMessage()

Specified by:

createChannelMessage in class FutureOperation<FetchOperation.Response,com.basho.riak.protobuf.RiakKvPB.RpbGetResp,Location>

getQueryInfo

public Location 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<FetchOperation.Response,Location>

Specified by:

getQueryInfo in class FutureOperation<FetchOperation.Response,com.basho.riak.protobuf.RiakKvPB.RpbGetResp,Location>

Returns:

Information pertaining to the operation attached to this future.