Spring Data Key-Value

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

java.lang.Object
  extended by 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

Spring Data Key-Value

Copyright © 2010-2011 SpringSource. All Rights Reserved.