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.



20666
20667
20668
20669
20670
20671
20672
20673
20674
20675
20676
20677
20678
20679
20680
20681
20682
20683
20684
20685
20686
20687
20688
20689
20690
20691
20692
20693
20694
20695
# File 'lib/v20210820/models.rb', line 20666

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

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名称



20664
20665
20666
# File 'lib/v20210820/models.rb', line 20664

def WriteMode
  @WriteMode
end

Instance Method Details

#deserialize(params) ⇒ Object



20697
20698
20699
20700
20701
20702
20703
20704
20705
20706
20707
20708
20709
20710
20711
20712
20713
20714
20715
20716
20717
20718
20719
20720
20721
20722
20723
20724
20725
20726
20727
20728
20729
20730
20731
20732
20733
20734
20735
20736
20737
20738
20739
20740
20741
20742
20743
20744
20745
20746
20747
20748
20749
20750
# File 'lib/v20210820/models.rb', line 20697

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