接口 | 说明 |
---|---|
IBackoff | |
PipelineContext |
对Pipeline的计算环境进行抽象, 进行错误处理等工作。
|
Stage<INPUT,OUTPUT> |
类 | 说明 |
---|---|
AbstractStage<INPUT,OUTPUT> | |
Pipeline<INPUT,OUTPUT> | |
ProcessDataBackoff | |
ProcessDataPipeline |
ProcessDataPipeline是ChannelConnect上执行数据读取、数据处理的循环流水线处理任务。
|
ProcessDataPipelineContext |
ProcessDataPipleline计算环境的抽象,主要进行错误处理等操作。
|
ThreadPoolStageDecorator<INPUT,OUTPUT> | |
Utils |
异常错误 | 说明 |
---|---|
StageException |
Copyright © 2019. All Rights Reserved.