|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
Stage object to the end of this Pipeline.
BaseStage.preprocess(), #process(), BaseStage.postprocess(),
and BaseStage.release() methods.StageDriver implementations require for one or more queues
to be created.StageDedicatedThreadStageDriver based upon the configuration
of this factory instance
SynchronousStageDriver based upon this factory's configuration.
ThreadPoolStageDriver based upon the configuration
of this factory instance
StageExceptions for every other object this
stage processes.Stage is used
to recursively find (non-directory) files that match the specified regex.StageDriver
for each stage and using that driver to request that the stage finish
execution.
Stage provides the
functionality needed to retrieve data from an FTP URL.StageEventListeners registered with the
context.
StageEventListeners registered with the
context.
Stage provides the
functionality needed to retrieve data from an HTTP URL.StageEvent
ObjectProcessedEvents
received from each StagePipelineFactorys.PipelineCreationException without detail message.
PipelineCreationException with the specified detail message.
PipelineCreationException with the specified detail message.
PipelineCreationException with the specified detail message.
workDir uf it does
not exist and makes a connection to the remote FTP server.
methodName, calls it to process the object, and
exqueues any returned object.
Feeder.
Stage.Stage produces the same type
of object that is consumed (or any subtype thereof).Stage
for a specific branch pipeline.StageDriver implementations require for one or more queues
to be created.