xin.manong.stream.framework.common

类 StreamManager

java.lang.Object

xin.manong.stream.framework.common.StreamManager

public class StreamManager
extends Object

数据流管理

作者:

frankcl

构造器概要

构造器

构造器和说明
StreamManager()

方法概要

限定符和类型	方法和说明
static void	buildStreamLogger(String filename, List<String> loggerKeys) 构建stream框架日志
static void	commitLog(xin.manong.weapon.base.common.Context context) 提交stream日志
static void	commitLog(xin.manong.weapon.base.record.KVRecord kvRecord) 提交stream日志
static void	keepWatchRecord(xin.manong.weapon.base.record.KVRecord kvRecord, xin.manong.weapon.base.common.Context context) 监管流程数据

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

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

构造器详细资料

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 - 上下文