class GroupOfPipelineCollects
A GroupOfPipelineCollects comprises a network of groups parallel occurrences and each pipeline comprises stages Worker processes, excluding the final Collect stage. Inputs from the preceding process are assumed to come from the any end of a channel.
inputAny
- the any end of channel used to read objects into the network created by GroupOfPipelineCollectsstages
- the number of stages in each pipeline excluding the Collect processgroups
- the number of parallel pipelines in the networkstageOp
- a list of function identifiers to be associated with each stage of the pipelinestageModifier
- a list of groups lists, each containing stages elements that are the
stage modifier data for that combination of group and stage. Each entry could itself be a list of values.outData
- a list of groups lists each entry of which comprises stages entries. Each entry is a boolean value
such that if true the worker processes in that stage
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. If omitted the value defaults to true.cDetails
- A CompositeDetails object defining the object that defines each of the stages and groupsrDetails
- A ResultDetails object defining the result class used by the Collect processlogPhaseName
- an optional list of string values, which if specified indicates that the processes in the Pipeline should be logged
otherwise the process will not be logged. Specific stages in the Pipeline can be logged by specifying a string value, otherwise the value must
be an empty stringlogPropertyName
- 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 specifiedlogFileName
- is a string value specifying that the log output should be written to a file rather than the console.
The filename string should contain the full pathe name. The suffix.log will be added to the file name. Each log file in
the group will be identified by its index.Type | Name and description |
---|---|
CompositeDetails |
cDetails |
int |
groups |
ChannelInput |
inputAny |
String |
logFileName |
String[] |
logPhaseNames |
String |
logPropertyName |
List |
outData |
ResultDetails |
rDetails |
List |
stageModifier |
List |
stageOp |
int |
stages |
Constructor and description |
---|
GroupOfPipelineCollects
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk