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.
20800 20801 20802 20803 20804 20805 20806 20807 20808 20809 20810 20811 20812 20813 20814 20815 20816 20817 20818 20819 20820 20821 20822 20823 20824 20825 20826 20827 20828 20829 |
# File 'lib/v20210820/models.rb', line 20800 def initialize(projectid=nil, sinkdatabase=nil, id=nil, mstype=nil, datasourceid=nil, sourcedatabase=nil, tablename=nil, sinktype=nil, schemaname=nil, sourcefieldinfolist=nil, partitions=nil, properties=nil, tablemode=nil, tableversion=nil, upsertflag=nil, tablecomment=nil, adddatafiles=nil, addequalitydeletes=nil, addpositiondeletes=nil, adddeletefiles=nil, targetdatasourceid=nil, upsertkeys=nil, tablebaseinfo=nil, sinkschemaname=nil, env=nil, writemode=nil, tasktype=nil, sinktablename=nil) @ProjectId = projectid @SinkDatabase = sinkdatabase @Id = id @MsType = mstype @DatasourceId = datasourceid @SourceDatabase = sourcedatabase @TableName = tablename @SinkType = sinktype @SchemaName = schemaname @SourceFieldInfoList = sourcefieldinfolist @Partitions = partitions @Properties = properties @TableMode = tablemode @TableVersion = tableversion @UpsertFlag = upsertflag @TableComment = tablecomment @AddDataFiles = adddatafiles @AddEqualityDeletes = addequalitydeletes @AddPositionDeletes = addpositiondeletes @AddDeleteFiles = adddeletefiles @TargetDatasourceId = targetdatasourceid @UpsertKeys = upsertkeys @TableBaseInfo = tablebaseinfo @SinkSchemaName = sinkschemaname @Env = env @WriteMode = writemode @TaskType = tasktype @SinkTableName = sinktablename end |
Instance Attribute Details
#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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 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名称
20798 20799 20800 |
# File 'lib/v20210820/models.rb', line 20798 def WriteMode @WriteMode end |
Instance Method Details
#deserialize(params) ⇒ Object
20831 20832 20833 20834 20835 20836 20837 20838 20839 20840 20841 20842 20843 20844 20845 20846 20847 20848 20849 20850 20851 20852 20853 20854 20855 20856 20857 20858 20859 20860 20861 20862 20863 20864 20865 20866 20867 20868 20869 20870 20871 20872 20873 20874 20875 20876 20877 20878 20879 20880 20881 20882 20883 20884 |
# File 'lib/v20210820/models.rb', line 20831 def deserialize(params) @ProjectId = params['ProjectId'] @SinkDatabase = params['SinkDatabase'] @Id = params['Id'] @MsType = params['MsType'] @DatasourceId = params['DatasourceId'] @SourceDatabase = params['SourceDatabase'] @TableName = params['TableName'] @SinkType = params['SinkType'] @SchemaName = params['SchemaName'] unless params['SourceFieldInfoList'].nil? @SourceFieldInfoList = [] params['SourceFieldInfoList'].each do |i| sourcefieldinfo_tmp = SourceFieldInfo.new sourcefieldinfo_tmp.deserialize(i) @SourceFieldInfoList << sourcefieldinfo_tmp end end unless params['Partitions'].nil? @Partitions = [] params['Partitions'].each do |i| partition_tmp = Partition.new partition_tmp.deserialize(i) @Partitions << partition_tmp end end unless params['Properties'].nil? @Properties = [] params['Properties'].each do |i| property_tmp = Property.new property_tmp.deserialize(i) @Properties << property_tmp end end @TableMode = params['TableMode'] @TableVersion = params['TableVersion'] @UpsertFlag = params['UpsertFlag'] @TableComment = params['TableComment'] @AddDataFiles = params['AddDataFiles'] @AddEqualityDeletes = params['AddEqualityDeletes'] @AddPositionDeletes = params['AddPositionDeletes'] @AddDeleteFiles = params['AddDeleteFiles'] @TargetDatasourceId = params['TargetDatasourceId'] @UpsertKeys = params['UpsertKeys'] unless params['TableBaseInfo'].nil? @TableBaseInfo = TableBaseInfo.new @TableBaseInfo.deserialize(params['TableBaseInfo']) end @SinkSchemaName = params['SinkSchemaName'] @Env = params['Env'] @WriteMode = params['WriteMode'] @TaskType = params['TaskType'] @SinkTableName = params['SinkTableName'] end |