程序包 com.sh.wf.etl.log

类 ETLRunLog

java.lang.Object

com.sh.wf.etl.log.ETLRunLog

所有已实现的接口:

DBQueue

public class ETLRunLog
extends Object
implements DBQueue

Description: ETL执行记录的日志

Title:首亨软件 - TSS/CRM等

从以下版本开始:

2017-07-31

字段概要

字段

修饰符和类型	字段	说明
protected static org.apache.logging.log4j.Logger	log4j

构造器概要

构造器

构造器	说明
ETLRunLog()

方法概要

修饰符和类型	方法	说明
void	execute(DataCenter dc)	执行当前需要处理的队列里的操作
boolean	getWaitTimeout()	该队列等待执行超时设置，当返回true时表示进入执行时间
static void	putQueue(ETLContext etlContext, Exception _ex)
static void	putQueue(ETLContext etlContext, String log)	添加到队列
static void	putQueue(ETLContext etlContext, String sql, Datastore ds)
static void	putQueue(ETLContext etlContext, String sql, String[] updateMsg)
static void	putQueue(ETLContext etlContext, String sql, String[] colsType, Object[] obj)
static void	putQueue(ETLContext etlContext, String sql, String[] colsType, Object[] obj, Datastore ds)
static void	putQueue(ETLContext etlContext, String sql, String[] colsType, Object[] obj, String[] updateMsg)
boolean	start()	启动队列，只会执行一次

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

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

字段详细资料

log4j

protected static org.apache.logging.log4j.Logger log4j

构造器详细资料

ETLRunLog

public ETLRunLog()

方法详细资料

putQueue

public static void putQueue(ETLContext etlContext,
 String log)

添加到队列

参数:

etlContext - ETLContext

log - 日志信息

putQueue

public static void putQueue(ETLContext etlContext,
 String sql,
 String[] colsType,
 Object[] obj)

putQueue

public static void putQueue(ETLContext etlContext,
 String sql,
 Datastore ds)

putQueue

public static void putQueue(ETLContext etlContext,
 String sql,
 String[] colsType,
 Object[] obj,
 Datastore ds)

putQueue

public static void putQueue(ETLContext etlContext,
 String sql,
 String[] updateMsg)

putQueue

public static void putQueue(ETLContext etlContext,
 String sql,
 String[] colsType,
 Object[] obj,
 String[] updateMsg)

putQueue

public static void putQueue(ETLContext etlContext,
 Exception _ex)

start

public boolean start()

从接口复制的说明: DBQueue

启动队列，只会执行一次

指定者:

start 在接口中 DBQueue

返回:

boolean

getWaitTimeout

public boolean getWaitTimeout()

从接口复制的说明: DBQueue

该队列等待执行超时设置，当返回true时表示进入执行时间

指定者:

getWaitTimeout 在接口中 DBQueue

返回:

boolean

execute

public void execute(DataCenter dc)

从接口复制的说明: DBQueue

执行当前需要处理的队列里的操作

指定者:

execute 在接口中 DBQueue

参数:

dc - DataCenter