|
||||||||||
| 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.StageEventListener to the context that will be notified by calls
to StageContext.raise(EventObject).
StageEventListener to the context that will be notified by calls
to StageContext.raise(EventObject).
Pipeline.Pipeline to create
a driver for a Stage when that stage is added to the pipeline.EventObjects.StageException without detail message.
StageException with the specified detail message.
StageException with the specified detail message and cause
StageException with the specified detail message and cause
preprocess() method of the attached stage
and to then begin processing any objects fed to this driver's Feeder.
StageDriver for each stage and using that driver to start the stage.
preprocess() method of the attached stage
and to then begin processing any objects fed to this driver's Feeder.
StageDriver implementation uses a pool of threads
to process objects from an input queue.ThreadPoolStageDriver instances configured
to run specific stages.ValidationException without detail message.
ValidationException with the specified detail message.
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||