类的使用
com.sh.wf.etl.context.ETLContext

使用ETLContext的程序包

程序包	说明
com.sh.wf.etl
com.sh.wf.etl.base
com.sh.wf.etl.batch
com.sh.wf.etl.compontent
com.sh.wf.etl.java
com.sh.wf.etl.log
com.sh.wf.etl.sdb
com.sh.wf.etl.sync
com.sh.wf.etl.sync.impl
com.sh.wf.etl.util

com.sh.wf.etl中ETLContext的使用

参数类型为ETLContext的com.sh.wf.etl中的方法

限定符和类型	方法和说明
void	ETLData.run(ETLContext etlContext)

com.sh.wf.etl.base中ETLContext的使用

参数类型为ETLContext的com.sh.wf.etl.base中的方法

限定符和类型	方法和说明
java.lang.String	JavaAttr.etlNodeWhere(ETLContext context)
void	JavaAttr.etlTaskAfter(ETLContext context)
void	JavaAttr.etlTaskBfore(ETLContext context)
void	JavaAttr.etlTaskEverySubmit(ETLContext context)
java.lang.Object	JavaAttr.lineTransferData(ETLContext context, java.lang.Object value)
void	ETLColumnObj.processCheckExistSql(ETLContext etlContext, SqlBuilder sb, Datastore ds, RowInfo rowInfo) 查询语句条件
java.lang.String	ETLColumnObj.processExecuteBeforeSql(ETLContext etlContext, java.lang.String sql, DataCenter toDc, Datastore ds, RowInfo rowInfo) 处理执行前的SQL
void	ETLColumnObj.processExecuteBeforeSqlReset(ETLContext etlContext)
void	ETLColumnObj.processFixColumnObj(ETLContext etlContext, java.lang.StringBuilder toInsertColSql, java.lang.StringBuilder toInsertValueSql, java.lang.StringBuilder toUpdateSql, java.lang.StringBuilder toUpdateWhereSql, DataCenter toDc) 设置目标表固定列

com.sh.wf.etl.batch中ETLContext的使用

参数类型为ETLContext的com.sh.wf.etl.batch中的构造器

构造器和说明
BatchInstance(ETLContext etlContext, DataCenter dc)
BatchOperate(ETLContext etlContext, DataCenter dc)

com.sh.wf.etl.compontent中ETLContext的使用

参数类型为ETLContext的com.sh.wf.etl.compontent中的方法

限定符和类型	方法和说明
void	ETLBase.processCheckExistSql(ETLContext etlContext, SqlBuilder sb, Datastore ds, RowInfo rowInfo)
java.lang.String	ETLBase.processExecuteBeforeSql(ETLContext etlContext, java.lang.String sql, DataCenter toDc, Datastore ds, RowInfo rowInfo) 处理执行前的SQL
void	ETLBase.processExecuteBeforeSqlReset(ETLContext etlContext)
void	ETLBase.processFixColumnObj(ETLContext etlContext, java.lang.StringBuilder toInsertColSql, java.lang.StringBuilder toInsertValueSql, java.lang.StringBuilder toUpdateSql, java.lang.StringBuilder toUpdateWhereSql, DataCenter toDc) 设置固定列
void	ArrowLine.processFromSql(ETLContext etlContext, java.lang.StringBuilder sql, SDBData fromSDB, SDBData toSDB)
void	ArrowLine.processToSql(ETLContext etlContext, java.lang.StringBuilder colSql, java.lang.StringBuilder valueSql, SDBData fromSDB, SDBData toSDB)
void	ArrowLine.processToUpdateSql(ETLContext etlContext, java.lang.StringBuilder toUpdateSql, java.lang.StringBuilder toUpdateWhereSql, SDBData fromSDB, SDBData toSDB)
void	ETLSource.run(ETLContext etlContext)
abstract void	ETLBase.run(ETLContext etlContext)
java.lang.Object	ArrowLine.transferData(ETLContext context, java.lang.Object value) 数据自定义转换

com.sh.wf.etl.java中ETLContext的使用

参数类型为ETLContext的com.sh.wf.etl.java中的方法

