class Reducer
The Reducer process implements the reduce phase of the map-reduce architecture. The process reads input objects from the channel inputList. It is assumed that each elelemnt of the inputList will send objects in the same sorted order. The Reducer process undertakes a n-way merge operation on the inputs such that it can be guaranteed that all equal inputs will be available to the process at the same time. The reduceFunction then undertakes an operation on all the equal input objects in order to output a single object summarising the inputs. The output object does not have to be of the same class definition as the input object.
inputList
- The ChannelInputList from which input objects are readoutput
- The channel to which the processed object is writtenreduceFunction
- The name of the method in the input object that is the reduce function definitionoutClassName
- The name of the class used for output objectslogPhaseName
- 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 |
---|---|
ChannelInputList |
inputList |
String |
logPhaseName |
String |
logPropertyName |
String |
outClassName |
ChannelOutput |
output |
String |
reduceFunction |
Constructor and description |
---|
Reducer
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk