Spring Data Key-Value

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

java.lang.Object
  extended by 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 <[email protected]>

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:

Spring Data Key-Value

Copyright © 2010-2011 SpringSource. All Rights Reserved.