org.springframework.data.keyvalue.riak.mapreduce
Class RiakMapReduceJob

java.lang.Object
  org.springframework.data.keyvalue.riak.mapreduce.RiakMapReduceJob

All Implemented Interfaces:

Callable, MapReduceJob

public class RiakMapReduceJob
extends Object
implements MapReduceJob

An implementation of MapReduceJob for the Riak data store.

Author:

J. Brisbin

Field Summary

protected Object	arg
protected List<Object>	inputs
protected org.slf4j.Logger	log
protected List<MapReducePhase>	phases
protected RiakTemplate	riakTemplate

Constructor Summary

RiakMapReduceJob(RiakTemplate riakTemplate)

Method Summary

MapReduceJob	addInputs(List keys) Set the list of inputs for this job.
MapReduceJob	addPhase(MapReducePhase phase) Add a phase to this operation.
Object	call()
Object	getArg() Get the static argument for this job.
List	getInputs() Get the list of inputs for this job.
RiakTemplate	getRiakTemplate()
void	setArg(Object arg) Set the static argument for this job.
void	setRiakTemplate(RiakTemplate riakTemplate)
String	toJson() Convert this job into the appropriate JSON to send to the server.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected final org.slf4j.Logger log

inputs

protected List<Object> inputs

phases

protected List<MapReducePhase> phases

arg

protected Object arg

riakTemplate

protected RiakTemplate riakTemplate

Constructor Detail

RiakMapReduceJob

public RiakMapReduceJob(RiakTemplate riakTemplate)

Method Detail

getRiakTemplate

public RiakTemplate getRiakTemplate()

setRiakTemplate

public void setRiakTemplate(RiakTemplate riakTemplate)

getInputs

public List getInputs()

Description copied from interface: MapReduceJob

Get the list of inputs for this job.

Specified by:

getInputs in interface MapReduceJob

Returns:

addInputs

public MapReduceJob addInputs(List keys)

Description copied from interface: MapReduceJob

Set the list of inputs for this job.

Specified by:

addInputs in interface MapReduceJob

Returns:

addPhase

public MapReduceJob addPhase(MapReducePhase phase)

Description copied from interface: MapReduceJob

Add a phase to this operation.

Specified by:

addPhase in interface MapReduceJob

Returns:

setArg

public void setArg(Object arg)

Description copied from interface: MapReduceJob

Set the static argument for this job.

Specified by:

setArg in interface MapReduceJob

getArg

public Object getArg()

Description copied from interface: MapReduceJob

Get the static argument for this job.

Specified by:

getArg in interface MapReduceJob

Returns:

toJson

public String toJson()

Description copied from interface: MapReduceJob

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

Specified by:

toJson in interface MapReduceJob

Returns:

call

public Object call()
            throws Exception

Specified by:

call in interface Callable

Throws:

Exception