| Interface | Description |
|---|---|
| IBackoff | |
| PipelineContext |
对Pipeline的计算环境进行抽象, 进行错误处理等工作。
|
| Stage<INPUT,OUTPUT> |
| Class | Description |
|---|---|
| AbstractStage<INPUT,OUTPUT> | |
| Pipeline<INPUT,OUTPUT> | |
| ProcessDataBackoff | |
| ProcessDataPipeline |
ProcessDataPipeline是ChannelConnect上执行数据读取、数据处理的循环流水线处理任务。
每个阶段都可以指定其特定的执行资源(线程池),任务的每个阶段只会占据相应阶段的处理资源,相互之间不会直接影响,相关的线程池配置在
TunnelWorkerConfig里(readRecordsExecutor && processRecordsExecutor)。
当每一轮的数据读取和数据处理完成后,若未发生任何错误,则会马上进行新一轮的处理周期。
|
| ProcessDataPipelineContext |
ProcessDataPipeline计算环境的抽象,主要进行错误处理等操作。
|
| ThreadPoolStageDecorator<INPUT,OUTPUT> | |
| Utils |
| Exception | Description |
|---|---|
| StageException |
Copyright © 2024. All Rights Reserved.