Uses of Interface
org.springframework.data.keyvalue.riak.mapreduce.MapReduceJob

Packages that use MapReduceJob

org.springframework.data.keyvalue.riak.core
org.springframework.data.keyvalue.riak.mapreduce

Uses of MapReduceJob in org.springframework.data.keyvalue.riak.core

Methods in org.springframework.data.keyvalue.riak.core with parameters of type MapReduceJob

Object	RiakTemplate.execute(MapReduceJob job)
Object	RiakKeyValueTemplate.execute(MapReduceJob job)
<R> Future<?>	AsyncRiakTemplate.execute(MapReduceJob job, AsyncKeyValueStoreOperation<List<?>,R> callback)
<T> T	RiakTemplate.execute(MapReduceJob job, Class<T> targetType)
<T> T	RiakKeyValueTemplate.execute(MapReduceJob job, Class<T> targetType)
<T> Future<List<T>>	RiakTemplate.submit(MapReduceJob job)
<T> Future<List<T>>	RiakKeyValueTemplate.submit(MapReduceJob job)

Uses of MapReduceJob in org.springframework.data.keyvalue.riak.mapreduce

Classes in org.springframework.data.keyvalue.riak.mapreduce that implement MapReduceJob

class	AbstractRiakMapReduceJob An implementation of MapReduceJob for the Riak data store.
class	AsyncRiakMapReduceJob An implementation of MapReduceJob for the Riak data store.
class	RiakMapReduceJob An implementation of MapReduceJob for the Riak data store.

Methods in org.springframework.data.keyvalue.riak.mapreduce that return MapReduceJob

MapReduceJob	AbstractRiakMapReduceJob.addInputs(List keys)
<V> MapReduceJob	MapReduceJob.addInputs(List<V> keys) Set the list of inputs for this job.
MapReduceJob	MapReduceJob.addPhase(MapReducePhase phase) Add a phase to this operation.
MapReduceJob	AbstractRiakMapReduceJob.addPhase(MapReducePhase phase)

Methods in org.springframework.data.keyvalue.riak.mapreduce with parameters of type MapReduceJob

Object	MapReduceOperations.execute(MapReduceJob job) Execute a MapReduceJob synchronously.
<R> Future<?>	AsyncMapReduceOperations.execute(MapReduceJob job, AsyncKeyValueStoreOperation<List<?>,R> callback) Execute a MapReduceJob synchronously.
<T> T	MapReduceOperations.execute(MapReduceJob job, Class<T> targetType) Execute a MapReduceJob synchronously, converting the result into the given type.
<T> Future<List<T>>	MapReduceOperations.submit(MapReduceJob job) Submit the job to run asynchronously.