| 程序包 | 说明 |
|---|---|
| xin.manong.stream.framework.processor | |
| xin.manong.stream.framework.receiver | |
| xin.manong.stream.framework.runner |
| 限定符和类型 | 方法和说明 |
|---|---|
boolean |
Processor.init(ProcessorConfig config)
初始化processor
|
| 限定符和类型 | 方法和说明 |
|---|---|
static ProcessorGraph |
ProcessorGraphFactory.make(List<ProcessorConfig> graphConfig)
构建processor拓扑图
|
| 构造器和说明 |
|---|
ProcessorGraph(List<ProcessorConfig> processorGraphConfig) |
| 限定符和类型 | 方法和说明 |
|---|---|
boolean |
ReceiveController.init(ReceiveControllerConfig config,
List<ProcessorConfig> processorGraphConfig)
初始化
|
| 构造器和说明 |
|---|
ReceiveManager(List<ReceiveControllerConfig> configList,
List<ProcessorConfig> processorGraphConfig) |
ReceiveProcessorImpl(String name,
List<String> processors,
List<ProcessorConfig> processorGraphConfig,
ReceiveConverter converter) |
| 限定符和类型 | 字段和说明 |
|---|---|
List<ProcessorConfig> |
StreamRunnerConfig.processors |
Copyright © 2023. All rights reserved.