class Mapper
The Mapper process implements the Map part of the map-reduce architecture. The process inputs an input class object, which is transformed into one or more output class objects by means of the map fuction specified in the input class.
input
- The channel from which the input object to be processed is readoutput
- The channel to which the mapped output object is writtenoutClassname
- The name of the output classmapFunction
- The name of the method in the input object that is the map function definitioncreateClass
- The name of the method in the output object that is used to set the properties of an object instancelogPhaseName
- an optional string property, which if specified indicates that the process should be logged
otherwise the process will not be loggedlogPropertyName
- the name of a property in the input object that will uniquely identify an instance of the object.
LogPropertyName must be specified if logPhaseName is specifiedType | Name and description |
---|---|
String |
createClass |
ChannelInput |
input |
String |
logPhaseName |
String |
logPropertyName |
String |
mapFunction |
String |
outClassName |
ChannelOutput |
output |
Constructor and description |
---|
Mapper
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk