|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use StageContext | |
---|---|
org.apache.commons.pipeline | This package provides a set of pipeline utilities designed around work queues that run in parallel to sequentially process data objects. |
org.apache.commons.pipeline.driver | This package contains implementations of the StageDriver and StageDriverFactory interfaces. |
org.apache.commons.pipeline.stage | A few simple Stage implementations for common use cases. |
org.apache.commons.pipeline.testFramework | Framework classes used to simplify unit test development for pipeline stages. |
Uses of StageContext in org.apache.commons.pipeline |
---|
Classes in org.apache.commons.pipeline that implement StageContext | |
---|---|
class |
Pipeline
This class represents a processing system consisting of a number of stages and branches. |
Methods in org.apache.commons.pipeline with parameters of type StageContext | |
---|---|
T |
StageDriverFactory.createStageDriver(Stage stage,
StageContext context)
This method is used to create a driver that will run the specified stage in the specified context. |
void |
Stage.init(StageContext context)
Initialization takes place when the stage is added to a pipeline. |
Uses of StageContext in org.apache.commons.pipeline.driver |
---|
Fields in org.apache.commons.pipeline.driver declared as StageContext | |
---|---|
protected StageContext |
AbstractStageDriver.context
The context for the stage being run |
Methods in org.apache.commons.pipeline.driver with parameters of type StageContext | |
---|---|
StageDriver |
ThreadPoolStageDriverFactory.createStageDriver(Stage stage,
StageContext context)
Creates the new ThreadPoolStageDriver based upon the configuration
of this factory instance |
StageDriver |
SynchronousStageDriverFactory.createStageDriver(Stage stage,
StageContext context)
Creates a new SynchronousStageDriver based upon this factory's configuration. |
StageDriver |
DedicatedThreadStageDriverFactory.createStageDriver(Stage stage,
StageContext context)
Creates the new DedicatedThreadStageDriver based upon the configuration
of this factory instance |
Constructors in org.apache.commons.pipeline.driver with parameters of type StageContext | |
---|---|
AbstractStageDriver(Stage stage,
StageContext context)
Creates a StageDriver for the specified stage. |
|
AbstractStageDriver(Stage stage,
StageContext context,
FaultTolerance faultTolerance)
Creates a StageDriver for the specified stage. |
|
DedicatedThreadStageDriver(Stage stage,
StageContext context,
BlockingQueue queue,
long timeout,
FaultTolerance faultTolerance)
Creates a new DedicatedThreadStageDriver with the specified thread wait timeout and fault tolerance values. |
|
SynchronousStageDriver(Stage stage,
StageContext context,
FaultTolerance faultTolerance)
Creates a new instance of SimpleStageDriver |
|
ThreadPoolStageDriver(Stage stage,
StageContext context,
BlockingQueue queue,
long timeout,
FaultTolerance faultTolerance,
int numThreads)
Creates a new ThreadPoolStageDriver. |
Uses of StageContext in org.apache.commons.pipeline.stage |
---|
Fields in org.apache.commons.pipeline.stage declared as StageContext | |
---|---|
protected StageContext |
BaseStage.context
The context in which the stage runs. |
protected StageContext |
ExtendedBaseStage.stageContext
|
Methods in org.apache.commons.pipeline.stage with parameters of type StageContext | |
---|---|
void |
KeyWaitBufferStage.init(StageContext context)
|
void |
ExtendedBaseStage.init(StageContext context)
|
void |
BaseStage.init(StageContext context)
This implementation of init() simply stores a reference to the stage context. |
Uses of StageContext in org.apache.commons.pipeline.testFramework |
---|
Classes in org.apache.commons.pipeline.testFramework that implement StageContext | |
---|---|
class |
TestStageContext
Stage Context for test harness. |
Methods in org.apache.commons.pipeline.testFramework with parameters of type StageContext | |
---|---|
void |
TestStage.init(StageContext context)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |