程序包 | 说明 |
---|---|
com.alicloud.openservices.tablestore.tunnel.pipeline | |
com.alicloud.openservices.tablestore.tunnel.worker |
类和说明 |
---|
AbstractStage |
IBackoff |
PipelineContext
对Pipeline的计算环境进行抽象, 进行错误处理等工作。
|
ProcessDataBackoff |
Stage |
StageException |
类和说明 |
---|
ProcessDataPipeline
ProcessDataPipeline是ChannelConnect上执行数据读取、数据处理的循环流水线处理任务。
|
Copyright © 2019. All Rights Reserved.