A TaskParallelOFGroupCollects comprises a sequence of processes in a so-called Farm. The sequence comprises Emit; OneFanAny; PipelineOfGroupCollects. 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 processlDetails
- A LocalDetails list object containing information concerning each stage of the PipelinestageOp
- A List of String values identifying the operation to be undertaken
by each stage processstageModifier
- A List containing the possible modifiers for the operation, within each stage by each worker in a group
accessing the element that corresponds to the index of the stage.workers
- An int specifying the number of workers in the PipelineOfGroupCollectscDetails
- A List of CompositeDetails objects containing data pertaining to each group of processes.rDetails
- A ResultDetails object containing data pertaining to result class used by the Collect process, it MUST be specified.stages
- The number of stages in the pipeline of processes that will be created
when the Pipeline is runoutData
- A List of booleans. If true the stage with the same index will output each processed input object. If false the stage 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, ... true]Type | Name and description |
---|---|
CompositeDetails |
cDetails |
DataDetails |
eDetails |
boolean[] |
outData |
ResultDetails |
rDetails |
List |
stageModifier |
List |
stageOp |
int |
stages |
int |
workers |
Constructor and description |
---|
TaskParallelOfGroupCollects
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk