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

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

All Implemented Interfaces:

Callable, MapReduceJob

Direct Known Subclasses:

AsyncRiakMapReduceJob, RiakMapReduceJob

public abstract class AbstractRiakMapReduceJob
extends Object
implements MapReduceJob

An implementation of MapReduceJob for the Riak data store.

Author:

J. Brisbin

Field Summary

protected List<Object>	inputs
protected org.apache.commons.logging.Log	log
protected List<MapReducePhase>	phases

Constructor Summary

AbstractRiakMapReduceJob()

Method Summary

MapReduceJob	addInputs(List keys) Set the list of inputs for this job.
MapReduceJob	addPhase(MapReducePhase phase) Add a phase to this operation.
List	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 class java.lang.Object

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

Methods inherited from interface java.util.concurrent.Callable

call

Field Detail

log

protected final org.apache.commons.logging.Log log

inputs

protected List<Object> inputs

phases

protected List<MapReducePhase> phases

Constructor Detail

AbstractRiakMapReduceJob

public AbstractRiakMapReduceJob()

Method Detail

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:

getPhases

public List<MapReducePhase> getPhases()

Description copied from interface: MapReduceJob

Get the list of phases for this job.

Specified by:

getPhases 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: