Class: TencentCloud::Wedata::V20210820::GenHiveTableDDLSqlRequest

Inherits:
Common::AbstractModel
  • Object
show all
Defined in:
lib/v20210820/models.rb

Overview

GenHiveTableDDLSql请求参数结构体

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(projectid = nil, sinkdatabase = nil, id = nil, mstype = nil, datasourceid = nil, sourcedatabase = nil, tablename = nil, sinktype = nil, schemaname = nil, sourcefieldinfolist = nil, partitions = nil, properties = nil, tablemode = nil, tableversion = nil, upsertflag = nil, tablecomment = nil, adddatafiles = nil, addequalitydeletes = nil, addpositiondeletes = nil, adddeletefiles = nil, targetdatasourceid = nil, upsertkeys = nil, tablebaseinfo = nil, sinkschemaname = nil, env = nil, writemode = nil, tasktype = nil, sinktablename = nil) ⇒ GenHiveTableDDLSqlRequest

Returns a new instance of GenHiveTableDDLSqlRequest.



20800
20801
20802
20803
20804
20805
20806
20807
20808
20809
20810
20811
20812
20813
20814
20815
20816
20817
20818
20819
20820
20821
20822
20823
20824
20825
20826
20827
20828
20829
# File 'lib/v20210820/models.rb', line 20800

def initialize(projectid=nil, sinkdatabase=nil, id=nil, mstype=nil, datasourceid=nil, sourcedatabase=nil, tablename=nil, sinktype=nil, schemaname=nil, sourcefieldinfolist=nil, partitions=nil, properties=nil, tablemode=nil, tableversion=nil, upsertflag=nil, tablecomment=nil, adddatafiles=nil, addequalitydeletes=nil, addpositiondeletes=nil, adddeletefiles=nil, targetdatasourceid=nil, upsertkeys=nil, tablebaseinfo=nil, sinkschemaname=nil, env=nil, writemode=nil, tasktype=nil, sinktablename=nil)
  @ProjectId = projectid
  @SinkDatabase = sinkdatabase
  @Id = id
  @MsType = mstype
  @DatasourceId = datasourceid
  @SourceDatabase = sourcedatabase
  @TableName = tablename
  @SinkType = sinktype
  @SchemaName = schemaname
  @SourceFieldInfoList = sourcefieldinfolist
  @Partitions = partitions
  @Properties = properties
  @TableMode = tablemode
  @TableVersion = tableversion
  @UpsertFlag = upsertflag
  @TableComment = tablecomment
  @AddDataFiles = adddatafiles
  @AddEqualityDeletes = addequalitydeletes
  @AddPositionDeletes = addpositiondeletes
  @AddDeleteFiles = adddeletefiles
  @TargetDatasourceId = targetdatasourceid
  @UpsertKeys = upsertkeys
  @TableBaseInfo = tablebaseinfo
  @SinkSchemaName = sinkschemaname
  @Env = env
  @WriteMode = writemode
  @TaskType = tasktype
  @SinkTableName = sinktablename
end

Instance Attribute Details

#AddDataFilesObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def AddDataFiles
  @AddDataFiles
end

#AddDeleteFilesObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def AddDeleteFiles
  @AddDeleteFiles
end

#AddEqualityDeletesObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def AddEqualityDeletes
  @AddEqualityDeletes
end

#AddPositionDeletesObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def AddPositionDeletes
  @AddPositionDeletes
end

#DatasourceIdObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def DatasourceId
  @DatasourceId
end

#EnvObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def Env
  @Env
end

#IdObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def Id
  @Id
end

#MsTypeObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def MsType
  @MsType
end

#PartitionsObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def Partitions
  @Partitions
end

#ProjectIdObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def ProjectId
  @ProjectId
end

#PropertiesObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def Properties
  @Properties
end

#SchemaNameObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def SchemaName
  @SchemaName
end

#SinkDatabaseObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def SinkDatabase
  @SinkDatabase
end

#SinkSchemaNameObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def SinkSchemaName
  @SinkSchemaName
end

#SinkTableNameObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def SinkTableName
  @SinkTableName
end

#SinkTypeObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def SinkType
  @SinkType
end

#SourceDatabaseObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def SourceDatabase
  @SourceDatabase
end

#SourceFieldInfoListObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def SourceFieldInfoList
  @SourceFieldInfoList
end

#TableBaseInfoObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def TableBaseInfo
  @TableBaseInfo
end

#TableCommentObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def TableComment
  @TableComment
end

#TableModeObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def TableMode
  @TableMode
end

#TableNameObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def TableName
  @TableName
end

#TableVersionObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def TableVersion
  @TableVersion
