类 ProcessorGraphFactory


  • public class ProcessorGraphFactory
    extends Object
    processor拓扑图工厂
    作者:
    frankcl
    • 方法详细资料

      • 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