com.sh.wf.etl.context

类 ETLContext

java.lang.Object

com.sh.wf.etl.context.Constant

com.sh.wf.etl.context.ETLContext

所有已实现的接口:

java.io.Serializable, java.lang.Cloneable

public class ETLContext
extends Constant

Description: ETL上下文对象

Title:首亨软件 - TSS/CRM等

从以下版本开始:

2017年7月18日

版本:

3.0

作者:

江兴春

另请参阅:

序列化表格

字段概要

从类继承的字段 com.sh.wf.etl.context.Constant

DATACENTER_DBID_PREFIX, ERROR, ETL_DATA_OBJ, FAILURE, MAIN_DATACENTER, MESSAGE, SUCCESS

构造器概要

构造器

构造器和说明
ETLContext(ETLData etlData)

方法概要

限定符和类型	方法和说明
void	addCurETLSyncBase(ETLSyncBase base)
void	addCurFromETLSource(ETLSource fromSource)
void	addCurFromSDBData(SDBData fromSDBData)
void	addCurLineList(java.util.List<ArrowLine> lineList)
void	addCurSyncRowsWithFailure(int rows)
void	addCurSyncRowsWithSuccess(int rows)
void	addCurToETLSource(ETLSource toSource)
void	addCurToSDBData(SDBData toSDBData)
void	closeAllDataCenter() 关闭所有连接
boolean	containKey(java.lang.String key)
boolean	getBoolean(java.lang.String key)
boolean	getBoolean(java.lang.String key, boolean defaultValue)
ETLSource	getCurFromETLSource()
SDBData	getCurFromSDBData()
java.util.List<ArrowLine>	getCurLineList()
int	getCurSyncFailureRows()
int	getCurSyncSuccessRows()
ETLSource	getCurToETLSource()
ETLSyncBase	getCurToETLSyncBase()
SDBData	getCurToSDBData()
DataCenter	getDataCenterByDbId(java.lang.String dbId)
DataCenter	getDataCenterByKey(java.lang.String key) 获取数据库连接对象
DataCenter	getDataCenterBySDBData(SDBData sdbData)
Datastore	getDatastore(java.lang.String key) 获取数据集
double	getDouble(java.lang.String key)
double	getDouble(java.lang.String key, double defaultValue) 获取整型
ETLData	getEtlData()
java.lang.String	getEtlId()
int	getInteger(java.lang.String key)
int	getInteger(java.lang.String key, int defaultValue) 获取整型
java.util.List	getList(java.lang.String key)
DataCenter	getMainDataCenter()
ModuleContext	getModuleContext()
java.lang.String	getRunId()
java.lang.String	getString(java.lang.String key)
java.lang.String	getString(java.lang.String key, java.lang.String defaultValue) 获取字符串
java.lang.String[]	getStringArray(java.lang.String key)
java.lang.Object	getValue(java.lang.String key) 获取上下文中的值
void	putValue(java.lang.String key, java.lang.Object obj) 存值
void	removeByKey(java.lang.String key)

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

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

构造器详细资料

ETLContext

public ETLContext(ETLData etlData)

方法详细资料

getEtlData

public ETLData getEtlData()

getEtlId

public java.lang.String getEtlId()

getModuleContext

public ModuleContext getModuleContext()

addCurFromSDBData

public void addCurFromSDBData(SDBData fromSDBData)

getCurFromSDBData

public SDBData getCurFromSDBData()

addCurToSDBData

public void addCurToSDBData(SDBData toSDBData)

getCurToSDBData

public SDBData getCurToSDBData()

addCurFromETLSource

public void addCurFromETLSource(ETLSource fromSource)

getCurFromETLSource

public ETLSource getCurFromETLSource()

addCurToETLSource

public void addCurToETLSource(ETLSource toSource)

getCurToETLSource

public ETLSource getCurToETLSource()

addCurETLSyncBase

public void addCurETLSyncBase(ETLSyncBase base)

getCurToETLSyncBase

public ETLSyncBase getCurToETLSyncBase()

addCurLineList

public void addCurLineList(java.util.List<ArrowLine> lineList)

getCurLineList

public java.util.List<ArrowLine> getCurLineList()

getRunId

public java.lang.String getRunId()

addCurSyncRowsWithSuccess

public void addCurSyncRowsWithSuccess(int rows)

addCurSyncRowsWithFailure

public void addCurSyncRowsWithFailure(int rows)

getCurSyncSuccessRows

public int getCurSyncSuccessRows()

getCurSyncFailureRows

public int getCurSyncFailureRows()

closeAllDataCenter

public void closeAllDataCenter()

关闭所有连接

getValue

public java.lang.Object getValue(java.lang.String key)

获取上下文中的值

参数:

key - String

返回:

Object

putValue

public void putValue(java.lang.String key,
                     java.lang.Object obj)

存值

参数:

key - String

obj - Object

removeByKey

public void removeByKey(java.lang.String key)

containKey

public boolean containKey(java.lang.String key)

getString

public java.lang.String getString(java.lang.String key,
                                  java.lang.String defaultValue)

获取字符串

参数:

key - String

defaultValue - String

返回:

String

getString

public java.lang.String getString(java.lang.String key)

getStringArray

public java.lang.String[] getStringArray(java.lang.String key)

getInteger

public int getInteger(java.lang.String key)

getInteger

public int getInteger(java.lang.String key,
                      int defaultValue)

获取整型

参数:

key - String

defaultValue - 默认值

返回:

int

getDouble

public double getDouble(java.lang.String key)

getDouble

public double getDouble(java.lang.String key,
                        double defaultValue)

获取整型

参数:

key - String

defaultValue - double

返回:

double

getBoolean

public boolean getBoolean(java.lang.String key)

getBoolean

public boolean getBoolean(java.lang.String key,
                          boolean defaultValue)

getDatastore

public Datastore getDatastore(java.lang.String key)

获取数据集

参数:

key - String

返回:

Datastore

getMainDataCenter

public DataCenter getMainDataCenter()

getDataCenterByDbId

public DataCenter getDataCenterByDbId(java.lang.String dbId)

getDataCenterBySDBData

public DataCenter getDataCenterBySDBData(SDBData sdbData)

getDataCenterByKey

public DataCenter getDataCenterByKey(java.lang.String key)

获取数据库连接对象

参数:

key - String

返回:

DataCenter

getList

public java.util.List getList(java.lang.String key)