|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Feeder | |
---|---|
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.testFramework | Framework classes used to simplify unit test development for pipeline stages. |
Uses of Feeder in org.apache.commons.pipeline |
---|
Fields in org.apache.commons.pipeline declared as Feeder | |
---|---|
static Feeder |
Feeder.VOID
This Feeder implementation provides a standard, no-op sink for objects. |
Methods in org.apache.commons.pipeline that return Feeder | |
---|---|
Feeder |
StageContext.getBranchFeeder(String branch)
Return the source feeder for the specified pipeline branch. |
Feeder |
Pipeline.getBranchFeeder(String branch)
Return the source feeder for the specified pipeline branch. |
Feeder |
StageContext.getDownstreamFeeder(Stage stage)
This method is used by a stage driver to pass data from one stage to the next. |
Feeder |
Pipeline.getDownstreamFeeder(Stage stage)
This method is used by a stage driver to pass data from one stage to the next. |
Feeder |
StageDriver.getFeeder()
This method is used to provide a communication channel between the context in which the driver is being run and the managed stage. |
Feeder |
Pipeline.getSourceFeeder()
Returns a feeder for the first stage if the pipeline is not empty |
Feeder |
Pipeline.getTerminalFeeder()
Gets the feeder that receives output from the final stage. |
Methods in org.apache.commons.pipeline with parameters of type Feeder | |
---|---|
void |
Pipeline.setTerminalFeeder(Feeder terminalFeeder)
Sets the terminal feeder used to handle any output from the final stage. |
Uses of Feeder in org.apache.commons.pipeline.driver |
---|
Methods in org.apache.commons.pipeline.driver that return Feeder | |
---|---|
Feeder |
ThreadPoolStageDriver.getFeeder()
Return the Feeder used to feed data to the queue of objects to be processed. |
Feeder |
SynchronousStageDriver.getFeeder()
Get the feeder for the encapsulated stage. |
Feeder |
DedicatedThreadStageDriver.getFeeder()
Return the Feeder used to feed data to the queue of objects to be processed. |
abstract Feeder |
AbstractStageDriver.getFeeder()
This method is used to provide a communication channel between the context in which the driver is being run and the managed stage. |
Uses of Feeder in org.apache.commons.pipeline.testFramework |
---|
Classes in org.apache.commons.pipeline.testFramework that implement Feeder | |
---|---|
class |
TestFeeder
This feeder simply adds the received objects to a list. |
Fields in org.apache.commons.pipeline.testFramework with type parameters of type Feeder | |
---|---|
Map<Stage,Feeder> |
TestStageContext.downstreamFeeders
|
Methods in org.apache.commons.pipeline.testFramework that return Feeder | |
---|---|
Feeder |
TestStageContext.getBranchFeeder(String key)
Dynamically adds branch feeders as needed to provide a feeder for the requested branch key. |
Feeder |
TestStageContext.getDownstreamFeeder(Stage stage)
Dynamically adds downstream feeders as needed to provide a downstream feeder for the specified stage. |
Methods in org.apache.commons.pipeline.testFramework with parameters of type Feeder | |
---|---|
void |
TestStageContext.registerDownstreamFeeder(Stage stage,
Feeder feeder)
This method is used by the test implementation to set up the feeders for a stage as though they were provided by drivers in a pipeline. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |