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

类 ETLContext

java.lang.Object
com.sh.wf.etl.context.Constant
com.sh.wf.etl.context.ETLContext
所有已实现的接口:
Serializable, Cloneable
public class ETLContext extends Constant

Description: ETL上下文对象

Title:首亨软件 - TSS/CRM等

从以下版本开始:
2017年7月18日
另请参阅:

  • 字段详细资料

    • log4j

      protected org.apache.logging.log4j.Logger log4j

  • 构造器详细资料

    • ETLContext

      public ETLContext(ETLData etlData)

  • 方法详细资料

    • getEtlData

      public ETLData getEtlData()

    • getEtlId

      public 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(List<ArrowLine> lineList)

    • getCurLineList

      public List<ArrowLine> getCurLineList()

    • getRunId

      public 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 Object getValue(String key)
      获取上下文中的值
      参数:
      key - String
      返回:
      Object

    • putValue

      public void putValue(String key, Object obj)
      存值
      参数:
      key - String
      obj - Object

    • removeByKey

      public void removeByKey(String key)

    • containKey

      public boolean containKey(String key)

    • getString

      public String getString(String key, String defaultValue)
      获取字符串
      参数:
      key - String
      defaultValue - String
      返回:
      String

    • getString

      public String getString(String key)

    • getStringArray

      public String[] getStringArray(String key)

    • getInteger

      public int getInteger(String key)

    • getInteger

      public int getInteger(String key, int defaultValue)
      获取整型
      参数:
      key - String
      defaultValue - 默认值
      返回:
      int

    • getDouble

      public double getDouble(String key)

    • getDouble

      public double getDouble(String key, double defaultValue)
      获取整型
      参数:
      key - String
      defaultValue - double
      返回:
      double

    • getBoolean

      public boolean getBoolean(String key)

    • getBoolean

      public boolean getBoolean(String key, boolean defaultValue)

    • getDatastore

      public Datastore getDatastore(String key)
      获取数据集
      参数:
      key - String
      返回:
      Datastore

    • getMainDataCenter

      public DataCenter getMainDataCenter()

    • getDataCenterByDbId

      public DataCenter getDataCenterByDbId(String dbId)

    • getDataCenterBySDBData

      public DataCenter getDataCenterBySDBData(SDBData sdbData)

    • getDataCenterByKey

      public DataCenter getDataCenterByKey(String key)
      获取数据库连接对象
      参数:
      key - String
      返回:
      DataCenter

    • getList

      public List getList(String key)