Class: TencentCloud::Wedata::V20210820::GenHiveTableDDLSqlRequest
- Inherits:
-
Common::AbstractModel
- Object
- Common::AbstractModel
- TencentCloud::Wedata::V20210820::GenHiveTableDDLSqlRequest
- Defined in:
- lib/v20210820/models.rb
Overview
GenHiveTableDDLSql请求参数结构体
Instance Attribute Summary collapse
- #AddDataFiles ⇒ Object
- #AddDeleteFiles ⇒ Object
- #AddEqualityDeletes ⇒ Object
- #AddPositionDeletes ⇒ Object
- #DatasourceId ⇒ Object
- #Env ⇒ Object
- #Id ⇒ Object
- #MsType ⇒ Object
- #Partitions ⇒ Object
- #ProjectId ⇒ Object
- #Properties ⇒ Object
- #SchemaName ⇒ Object
- #SinkDatabase ⇒ Object
- #SinkSchemaName ⇒ Object
- #SinkTableName ⇒ Object
- #SinkType ⇒ Object
- #SourceDatabase ⇒ Object
- #SourceFieldInfoList ⇒ Object
- #TableBaseInfo ⇒ Object
- #TableComment ⇒ Object
- #TableMode ⇒ Object
- #TableName ⇒ Object
- #TableVersion ⇒ Object
- #TargetDatasourceId ⇒ Object
- #TaskType ⇒ Object
- #UpsertFlag ⇒ Object
- #UpsertKeys ⇒ Object
- #WriteMode ⇒ Object
Instance Method Summary collapse
- #deserialize(params) ⇒ Object
-
#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
constructor
A new instance of GenHiveTableDDLSqlRequest.
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
#AddDataFiles ⇒ Object
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 |
#AddDeleteFiles ⇒ Object
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 |
#AddEqualityDeletes ⇒ Object
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 |
#AddPositionDeletes ⇒ Object
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 |
#DatasourceId ⇒ Object
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 |
#Env ⇒ Object
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 |
#Id ⇒ Object
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 |
#MsType ⇒ Object
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 |
#Partitions ⇒ Object
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 |
#ProjectId ⇒ Object
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 |
#Properties ⇒ Object
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 |
#SchemaName ⇒ Object
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 |
#SinkDatabase ⇒ Object
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 |
#SinkSchemaName ⇒ Object
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 |
#SinkTableName ⇒ Object
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 |
#SinkType ⇒ Object
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 |
#SourceDatabase ⇒ Object
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 |
#SourceFieldInfoList ⇒ Object
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 |
#TableBaseInfo ⇒ Object
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 |
#TableComment ⇒ Object
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 |
#TableMode ⇒ Object
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 |
#TableName ⇒ Object
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 |
#TableVersion ⇒ Object
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 |
#TargetDatasourceId ⇒ Object
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 |
#TaskType ⇒ Object
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 |
#UpsertFlag ⇒ Object
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 |
#UpsertKeys ⇒ Object
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 |
#WriteMode ⇒ Object
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 |