class PipelineCollect
A PipelineCollect is a collection of Worker processes running in sequence each processing instances of the same Class called className but applying a different operation in each of the Workers. The final stage of the pipeline is a collect process
input
- The channel from which data objects are read. The channel
is a one2one typically connected to an EmitToOne process.output
- The channel upon which processed data objects are written. The
channel must be a one2one channel and will typically be connected to
a Collect process.stages
- The number of Worker processes in the pipeline. Normally there will
be as many stages as there are operations performed on each data object.
The Collect process at the end of the pipeline is not included in this value.
There must be at least 2 stages in the pipeline followed by a Collect process.dataClassName
- The name of the data class to be processed by each of the
contained Worker processesstageOp
- A List containing the code value identifying the operation to be undertaken
by each Worker process. The operation codes must be specified in the
order in which they are to be carried out.stageModifier
- A List containing a modifier value, if any, for each stage of the pipeline.
There must be as many elements in the List as there are stages. Any stage
not requiring a modifier must specify null. If omitted completely a null will
passed to each Worker process. There must be as many elements in the List as
there are stages. Any stage not requiring a modifier must specify null.
If omitted completely a null will passed to each Worker processworkerClassName
- a List containing the name of the Worker class associated with each stage
of the pipelineworkerInitData
- A List containing worker class initialisation data for each stage of the pipeline.
There must be as many elements in the List as there are stages. Any stage
not requiring a modifier must specify null. If omitted completely a null will
passed to each Worker process. There must be as many elements in the List as
there are stages. Any stage not requiring a modifier must specify null.
If omitted completely a null will passed to each Worker processresultClassName
- the name of the result classresultInitData
- the data value(s) used to initialise the result classfinaliseData
- the data values passed to the finalise operation of the result class
Further Author Information, Copyright and License are held in the file \\src\\Copyright and License
Type | Name and description |
---|---|
String |
dataClassName |
def |
finaliseData |
ChannelInput |
input |
String |
resultClassName |
def |
resultInitData |
def |
stageModifier |
def |
stageOp |
int |
stages |
String[] |
workerClassName |
def |
workerInitData |
Constructor and description |
---|
PipelineCollect
() |
GPP - Groovy Parallel Patterns generated test by Jon Kerridge, Edinburgh Napier University - j dot kerridge at napier dot ac dot uk