xin.manong.stream.framework.processor

类 ProcessorGraph

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 UnacceptableException

构建processor图，构建失败抛出异常

抛出:

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 UnacceptableException

指定processor处理数据

参数:

name - 处理processor名称

kvRecords - 数据

context - 上下文

抛出:

UnacceptableException - 不可接受异常

containsProcessor

public final boolean containsProcessor(String processorName)

是否包含processor

参数:

processorName - processor名称

返回:

包含返回true，否则返回false

getId

public String getId()

获取插件图ID

返回:

插件图ID