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

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

All Implemented Interfaces:

MapReducePhase

public class RiakMapReducePhase
extends Object
implements MapReducePhase

An implementation of MapReducePhase for the Riak data store.

Author:

J. Brisbin

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.data.keyvalue.riak.mapreduce.MapReducePhase

MapReducePhase.Phase

Field Summary

protected Object	arg
protected boolean	keepResults
protected String	language
protected MapReduceOperation	operation
protected MapReducePhase.Phase	phase

Constructor Summary

RiakMapReducePhase(MapReducePhase.Phase phase, String language, MapReduceOperation oper)

RiakMapReducePhase(String phase, String language, MapReduceOperation oper)

Method Summary

Object	getArg() Get the static argument for this phase.
boolean	getKeepResults() Whether or not to keep the result of this phase.
String	getLanguage() The language this phase is described in.
MapReduceOperation	getOperation() Get the operation this phase will execute.
MapReducePhase.Phase	getPhase()
void	setArg(Object arg) Set the static argument for this job.
void	setKeepResults(boolean keepResults)
void	setOperation(MapReduceOperation oper)

Methods inherited from class java.lang.Object

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

Field Detail

phase

protected MapReducePhase.Phase phase

language

protected String language

operation

protected MapReduceOperation operation

keepResults

protected boolean keepResults

arg

protected Object arg

Constructor Detail

RiakMapReducePhase

public RiakMapReducePhase(String phase,
                          String language,
                          MapReduceOperation oper)

RiakMapReducePhase

public RiakMapReducePhase(MapReducePhase.Phase phase,
                          String language,
                          MapReduceOperation oper)

Method Detail

getPhase

public MapReducePhase.Phase getPhase()

Specified by:

getPhase in interface MapReducePhase

getLanguage

public String getLanguage()

Description copied from interface: MapReducePhase

The language this phase is described in.

Specified by:

getLanguage in interface MapReducePhase

Returns:

getOperation

public MapReduceOperation getOperation()

Description copied from interface: MapReducePhase

Get the operation this phase will execute.

Specified by:

getOperation in interface MapReducePhase

Returns:

getKeepResults

public boolean getKeepResults()

Description copied from interface: MapReducePhase

Whether or not to keep the result of this phase.

Specified by:

getKeepResults in interface MapReducePhase

Returns:

setKeepResults

public void setKeepResults(boolean keepResults)

setOperation

public void setOperation(MapReduceOperation oper)

getArg

public Object getArg()

Description copied from interface: MapReducePhase

Get the static argument for this phase.

Specified by:

getArg in interface MapReducePhase

Returns:

setArg

public void setArg(Object arg)

Description copied from interface: MapReducePhase

Set the static argument for this job.

Specified by:

setArg in interface MapReducePhase