class PipelineOfGroupCollects
A PipelineOfGroupCollects comprises a collection of Groups, linked together to form a pipeline. The pipeline starts with an AnyGroupList followed by zero of more ListGroupList processes followed by a GroupCollect.
inputAny
- The channel upon which data objects are read. This will be from a FanOutAny process.stages
- The number of stages in the pipeline including the initial
GroupFromAny but excluding the GroupCollect stage. There must be at least 1, the AnyGroupList, stage.stageOp
- a List of operation code values identifying the operation to be undertaken
by the Worker processes in each stage of the pipeline excluding the Collect stagestageModifier
- Contains a possible modifier for the operation, with each Stage
accessing the element that corresponds to the index of the Stage excluding the Collect stage.workers
- The number of Worker processes that will be created
when each Group is runcDetails
- 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 processoutData
- A list of boolean values one entry per stage, excluding the GroupCollect stage,
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. The output
only happens after the finalise method has been called. outData defaults to true.logPhaseName
- 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 |
ChannelInput |
inputAny |
String |
logFileName |
String[] |
logPhaseNames |
String |
logPropertyName |
boolean[] |
outData |
ResultDetails |
rDetails |
List |
stageModifier |
List |
stageOp |
int |
stages |
int |
workers |
Constructor and description |
---|
PipelineOfGroupCollects
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk