class PipelineOfGroups
A PipelineOfGroups comprises a collection of Groups, linked together to form a pipeline. The pipeline starts with an AnyGroupList followed by zero or more ListGroupList processes followed by a ListGroupAny process.
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.dataClassName
- The name of the Class to be processed by each of the
contained Worker processesresultsName
- The Class name of the data object used to hold the resultsworkerClassName
- a List of worker class names one for each stage of the pipeline excluding the GroupCollect stageworkerInitData
- a list of lists of initial data for each worker, each list contains workers elements such that
[ [S0W0, S0W1, ... ,S0Wl], ..., [SgW0, SgW1, ... ,SgWl]]
where l is the index of the last Worker process, that is workers - 1 and
and g is the index of the last group, that is stages -1resultsInitData
- Values used to initialise the results classresultsFinaliseData
- Values used by the finalise method in the results classresultInit
- The name of the method that implements the initialise method of the result classresultCollector
- The name of the method that implements the collector method of the result classresultFinalise
- The name of the method that implements the finalise method of the result classstageOp
- 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 stagemodifier
- 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 runoutData
- 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.Type | Name and description |
---|---|
CompositeDetails |
cDetails |
ChannelInput |
inputAny |
String[] |
logPhaseNames |
String |
logPropertyName |
boolean[] |
outData |
ChannelOutput |
outputAny |
List |
stageModifier |
List |
stageOp |
int |
stages |
int |
workers |
Constructor and description |
---|
PipelineOfGroups
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk