com.basho.riak.client.core.operations

Class MapReduceOperation

java.lang.Object

com.basho.riak.client.core.FutureOperation<MapReduceOperation.Response,com.basho.riak.protobuf.RiakKvPB.RpbMapRedResp,BinaryValue>

com.basho.riak.client.core.operations.MapReduceOperation

All Implemented Interfaces:

RiakFuture<MapReduceOperation.Response,BinaryValue>, Future<MapReduceOperation.Response>

public class MapReduceOperation
extends FutureOperation<MapReduceOperation.Response,com.basho.riak.protobuf.RiakKvPB.RpbMapRedResp,BinaryValue>

A Map/Reduce Operation on Riak. No error checking is done on the content type of the content itself with the exception to making sure they are provided.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MapReduceOperation.Builder
static class	MapReduceOperation.Response

Method Summary

Methods

Modifier and Type	Method and Description
protected MapReduceOperation.Response	convert(List<com.basho.riak.protobuf.RiakKvPB.RpbMapRedResp> rawResponse)
protected RiakMessage	createChannelMessage()
protected com.basho.riak.protobuf.RiakKvPB.RpbMapRedResp	decode(RiakMessage rawMessage)
protected boolean	done(com.basho.riak.protobuf.RiakKvPB.RpbMapRedResp message) Detect when the streaming operation is finished
BinaryValue	getQueryInfo() Returns information related to the operation performed.

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

addListener, await, await, cancel, cause, channelMessage, 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

convert

protected MapReduceOperation.Response convert(List<com.basho.riak.protobuf.RiakKvPB.RpbMapRedResp> rawResponse)

Specified by:

convert in class FutureOperation<MapReduceOperation.Response,com.basho.riak.protobuf.RiakKvPB.RpbMapRedResp,BinaryValue>

createChannelMessage

protected RiakMessage createChannelMessage()

Specified by:

createChannelMessage in class FutureOperation<MapReduceOperation.Response,com.basho.riak.protobuf.RiakKvPB.RpbMapRedResp,BinaryValue>

decode

protected com.basho.riak.protobuf.RiakKvPB.RpbMapRedResp decode(RiakMessage rawMessage)

Specified by:

decode in class FutureOperation<MapReduceOperation.Response,com.basho.riak.protobuf.RiakKvPB.RpbMapRedResp,BinaryValue>

done

protected boolean done(com.basho.riak.protobuf.RiakKvPB.RpbMapRedResp message)

Description copied from class: FutureOperation

Detect when the streaming operation is finished

Overrides:

done in class FutureOperation<MapReduceOperation.Response,com.basho.riak.protobuf.RiakKvPB.RpbMapRedResp,BinaryValue>

Parameters:

message - raw message

Returns:

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

getQueryInfo

public BinaryValue 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<MapReduceOperation.Response,BinaryValue>

Specified by:

getQueryInfo in class FutureOperation<MapReduceOperation.Response,com.basho.riak.protobuf.RiakKvPB.RpbMapRedResp,BinaryValue>

Returns:

Information pertaining to the operation attached to this future.