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.



21490
21491
21492
21493
21494
21495
21496
21497
21498
21499
21500
21501
21502
21503
21504
21505
21506
21507
21508
21509
21510
21511
21512
21513
21514
21515
21516
21517
21518
21519
# File 'lib/v20210820/models.rb', line 21490

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

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



21488
21489
21490
# File 'lib/v20210820/models.rb', line 21488

def WriteMode
  @WriteMode
end

Instance Method Details

#deserialize(params) ⇒ Object



21521
21522
21523
21524
21525
21526
21527
21528
21529
21530
21531
21532
21533
21534
21535
21536
21537
21538
21539
21540
21541
21542
21543
21544
21545
21546
21547
21548
21549
21550
21551
21552
21553
21554
21555
21556
21557
21558
21559
21560
21561
21562
21563
21564
21565
21566
21567
21568
21569
21570
21571
21572
21573
21574
# File 'lib/v20210820/models.rb', line 21521

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