类 ProcessorGraphFactory
- java.lang.Object
-
- xin.manong.stream.framework.processor.ProcessorGraphFactory
-
public class ProcessorGraphFactory extends Object
processor拓扑图工厂- 作者:
- frankcl
-
-
方法概要
所有方法 静态方法 具体方法 修饰符和类型 方法 说明 static voidclean(String processorGraphId)清理指定ID插件图static ProcessorGraphmake(List<ProcessorConfig> graphConfig)构建processor拓扑图static voidsweep()清理工厂:清除所有processorGraph
-
-
-
方法详细资料
-
make
public static ProcessorGraph make(List<ProcessorConfig> graphConfig) throws xin.manong.stream.sdk.common.UnacceptableException
构建processor拓扑图- 参数:
graphConfig- processor图配置- 返回:
- 成功返回processorGraph,否则返回null
- 抛出:
xin.manong.stream.sdk.common.UnacceptableException- 创建失败抛出异常
-
clean
public static void clean(String processorGraphId)
清理指定ID插件图- 参数:
processorGraphId- 清理插件图ID
-
sweep
public static void sweep()
清理工厂:清除所有processorGraph
-
-