org.springframework.data.keyvalue.riak.mapreduce
Interface MapReduceJob<T>

All Superinterfaces:

Callable

All Known Implementing Classes:

AbstractRiakMapReduceJob, AsyncRiakMapReduceJob, RiakMapReduceJob

public interface MapReduceJob<T>
extends Callable

A generic interface to representing a Map/Reduce job to a data store that supports that operation.

Author:

J. Brisbin

Method Summary

<V> MapReduceJob	addInputs(List<V> keys) Set the list of inputs for this job.
MapReduceJob	addPhase(MapReducePhase phase) Add a phase to this operation.
<V> List<V>	getInputs() Get the list of inputs for this job.
List<MapReducePhase>	getPhases() Get the list of phases for this job.
String	toJson() Convert this job into the appropriate JSON to send to the server.

Methods inherited from interface java.util.concurrent.Callable

call

Method Detail

getInputs

<V> List<V> getInputs()

Get the list of inputs for this job.

Returns:

addInputs

<V> MapReduceJob addInputs(List<V> keys)

Set the list of inputs for this job.

Type Parameters:

V -

Parameters:

keys -

Returns:

addPhase

MapReduceJob addPhase(MapReducePhase phase)

Add a phase to this operation.

Parameters:

phase -

Returns:

getPhases

List<MapReducePhase> getPhases()

Get the list of phases for this job.

Returns:

toJson

String toJson()

Convert this job into the appropriate JSON to send to the server.

Returns: