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.
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
#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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
20664 20665 20666 |
# File 'lib/v20210820/models.rb', line 20664 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名称
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 |