class OnePipelineOne
A Pipeline is a collection of WorkerTerminating processes running in sequence each processing instances of the same Class but applying a different operation in each of the Workers.
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 objectstageOp
- 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 processpDetails
- A PipelineDetails object defining any local class of each stage, default to nulloutData
- A list of boolean values one entry per stage, such that if true the worker process 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 specifiedType | Name and description |
---|---|
ChannelInput |
input |
String[] |
logPhaseNames |
String |
logPropertyName |
boolean[] |
outData |
ChannelOutput |
output |
PipelineDetails |
pDetails |
List |
stageModifier |
List |
stageOp |
int |
stages |
Constructor and description |
---|
OnePipelineOne
() |
GPP - Groovy Parallel Patterns generated 06112016 by Jon Kerridge, Edinburgh Napier University - j.kerridge@napier.ac.uk