end

#TargetDatasourceIdObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def TargetDatasourceId
  @TargetDatasourceId
end

#TaskTypeObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def TaskType
  @TaskType
end

#UpsertFlagObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def UpsertFlag
  @UpsertFlag
end

#UpsertKeysObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def UpsertKeys
  @UpsertKeys
end

#WriteModeObject

Parameters:

  • ProjectId:

    项目id

  • SinkDatabase:

    目标数据库

  • Id:

    节点id

  • MsType:

    元数据类型(MYSQL、ORACLE)

  • DatasourceId:

    数据源id

  • SourceDatabase:

    来源库名

  • TableName:

    来源表名

  • SinkType:

    目标表元数据类型(HIVE、GBASE)

  • SchemaName:

    源端schema名称

  • SourceFieldInfoList:

    上游节点的字段信息

  • Partitions:

    分区字段

  • Properties:

    建表属性

  • TableMode:

    建表模式,0:向导模式,1:ddl

  • TableVersion:

    DLC表版本,v1/v2

  • UpsertFlag:

    是否upsert写入

  • TableComment:

    表描述信息

  • AddDataFiles:

    增加的文件数量阈值, 超过值将触发小文件合并

  • AddEqualityDeletes:

    增加的Equality delete数量阈值, 超过值将触发小文件合并

  • AddPositionDeletes:

    增加的Position delete数量阈值, 超过值将触发小文件合并

  • AddDeleteFiles:

    增加的delete file数量阈值

  • TargetDatasourceId:

    下游节点数据源ID

  • UpsertKeys:

    dlc upsert主键

  • TableBaseInfo:

    dlc表治理信息

  • SinkSchemaName:

    目标端schema名称

  • Env:

    获取源信息的环境

  • WriteMode:

    doris写入模式配置

  • TaskType:

    任务类型 201(实时), 202(离线)

  • SinkTableName:

    目标端table名称



20798
20799
20800
# File 'lib/v20210820/models.rb', line 20798

def WriteMode
  @WriteMode
end

Instance Method Details

#deserialize(params) ⇒ Object



20831
20832
20833
20834
20835
20836
20837
20838
20839
20840
20841
20842
20843
20844
20845
20846
20847
20848
20849
20850
20851
20852
20853
20854
20855
20856
20857
20858
20859
20860
20861
20862
20863
20864
20865
20866
20867
20868
20869
20870
20871
20872
20873
20874
20875
20876
20877
20878
20879
20880
20881
20882
20883
20884
# File 'lib/v20210820/models.rb', line 20831

def deserialize(params)
  @ProjectId = params['ProjectId']
  @SinkDatabase = params['SinkDatabase']
  @Id = params['Id']
  @MsType = params['MsType']
  @DatasourceId = params['DatasourceId']
  @SourceDatabase = params['SourceDatabase']
  @TableName = params['TableName']
  @SinkType = params['SinkType']
  @SchemaName = params['SchemaName']
  unless params['SourceFieldInfoList'].nil?
    @SourceFieldInfoList = []
    params['SourceFieldInfoList'].each do |i|
      sourcefieldinfo_tmp = SourceFieldInfo.new
      sourcefieldinfo_tmp.deserialize(i)
      @SourceFieldInfoList << sourcefieldinfo_tmp
    end
  end
  unless params['Partitions'].nil?
    @Partitions = []
    params['Partitions'].each do |i|
      partition_tmp = Partition.new
      partition_tmp.deserialize(i)
      @Partitions << partition_tmp
    end
  end
  unless params['Properties'].nil?
    @Properties = []
    params['Properties'].each do |i|
      property_tmp = Property.new
      property_tmp.deserialize(i)
      @Properties << property_tmp
    end
  end
  @TableMode = params['TableMode']
  @TableVersion = params['TableVersion']
  @UpsertFlag = params['UpsertFlag']
  @TableComment = params['TableComment']
  @AddDataFiles = params['AddDataFiles']
  @AddEqualityDeletes = params['AddEqualityDeletes']
  @AddPositionDeletes = params['AddPositionDeletes']
  @AddDeleteFiles = params['AddDeleteFiles']
  @TargetDatasourceId = params['TargetDatasourceId']
  @UpsertKeys = params['UpsertKeys']
  unless params['TableBaseInfo'].nil?
    @TableBaseInfo = TableBaseInfo.new
    @TableBaseInfo.deserialize(params['TableBaseInfo'])
  end
  @SinkSchemaName = params['SinkSchemaName']
  @Env = params['Env']
  @WriteMode = params['WriteMode']
  @TaskType = params['TaskType']
  @SinkTableName = params['SinkTableName']
end