com.basho.riak.client.api.commands.mapreduce

Class MapReduce

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,I>

com.basho.riak.client.api.StreamableRiakCommand.StreamableRiakCommandWithSameInfo<MapReduce.Response,BinaryValue,MapReduceOperation.Response>

com.basho.riak.client.api.commands.mapreduce.MapReduce

Direct Known Subclasses:

BucketKeyMapReduce, BucketMapReduce, IndexMapReduce, SearchMapReduce

public abstract class MapReduce
extends StreamableRiakCommand.StreamableRiakCommandWithSameInfo<MapReduce.Response,BinaryValue,MapReduceOperation.Response>

Base abstract class for all MapReduce commands.

See Map/Reduce for details.

Since:

2.0

Author:

Dave Rusek

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	MapReduce.Builder<T extends MapReduce.Builder<T>> Base abstract class for all MapReduce command builders.
static class	MapReduce.Response Response from a MapReduce command.

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

StreamableRiakCommand.StreamableResponse<T,S>, 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

Modifier	Constructor and Description
protected	MapReduce(MapReduceInput input, MapReduce.Builder builder)

Method Summary

Modifier and Type	Method and Description
protected MapReduceOperation	buildCoreOperation(boolean streamResults)
protected MapReduce.Response	convertResponse(FutureOperation<MapReduceOperation.Response,?,BinaryValue> request, MapReduceOperation.Response coreResponse)
protected MapReduce.Response	createResponse(int timeout, StreamingRiakFuture<MapReduceOperation.Response,BinaryValue> coreFuture)

Methods inherited from class com.basho.riak.client.api.StreamableRiakCommand.StreamableRiakCommandWithSameInfo

convertInfo

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

buildCoreOperation, executeAsyncStreaming

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

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

MapReduce

protected MapReduce(MapReduceInput input,
                    MapReduce.Builder builder)

Method Detail

buildCoreOperation

protected MapReduceOperation buildCoreOperation(boolean streamResults)

Specified by:

buildCoreOperation in class StreamableRiakCommand<MapReduce.Response,BinaryValue,MapReduceOperation.Response,BinaryValue>

convertResponse

protected MapReduce.Response convertResponse(FutureOperation<MapReduceOperation.Response,?,BinaryValue> request,
                                             MapReduceOperation.Response coreResponse)

Specified by:

convertResponse in class GenericRiakCommand<MapReduce.Response,BinaryValue,MapReduceOperation.Response,BinaryValue>

createResponse

protected MapReduce.Response createResponse(int timeout,
                                            StreamingRiakFuture<MapReduceOperation.Response,BinaryValue> coreFuture)

Specified by:

createResponse in class StreamableRiakCommand<MapReduce.Response,BinaryValue,MapReduceOperation.Response,BinaryValue>