public class MapPhase extends Object implements MapReducePhase
MapReducePhase.PhaseType
Constructor and Description |
---|
MapPhase(Function phaseFunction)
Create a MapPhase
|
MapPhase(Function phaseFunction,
boolean keep)
Create a MapPhase
|
MapPhase(Function phaseFunction,
Object arg)
Create a MapPhase
|
MapPhase(Function phaseFunction,
Object arg,
boolean keepResult)
Create a MapPhase
|
Modifier and Type | Method and Description |
---|---|
Object |
getArg() |
Function |
getPhaseFunction() |
MapReducePhase.PhaseType |
getType()
The PhaseType of this
MapReducePhase implementation. |
Boolean |
isKeep()
Is this phase's output to be returned or only passed as input to the next phase.
|
static MapPhase |
map(Function function,
Object arg,
boolean keep) |
public MapPhase(Function phaseFunction, Object arg, boolean keepResult)
phaseFunction
- the Function
arg
- an argument that will be passed to the phase verbatim
(Object#toString)keepResult
- if the result should be returned or merely provide input for
the next phase.MapReduce.addMapPhase(Function, Object, boolean)
public MapPhase(Function phaseFunction, Object arg)
phaseFunction
- the Function
arg
- an argument that will be passed to the phase verbatim
(Object#toString)MapReduce.addMapPhase(Function, Object)
public MapPhase(Function phaseFunction)
phaseFunction
- the Function
MapReduce.addMapPhase(Function)
public MapPhase(Function phaseFunction, boolean keep)
phaseFunction
- the Function
keepResult
- if the result should be returned or merely provide input for
the next phase.MapReduce.addMapPhase(Function, Object, boolean)
public Function getPhaseFunction()
public Boolean isKeep()
MapReducePhase
isKeep
in interface MapReducePhase
public Object getArg()
public MapReducePhase.PhaseType getType()
MapReducePhase
MapReducePhase
implementation.getType
in interface MapReducePhase
Copyright © 2013. All Rights Reserved.