| Constructor and Description |
|---|
ThreadPoolStageDecorator(Stage<INPUT,OUTPUT> stage,
ExecutorService executorService) |
| Modifier and Type | Method and Description |
|---|---|
void |
init(PipelineContext context) |
void |
process(INPUT input) |
void |
setNextStage(Stage<?,?> nextPipe) |
void |
shutdown() |
public ThreadPoolStageDecorator(Stage<INPUT,OUTPUT> stage, ExecutorService executorService)
public void setNextStage(Stage<?,?> nextPipe)
setNextStage in interface Stage<INPUT,OUTPUT>public void init(PipelineContext context)
Copyright © 2024. All Rights Reserved.