A DataParallelCollect comprises a sequence of processes in a so-called Farm. The sequence comprises Emit; OneFanAny; AnyGroupAny; AnyFanOne; Collect. The properties of the pattern provide all the external values required to run the pattern. The internal channels required to connect the processes together are all declared within the class outwith programmer concerns.
eDetails
- A DataDetails object containing information concerning the DataClass
used by the Emit processgDetails
- A GroupDetails object containing information concerning the contained group of workers
used by the Emit processfunction
- A String value identifying the operation to be undertaken
by the Worker processesmodifier
- Contains a possible modifier for the operation, with each Worker
accessing the element that corresponds to the index of the Worker.rDetails
- A ResultDetails object containing data pertaining to result class used by the Collect process, it MUST be specified.workers
- The number of Worker processes that will be created
when the Group is runoutData
- If true the process will output each processed input object. If false the process will output
the workerClass once only, after it has processed all the input data objects. The output
only happens after the finalise method has been called. outData defaults to true.Type | Name and description |
---|---|
DataDetails |
eDetails |
String |
function |
GroupDetails |
gDetails |
List |
modifier |
boolean |
outData |
ResultDetails |
rDetails |
def |
run |
int |
workers |
Constructor and description |
---|
DataParallelCollect
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk