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

All Superinterfaces:

Callable

All Known Implementing Classes:

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.
<T> T	getArg() Get the static argument for this job.
<V> List<V>	getInputs() Get the list of inputs for this job.
void	setArg(T arg) Set the static argument 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:

setArg

void setArg(T arg)

Set the static argument for this job.

Parameters:

arg -

getArg

<T> T getArg()

Get the static argument for this job.

Type Parameters:

T -

Returns:

toJson

String toJson()

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

Returns: