class ListReduceList
The ListReduceList process implements the reduce phase of the map-reduce architecture. By means of a group of org.jcsp.gpp.mapReduce.Reduce processes. Initially the process splits the inputlist into a number of sublists, one per Reducer. Each Reducer writes to one element of the outputList.
In a map-reduce archiecture the number of reducers must be a factor of the number of mappers
inputList
- The ChannelInputList from which input objects are readoutputList
- The ChannelOutputList to which each Reducer writes to one elementreducers
- An int specifying the number of Reducer processesreduceFunction
- 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 |
ChannelOutputList |
outputList |
String |
reduceFunction |
int |
reducers |
Constructor and description |
---|
ListReduceList
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk