ProcessorGraph (stream-framework 0.0.7 API)

java.lang.Object
- xin.manong.stream.framework.processor.ProcessorGraph

public class ProcessorGraph
extends Object

processor拓扑图

作者:: frankcl

构造器概要

构造器
构造器说明

ProcessorGraph(List<ProcessorConfig> processorGraphConfig)

方法概要

所有方法实例方法具体方法
修饰符和类型	方法	说明
`void`	`buildGraph()`	构建processor图，构建失败抛出异常
`void`	`closeGraph()`	关闭processor 根据拓扑图结构依次关闭processor
`boolean`	`containsProcessor(String processorName)`	是否包含processor
`String`	`getId()`	获取插件图ID
`void`	`process(String name, xin.manong.weapon.base.record.KVRecords kvRecords, xin.manong.weapon.base.common.Context context)`	指定processor处理数据

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 构造器详细资料
  - ProcessorGraph
```
public ProcessorGraph(List<ProcessorConfig> processorGraphConfig)
```
- 方法详细资料
  - buildGraph
```
public final void buildGraph()
                      throws xin.manong.stream.sdk.common.UnacceptableException
```
    构建processor图，构建失败抛出异常
    
    抛出:
    
    xin.manong.stream.sdk.common.UnacceptableException - 不可接受异常
  - closeGraph
```
public final void closeGraph()
```
    关闭processor 根据拓扑图结构依次关闭processor
  - process
```
public final void process(String name,
                          xin.manong.weapon.base.record.KVRecords kvRecords,
                          xin.manong.weapon.base.common.Context context)
                   throws Exception
```
    指定processor处理数据
    
    参数:
    
    name - 处理processor名称
    
    kvRecords - 数据
    
    context - 上下文
    
    抛出:
    
    xin.manong.stream.sdk.common.UnacceptableException - 不可接受异常
    
    Exception
  - containsProcessor
```
public final boolean containsProcessor(String processorName)
```
    是否包含processor
    
    参数:
    
    processorName - processor名称
    
    返回:
    
    包含返回true，否则返回false
  - getId
```
public String getId()
```
    获取插件图ID
    
    返回:
    
    插件图ID