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

Class MapReduce

java.lang.Object

com.basho.riak.client.api.RiakCommand<MapReduce.Response,BinaryValue>

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

Direct Known Subclasses:

BucketKeyMapReduce, BucketMapReduce, IndexMapReduce, SearchMapReduce

public abstract class MapReduce
extends RiakCommand<MapReduce.Response,BinaryValue>

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 Map Reduce command.

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
protected RiakFuture<MapReduce.Response,BinaryValue>	executeAsync(RiakCluster cluster)

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

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

executeAsync

protected RiakFuture<MapReduce.Response,BinaryValue> executeAsync(RiakCluster cluster)

Specified by:

executeAsync in class RiakCommand<MapReduce.Response,BinaryValue>