class GroupOfPipelines
A GroupOfPipeline comprises a network of groups parallel occurrences and each pipeline comprises stages Worker processes. Inputs from the preceding process are assumed to come from a channel input list.
inputList
- the ChannelInputList used to read objects into the network created by GroupOfPipelineoutputList
- the ChannelOutputList used to output processed data or worker objectsstages
- 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 in could itself be a list of values.cDetails
- A CompositeDetails object defining the object that defines each of the stages and groupsoutData
- 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.Type | Name and description |
---|---|
CompositeDetails |
cDetails |
int |
groups |
ChannelInputList |
inputList |
String[] |
logPhaseNames |
String |
logPropertyName |
List |
outData |
ChannelOutputList |
outputList |
List |
stageModifier |
List |
stageOp |
int |
stages |
Constructor and description |
---|
GroupOfPipelines
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk