class PipelineOfGroups
A PipelineOfGroups comprises a collection of Groups, linked together to form a pipeline. The pipeline starts with a GroupFromAny followed by any number of Groups followed by a GroupCollect.
input
- 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 and the GroupCollect stages. There must be at least 2 stages.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 pipelineworkerInitData
- a list of lists of initial data for each worker, one per stageresultsInitData
- Values used to initialise the results classresultsFinaliseData
- Values used by the finalise method in the results 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 Collect processes that will be created
when the Group is run
Further Author Information, Copyright and License are held in the file \\src\\Copyright and License
Type | Name and description |
---|---|
String |
dataClassName |
ChannelInput |
input |
def |
resultsFinaliseData |
def |
resultsInitData |
String |
resultsName |
def |
stageModifier |
def |
stageOp |
int |
stages |
String[] |
workerClassName |
def |
workerInitData |
int |
workers |
Constructor and description |
---|
PipelineOfGroups
() |
GPP - Groovy Parallel Patterns generated test by Jon Kerridge, Edinburgh Napier University - j dot kerridge at napier dot ac dot uk