xin.manong.stream.framework.processor

类 ProcessorGraphFactory

java.lang.Object

xin.manong.stream.framework.processor.ProcessorGraphFactory

public class ProcessorGraphFactory
extends Object

processor拓扑图工厂

作者:

frankcl

方法概要

限定符和类型	方法和说明
static void	clean(String processorGraphId) 清理指定ID插件图
static ProcessorGraph	make(List<ProcessorConfig> graphConfig) 构建processor拓扑图
static void	sweep() 清理工厂：清除所有processorGraph

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

方法详细资料

make

public static ProcessorGraph make(List<ProcessorConfig> graphConfig)
                           throws UnacceptableException

构建processor拓扑图

参数:

graphConfig - processor图配置

返回:

成功返回processorGraph，否则返回null

抛出:

UnacceptableException - 创建失败抛出异常

clean

public static void clean(String processorGraphId)

清理指定ID插件图

参数:

processorGraphId - 清理插件图ID

sweep

public static void sweep()

清理工厂：清除所有processorGraph