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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
phase
protected MapReducePhase.Phase phase
language
protected String language
operation
protected MapReduceOperation operation
keepResults
protected boolean keepResults
RiakMapReducePhase
public RiakMapReducePhase(String phase,
String language,
MapReduceOperation oper)
RiakMapReducePhase
public RiakMapReducePhase(MapReducePhase.Phase phase,
String language,
MapReduceOperation oper)
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)
Copyright © 2010 SpringSource. All Rights Reserved.