限定符和类型	方法和说明
void	ETLJavaBase.setETLContext(ETLContext context)
void	ETLJavaBase.setETLContext(ETLContext context, JavaAttr javaAttr)

com.sh.wf.etl.log中ETLContext的使用

参数类型为ETLContext的com.sh.wf.etl.log中的方法

限定符和类型	方法和说明
static void	ETLRunLog.putQueue(ETLContext etlContext, java.lang.Exception _ex)
static void	ETLRunLog.putQueue(ETLContext etlContext, java.lang.String log) 添加到队列
static void	ETLRunLog.putQueue(ETLContext etlContext, java.lang.String sql, Datastore ds)
static void	ETLRunLog.putQueue(ETLContext etlContext, java.lang.String sql, java.lang.String[] updateMsg)
static void	ETLRunLog.putQueue(ETLContext etlContext, java.lang.String sql, java.lang.String[] colsType, java.lang.Object[] obj)
static void	ETLRunLog.putQueue(ETLContext etlContext, java.lang.String sql, java.lang.String[] colsType, java.lang.Object[] obj, Datastore ds)
static void	ETLRunLog.putQueue(ETLContext etlContext, java.lang.String sql, java.lang.String[] colsType, java.lang.Object[] obj, java.lang.String[] updateMsg)

com.sh.wf.etl.sdb中ETLContext的使用

参数类型为ETLContext的com.sh.wf.etl.sdb中的方法

限定符和类型	方法和说明
void	SyncInfo.execute(ETLContext etlContext) 已过时。

com.sh.wf.etl.sync中ETLContext的使用

参数类型为ETLContext的com.sh.wf.etl.sync中的方法

限定符和类型	方法和说明
java.lang.String	ETLSyncBase.getfromTableColByToTableCol(ETLContext etlContext, java.lang.String toTableCol)
abstract void	ETLSyncBase.sync(ETLContext etlContext) 各种条件下需要实现的同步方式
void	ETLSync_I.syncData(ETLContext etlContext) 同步数据
void	ETLSyncBase.syncData(ETLContext etlContext)

com.sh.wf.etl.sync.impl中ETLContext的使用

参数类型为ETLContext的com.sh.wf.etl.sync.impl中的方法

限定符和类型	方法和说明
void	ETLSyncPKData.sync(ETLContext etlContext)
void	ETLSyncIncrementDataByORAROWSCN.sync(ETLContext etlContext)
void	ETLSyncIncrement.sync(ETLContext etlContext)
void	ETLSyncFullData.sync(ETLContext etlContext)

com.sh.wf.etl.util中ETLContext的使用

参数类型为ETLContext的com.sh.wf.etl.util中的方法

限定符和类型	方法和说明
static void	ETLLogUtil.clearETLCacheLog(ETLContext etlContext)
static void	ETLLogUtil.dataLog(ETLContext etlContext, java.lang.String str) 记录数据日志
static void	ETLLogUtil.dataLog(ETLContext etlContext, java.lang.String str, java.lang.String[] colType, java.lang.Object[] obj, java.lang.String[] updateMsg)
static ETLSyncBase	ETLSyncUtil.getSync(ETLContext etlContext, ETLSource fromSource)
static void	ETLLogUtil.log(ETLContext etlContext, Datastore ds, java.lang.String str) 记录日志
static void	ETLLogUtil.log(ETLContext etlContext, Datastore ds, java.lang.String str, java.util.List<java.lang.String> colsTypeList, java.util.List<java.lang.Object> objList)
static void	ETLLogUtil.log(ETLContext etlContext, Datastore ds, java.lang.String str, java.lang.String[] colsType, java.lang.Object[] obj) 记录日志
static void	ETLLogUtil.log(ETLContext etlContext, java.lang.String str)
static void	ETLLogUtil.log(ETLContext etlContext, java.lang.String str, java.lang.Object... params) 日志
static void	ETLLogUtil.log(ETLContext etlContext, java.lang.String str, java.lang.String[] colsType, java.lang.Object[] obj)
static void	ETLLogUtil.logForever(ETLContext etlContext, java.lang.String str)
static void	ETLLogUtil.sysout(ETLContext etlContext, java.lang.String str) 普通日志