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