程序包 xin.manong.stream.framework.common

类 StreamManager

  • public class StreamManager
extends Object
    数据流管理
    作者:
    frankcl

    • 构造器详细资料

      • StreamManager

        public StreamManager()

    • 方法详细资料

      • buildStreamLogger

        public static void buildStreamLogger​(String filename,
                                     List<String> loggerKeys)
        构建stream框架日志
        参数:
        filename - 日志文件
        loggerKeys - 日志记录key集合

      • commitLog

        public static void commitLog​(xin.manong.weapon.base.record.KVRecord kvRecord)
        提交stream日志
        参数:
        kvRecord - 数据

      • commitLog

        public static void commitLog​(xin.manong.weapon.base.common.Context context)
        提交stream日志
        参数:
        context - 上下文

      • keepWatchRecord

        public static void keepWatchRecord​(xin.manong.weapon.base.record.KVRecord kvRecord,
                                   xin.manong.weapon.base.common.Context context)
        监管流程数据
        参数:
        kvRecord - 数据
        context - 上下文

      • removeStreamHistory

        public static void removeStreamHistory​(xin.manong.weapon.base.record.KVRecord kvRecord)
        抹除stream历史信息，所有__STREAM_开头的字段 例外：__STREAM_HISTORY__
        参数:
        kvRecord - 数据