# frozen_string_literal: true
# Copyright (c) 2017-2018 THL A29 Limited, a Tencent company. All Rights Reserved.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
module TencentCloud
module Dlc
module V20210125
# AddDMSPartitions请求参数结构体
class AddDMSPartitionsRequest < TencentCloud::Common::AbstractModel
# @param Partitions: 分区
# @type Partitions: Array
attr_accessor :Partitions
def initialize(partitions=nil)
@Partitions = partitions
end
def deserialize(params)
unless params['Partitions'].nil?
@Partitions = []
params['Partitions'].each do |i|
dmspartition_tmp = DMSPartition.new
dmspartition_tmp.deserialize(i)
@Partitions << dmspartition_tmp
end
end
end
end
# AddDMSPartitions返回参数结构体
class AddDMSPartitionsResponse < TencentCloud::Common::AbstractModel
# @param Total: 成功数量
# @type Total: Integer
# @param Partitions: 分区值
# @type Partitions: Array
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :Total, :Partitions, :RequestId
def initialize(total=nil, partitions=nil, requestid=nil)
@Total = total
@Partitions = partitions
@RequestId = requestid
end
def deserialize(params)
@Total = params['Total']
unless params['Partitions'].nil?
@Partitions = []
params['Partitions'].each do |i|
dmspartition_tmp = DMSPartition.new
dmspartition_tmp.deserialize(i)
@Partitions << dmspartition_tmp
end
end
@RequestId = params['RequestId']
end
end
# AddUsersToWorkGroup请求参数结构体
class AddUsersToWorkGroupRequest < TencentCloud::Common::AbstractModel
# @param AddInfo: 要操作的工作组和用户信息
# @type AddInfo: :class:`Tencentcloud::Dlc.v20210125.models.UserIdSetOfWorkGroupId`
attr_accessor :AddInfo
def initialize(addinfo=nil)
@AddInfo = addinfo
end
def deserialize(params)
unless params['AddInfo'].nil?
@AddInfo = UserIdSetOfWorkGroupId.new
@AddInfo.deserialize(params['AddInfo'])
end
end
end
# AddUsersToWorkGroup返回参数结构体
class AddUsersToWorkGroupResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# AlterDMSDatabase请求参数结构体
class AlterDMSDatabaseRequest < TencentCloud::Common::AbstractModel
def initialize()
end
def deserialize(params)
end
end
# AlterDMSDatabase返回参数结构体
class AlterDMSDatabaseResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# AlterDMSPartition请求参数结构体
class AlterDMSPartitionRequest < TencentCloud::Common::AbstractModel
# @param CurrentDbName: 当前名称，变更前db名称
# @type CurrentDbName: String
# @param CurrentTableName: 当前名称，变更前table名称
# @type CurrentTableName: String
# @param CurrentValues: 当前名称，变更前Part名称
# @type CurrentValues: String
# @param Partition: 分区
# @type Partition: :class:`Tencentcloud::Dlc.v20210125.models.DMSPartition`
attr_accessor :CurrentDbName, :CurrentTableName, :CurrentValues, :Partition
def initialize(currentdbname=nil, currenttablename=nil, currentvalues=nil, partition=nil)
@CurrentDbName = currentdbname
@CurrentTableName = currenttablename
@CurrentValues = currentvalues
@Partition = partition
end
def deserialize(params)
@CurrentDbName = params['CurrentDbName']
@CurrentTableName = params['CurrentTableName']
@CurrentValues = params['CurrentValues']
unless params['Partition'].nil?
@Partition = DMSPartition.new
@Partition.deserialize(params['Partition'])
end
end
end
# AlterDMSPartition返回参数结构体
class AlterDMSPartitionResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# AlterDMSTable请求参数结构体
class AlterDMSTableRequest < TencentCloud::Common::AbstractModel
# @param CurrentName: 当前名称
# @type CurrentName: String
# @param CurrentDbName: 当前数据库名称
# @type CurrentDbName: String
# @param Asset: 基础对象
# @type Asset: :class:`Tencentcloud::Dlc.v20210125.models.Asset`
# @param Type: 表类型
# @type Type: String
# @param DbName: 数据库名称
# @type DbName: String
# @param StorageSize: 存储大小
# @type StorageSize: Integer
# @param RecordCount: 记录数量
# @type RecordCount: Integer
# @param LifeTime: 生命周期
# @type LifeTime: Integer
# @param DataUpdateTime: 数据更新时间
# @type DataUpdateTime: String
# @param StructUpdateTime: 结构更新时间
# @type StructUpdateTime: String
# @param LastAccessTime: 最后访问时间
# @type LastAccessTime: String
# @param Sds: 存储对象
# @type Sds: :class:`Tencentcloud::Dlc.v20210125.models.DMSSds`
# @param Columns: 列
# @type Columns: Array
# @param PartitionKeys: 分区键值
# @type PartitionKeys: Array
# @param ViewOriginalText: 视图文本
# @type ViewOriginalText: String
# @param ViewExpandedText: 视图文本
# @type ViewExpandedText: String
# @param Partitions: 分区
# @type Partitions: Array
attr_accessor :CurrentName, :CurrentDbName, :Asset, :Type, :DbName, :StorageSize, :RecordCount, :LifeTime, :DataUpdateTime, :StructUpdateTime, :LastAccessTime, :Sds, :Columns, :PartitionKeys, :ViewOriginalText, :ViewExpandedText, :Partitions
def initialize(currentname=nil, currentdbname=nil, asset=nil, type=nil, dbname=nil, storagesize=nil, recordcount=nil, lifetime=nil, dataupdatetime=nil, structupdatetime=nil, lastaccesstime=nil, sds=nil, columns=nil, partitionkeys=nil, vieworiginaltext=nil, viewexpandedtext=nil, partitions=nil)
@CurrentName = currentname
@CurrentDbName = currentdbname
@Asset = asset
@Type = type
@DbName = dbname
@StorageSize = storagesize
@RecordCount = recordcount
@LifeTime = lifetime
@DataUpdateTime = dataupdatetime
@StructUpdateTime = structupdatetime
@LastAccessTime = lastaccesstime
@Sds = sds
@Columns = columns
@PartitionKeys = partitionkeys
@ViewOriginalText = vieworiginaltext
@ViewExpandedText = viewexpandedtext
@Partitions = partitions
end
def deserialize(params)
@CurrentName = params['CurrentName']
@CurrentDbName = params['CurrentDbName']
unless params['Asset'].nil?
@Asset = Asset.new
@Asset.deserialize(params['Asset'])
end
@Type = params['Type']
@DbName = params['DbName']
@StorageSize = params['StorageSize']
@RecordCount = params['RecordCount']
@LifeTime = params['LifeTime']
@DataUpdateTime = params['DataUpdateTime']
@StructUpdateTime = params['StructUpdateTime']
@LastAccessTime = params['LastAccessTime']
unless params['Sds'].nil?
@Sds = DMSSds.new
@Sds.deserialize(params['Sds'])
end
unless params['Columns'].nil?
@Columns = []
params['Columns'].each do |i|
dmscolumn_tmp = DMSColumn.new
dmscolumn_tmp.deserialize(i)
@Columns << dmscolumn_tmp
end
end
unless params['PartitionKeys'].nil?
@PartitionKeys = []
params['PartitionKeys'].each do |i|
dmscolumn_tmp = DMSColumn.new
dmscolumn_tmp.deserialize(i)
@PartitionKeys << dmscolumn_tmp
end
end
@ViewOriginalText = params['ViewOriginalText']
@ViewExpandedText = params['ViewExpandedText']
unless params['Partitions'].nil?
@Partitions = []
params['Partitions'].each do |i|
dmspartition_tmp = DMSPartition.new
dmspartition_tmp.deserialize(i)
@Partitions << dmspartition_tmp
end
end
end
end
# AlterDMSTable返回参数结构体
class AlterDMSTableResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# 元数据基本对象
class Asset < TencentCloud::Common::AbstractModel
def initialize()
end
def deserialize(params)
end
end
# AttachUserPolicy请求参数结构体
class AttachUserPolicyRequest < TencentCloud::Common::AbstractModel
# @param UserId: 用户Id，和子用户uin相同，需要先使用CreateUser接口创建用户。可以使用DescribeUsers接口查看。
# @type UserId: String
# @param PolicySet: 鉴权策略集合
# @type PolicySet: Array
attr_accessor :UserId, :PolicySet
def initialize(userid=nil, policyset=nil)
@UserId = userid
@PolicySet = policyset
end
def deserialize(params)
@UserId = params['UserId']
unless params['PolicySet'].nil?
@PolicySet = []
params['PolicySet'].each do |i|
policy_tmp = Policy.new
policy_tmp.deserialize(i)
@PolicySet << policy_tmp
end
end
end
end
# AttachUserPolicy返回参数结构体
class AttachUserPolicyResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# AttachWorkGroupPolicy请求参数结构体
class AttachWorkGroupPolicyRequest < TencentCloud::Common::AbstractModel
# @param WorkGroupId: 工作组Id
# @type WorkGroupId: Integer
# @param PolicySet: 要绑定的策略集合
# @type PolicySet: Array
attr_accessor :WorkGroupId, :PolicySet
def initialize(workgroupid=nil, policyset=nil)
@WorkGroupId = workgroupid
@PolicySet = policyset
end
def deserialize(params)
@WorkGroupId = params['WorkGroupId']
unless params['PolicySet'].nil?
@PolicySet = []
params['PolicySet'].each do |i|
policy_tmp = Policy.new
policy_tmp.deserialize(i)
@PolicySet << policy_tmp
end
end
end
end
# AttachWorkGroupPolicy返回参数结构体
class AttachWorkGroupPolicyResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# BindWorkGroupsToUser请求参数结构体
class BindWorkGroupsToUserRequest < TencentCloud::Common::AbstractModel
# @param AddInfo: 绑定的用户和工作组信息
# @type AddInfo: :class:`Tencentcloud::Dlc.v20210125.models.WorkGroupIdSetOfUserId`
attr_accessor :AddInfo
def initialize(addinfo=nil)
@AddInfo = addinfo
end
def deserialize(params)
unless params['AddInfo'].nil?
@AddInfo = WorkGroupIdSetOfUserId.new
@AddInfo.deserialize(params['AddInfo'])
end
end
end
# BindWorkGroupsToUser返回参数结构体
class BindWorkGroupsToUserResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# CSV类型数据格式
class CSV < TencentCloud::Common::AbstractModel
# @param CodeCompress: 压缩格式，["Snappy", "Gzip", "None"选一]。
# @type CodeCompress: String
# @param CSVSerde: CSV序列化及反序列化数据结构。
# @type CSVSerde: :class:`Tencentcloud::Dlc.v20210125.models.CSVSerde`
# @param HeadLines: 标题行，默认为0。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type HeadLines: Integer
# @param Format: 格式，默认值为CSV
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Format: String
attr_accessor :CodeCompress, :CSVSerde, :HeadLines, :Format
def initialize(codecompress=nil, csvserde=nil, headlines=nil, format=nil)
@CodeCompress = codecompress
@CSVSerde = csvserde
@HeadLines = headlines
@Format = format
end
def deserialize(params)
@CodeCompress = params['CodeCompress']
unless params['CSVSerde'].nil?
@CSVSerde = CSVSerde.new
@CSVSerde.deserialize(params['CSVSerde'])
end
@HeadLines = params['HeadLines']
@Format = params['Format']
end
end
# CSV序列化及反序列化数据结构
class CSVSerde < TencentCloud::Common::AbstractModel
# @param Escape: CSV序列化转义符，默认为"\\"，最长8个字符，如 Escape: "/\"
# @type Escape: String
# @param Quote: CSV序列化字段域符，默认为"'"，最长8个字符, 如 Quote: "\""
# @type Quote: String
# @param Separator: CSV序列化分隔符，默认为"\t"，最长8个字符, 如 Separator: "\t"
# @type Separator: String
attr_accessor :Escape, :Quote, :Separator
def initialize(escape=nil, quote=nil, separator=nil)
@Escape = escape
@Quote = quote
@Separator = separator
end
def deserialize(params)
@Escape = params['Escape']
@Quote = params['Quote']
@Separator = params['Separator']
end
end
# CancelTask请求参数结构体
class CancelTaskRequest < TencentCloud::Common::AbstractModel
# @param TaskId: 任务Id，全局唯一
# @type TaskId: String
attr_accessor :TaskId
def initialize(taskid=nil)
@TaskId = taskid
end
def deserialize(params)
@TaskId = params['TaskId']
end
end
# CancelTask返回参数结构体
class CancelTaskResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# CheckLockMetaData请求参数结构体
class CheckLockMetaDataRequest < TencentCloud::Common::AbstractModel
# @param LockId: 锁ID
# @type LockId: Integer
# @param DatasourceConnectionName: 数据源名称
# @type DatasourceConnectionName: String
# @param TxnId: 事务ID
# @type TxnId: Integer
# @param ElapsedMs: 过期时间ms
# @type ElapsedMs: Integer
attr_accessor :LockId, :DatasourceConnectionName, :TxnId, :ElapsedMs
def initialize(lockid=nil, datasourceconnectionname=nil, txnid=nil, elapsedms=nil)
@LockId = lockid
@DatasourceConnectionName = datasourceconnectionname
@TxnId = txnid
@ElapsedMs = elapsedms
end
def deserialize(params)
@LockId = params['LockId']
@DatasourceConnectionName = params['DatasourceConnectionName']
@TxnId = params['TxnId']
@ElapsedMs = params['ElapsedMs']
end
end
# CheckLockMetaData返回参数结构体
class CheckLockMetaDataResponse < TencentCloud::Common::AbstractModel
# @param LockId: 锁ID
# @type LockId: Integer
# @param LockState: 锁状态：ACQUIRED、WAITING、ABORT、NOT_ACQUIRED
# @type LockState: String
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :LockId, :LockState, :RequestId
def initialize(lockid=nil, lockstate=nil, requestid=nil)
@LockId = lockid
@LockState = lockstate
@RequestId = requestid
end
def deserialize(params)
@LockId = params['LockId']
@LockState = params['LockState']
@RequestId = params['RequestId']
end
end
# 数据表列信息。
class Column < TencentCloud::Common::AbstractModel
# @param Name: 列名称，不区分大小写，最大支持25个字符。
# @type Name: String
# @param Type: 列类型，支持如下类型定义:
# string|tinyint|smallint|int|bigint|boolean|float|double|decimal|timestamp|date|binary|array<data_type>|map<primitive_type, data_type>|struct<col_name : data_type [COMMENT col_comment], ...>|uniontype<data_type, data_type, ...>。
# @type Type: String
# @param Comment: 对该类的注释。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Comment: String
# @param Precision: 表示整个 numeric 的长度
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Precision: Integer
# @param Scale: 表示小数部分的长度
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Scale: Integer
# @param Nullable: 是否为null
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Nullable: String
# @param Position: 字段位置，小的在前
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Position: Integer
# @param CreateTime: 字段创建时间
# 注意：此字段可能返回 null，表示取不到有效值。
# @type CreateTime: String
# @param ModifiedTime: 字段修改时间
# 注意：此字段可能返回 null，表示取不到有效值。
# @type ModifiedTime: String
# @param IsPartition: 是否为分区字段
# 注意：此字段可能返回 null，表示取不到有效值。
# @type IsPartition: Boolean
attr_accessor :Name, :Type, :Comment, :Precision, :Scale, :Nullable, :Position, :CreateTime, :ModifiedTime, :IsPartition
def initialize(name=nil, type=nil, comment=nil, precision=nil, scale=nil, nullable=nil, position=nil, createtime=nil, modifiedtime=nil, ispartition=nil)
@Name = name
@Type = type
@Comment = comment
@Precision = precision
@Scale = scale
@Nullable = nullable
@Position = position
@CreateTime = createtime
@ModifiedTime = modifiedtime
@IsPartition = ispartition
end
def deserialize(params)
@Name = params['Name']
@Type = params['Type']
@Comment = params['Comment']
@Precision = params['Precision']
@Scale = params['Scale']
@Nullable = params['Nullable']
@Position = params['Position']
@CreateTime = params['CreateTime']
@ModifiedTime = params['ModifiedTime']
@IsPartition = params['IsPartition']
end
end
# CreateDMSDatabase请求参数结构体
class CreateDMSDatabaseRequest < TencentCloud::Common::AbstractModel
# @param Name: 数据库名称
# @type Name: String
attr_accessor :Name
def initialize(name=nil)
@Name = name
end
def deserialize(params)
@Name = params['Name']
end
end
# CreateDMSDatabase返回参数结构体
class CreateDMSDatabaseResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# CreateDMSTable请求参数结构体
class CreateDMSTableRequest < TencentCloud::Common::AbstractModel
# @param Asset: 基础对象
# @type Asset: :class:`Tencentcloud::Dlc.v20210125.models.Asset`
# @param Type: 表类型
# @type Type: String
# @param DbName: 数据库名称
# @type DbName: String
# @param StorageSize: 存储大小
# @type StorageSize: Integer
# @param RecordCount: 记录数量
# @type RecordCount: Integer
# @param LifeTime: 生命周期
# @type LifeTime: Integer
# @param DataUpdateTime: 数据更新时间
# @type DataUpdateTime: String
# @param StructUpdateTime: 结构更新时间
# @type StructUpdateTime: String
# @param LastAccessTime: 最后访问时间
# @type LastAccessTime: String
# @param Sds: 存储对象
# @type Sds: :class:`Tencentcloud::Dlc.v20210125.models.DMSSds`
# @param Columns: 列
# @type Columns: Array
# @param PartitionKeys: 分区键值
# @type PartitionKeys: Array
# @param ViewOriginalText: 视图文本
# @type ViewOriginalText: String
# @param ViewExpandedText: 视图文本
# @type ViewExpandedText: String
# @param Partitions: 分区
# @type Partitions: Array
# @param Name: 表名称
# @type Name: String
attr_accessor :Asset, :Type, :DbName, :StorageSize, :RecordCount, :LifeTime, :DataUpdateTime, :StructUpdateTime, :LastAccessTime, :Sds, :Columns, :PartitionKeys, :ViewOriginalText, :ViewExpandedText, :Partitions, :Name
def initialize(asset=nil, type=nil, dbname=nil, storagesize=nil, recordcount=nil, lifetime=nil, dataupdatetime=nil, structupdatetime=nil, lastaccesstime=nil, sds=nil, columns=nil, partitionkeys=nil, vieworiginaltext=nil, viewexpandedtext=nil, partitions=nil, name=nil)
@Asset = asset
@Type = type
@DbName = dbname
@StorageSize = storagesize
@RecordCount = recordcount
@LifeTime = lifetime
@DataUpdateTime = dataupdatetime
@StructUpdateTime = structupdatetime
@LastAccessTime = lastaccesstime
@Sds = sds
@Columns = columns
@PartitionKeys = partitionkeys
@ViewOriginalText = vieworiginaltext
@ViewExpandedText = viewexpandedtext
@Partitions = partitions
@Name = name
end
def deserialize(params)
unless params['Asset'].nil?
@Asset = Asset.new
@Asset.deserialize(params['Asset'])
end
@Type = params['Type']
@DbName = params['DbName']
@StorageSize = params['StorageSize']
@RecordCount = params['RecordCount']
@LifeTime = params['LifeTime']
@DataUpdateTime = params['DataUpdateTime']
@StructUpdateTime = params['StructUpdateTime']
@LastAccessTime = params['LastAccessTime']
unless params['Sds'].nil?
@Sds = DMSSds.new
@Sds.deserialize(params['Sds'])
end
unless params['Columns'].nil?
@Columns = []
params['Columns'].each do |i|
dmscolumn_tmp = DMSColumn.new
dmscolumn_tmp.deserialize(i)
@Columns << dmscolumn_tmp
end
end
unless params['PartitionKeys'].nil?
@PartitionKeys = []
params['PartitionKeys'].each do |i|
dmscolumn_tmp = DMSColumn.new
dmscolumn_tmp.deserialize(i)
@PartitionKeys << dmscolumn_tmp
end
end
@ViewOriginalText = params['ViewOriginalText']
@ViewExpandedText = params['ViewExpandedText']
unless params['Partitions'].nil?
@Partitions = []
params['Partitions'].each do |i|
dmspartition_tmp = DMSPartition.new
dmspartition_tmp.deserialize(i)
@Partitions << dmspartition_tmp
end
end
@Name = params['Name']
end
end
# CreateDMSTable返回参数结构体
class CreateDMSTableResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# CreateDatabase请求参数结构体
class CreateDatabaseRequest < TencentCloud::Common::AbstractModel
# @param DatabaseInfo: 数据库基础信息
# @type DatabaseInfo: :class:`Tencentcloud::Dlc.v20210125.models.DatabaseInfo`
# @param DatasourceConnectionName: 数据源名称，默认为DataLakeCatalog
# @type DatasourceConnectionName: String
attr_accessor :DatabaseInfo, :DatasourceConnectionName
def initialize(databaseinfo=nil, datasourceconnectionname=nil)
@DatabaseInfo = databaseinfo
@DatasourceConnectionName = datasourceconnectionname
end
def deserialize(params)
unless params['DatabaseInfo'].nil?
@DatabaseInfo = DatabaseInfo.new
@DatabaseInfo.deserialize(params['DatabaseInfo'])
end
@DatasourceConnectionName = params['DatasourceConnectionName']
end
end
# CreateDatabase返回参数结构体
class CreateDatabaseResponse < TencentCloud::Common::AbstractModel
# @param Execution: 生成的建库执行语句对象。
# @type Execution: :class:`Tencentcloud::Dlc.v20210125.models.Execution`
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :Execution, :RequestId
def initialize(execution=nil, requestid=nil)
@Execution = execution
@RequestId = requestid
end
def deserialize(params)
unless params['Execution'].nil?
@Execution = Execution.new
@Execution.deserialize(params['Execution'])
end
@RequestId = params['RequestId']
end
end
# CreateExportTask请求参数结构体
class CreateExportTaskRequest < TencentCloud::Common::AbstractModel
# @param InputType: 数据来源，lakefsStorage、taskResult
# @type InputType: String
# @param InputConf: 导出任务输入配置
# @type InputConf: Array
# @param OutputConf: 导出任务输出配置
# @type OutputConf: Array
# @param OutputType: 目标数据源的类型，目前支持导出到cos
# @type OutputType: String
attr_accessor :InputType, :InputConf, :OutputConf, :OutputType
def initialize(inputtype=nil, inputconf=nil, outputconf=nil, outputtype=nil)
@InputType = inputtype
@InputConf = inputconf
@OutputConf = outputconf
@OutputType = outputtype
end
def deserialize(params)
@InputType = params['InputType']
unless params['InputConf'].nil?
@InputConf = []
params['InputConf'].each do |i|
kvpair_tmp = KVPair.new
kvpair_tmp.deserialize(i)
@InputConf << kvpair_tmp
end
end
unless params['OutputConf'].nil?
@OutputConf = []
params['OutputConf'].each do |i|
kvpair_tmp = KVPair.new
kvpair_tmp.deserialize(i)
@OutputConf << kvpair_tmp
end
end
@OutputType = params['OutputType']
end
end
# CreateExportTask返回参数结构体
class CreateExportTaskResponse < TencentCloud::Common::AbstractModel
# @param TaskId: 任务id
# @type TaskId: String
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :TaskId, :RequestId
def initialize(taskid=nil, requestid=nil)
@TaskId = taskid
@RequestId = requestid
end
def deserialize(params)
@TaskId = params['TaskId']
@RequestId = params['RequestId']
end
end
# CreateImportTask请求参数结构体
class CreateImportTaskRequest < TencentCloud::Common::AbstractModel
# @param InputType: 数据来源，cos
# @type InputType: String
# @param InputConf: 输入配置
# @type InputConf: Array
# @param OutputConf: 输出配置
# @type OutputConf: Array
# @param OutputType: 目标数据源的类型，目前支持导入到托管存储，即lakefsStorage
# @type OutputType: String
attr_accessor :InputType, :InputConf, :OutputConf, :OutputType
def initialize(inputtype=nil, inputconf=nil, outputconf=nil, outputtype=nil)
@InputType = inputtype
@InputConf = inputconf
@OutputConf = outputconf
@OutputType = outputtype
end
def deserialize(params)
@InputType = params['InputType']
unless params['InputConf'].nil?
@InputConf = []
params['InputConf'].each do |i|
kvpair_tmp = KVPair.new
kvpair_tmp.deserialize(i)
@InputConf << kvpair_tmp
end
end
unless params['OutputConf'].nil?
@OutputConf = []
params['OutputConf'].each do |i|
kvpair_tmp = KVPair.new
kvpair_tmp.deserialize(i)
@OutputConf << kvpair_tmp
end
end
@OutputType = params['OutputType']
end
end
# CreateImportTask返回参数结构体
class CreateImportTaskResponse < TencentCloud::Common::AbstractModel
# @param TaskId: 任务id
# @type TaskId: String
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :TaskId, :RequestId
def initialize(taskid=nil, requestid=nil)
@TaskId = taskid
@RequestId = requestid
end
def deserialize(params)
@TaskId = params['TaskId']
@RequestId = params['RequestId']
end
end
# CreateScript请求参数结构体
class CreateScriptRequest < TencentCloud::Common::AbstractModel
# @param ScriptName: 脚本名称，最大不能超过255个字符。
# @type ScriptName: String
# @param SQLStatement: base64编码后的sql语句
# @type SQLStatement: String
# @param ScriptDesc: 脚本描述， 不能超过50个字符
# @type ScriptDesc: String
# @param DatabaseName: 数据库名称
# @type DatabaseName: String
attr_accessor :ScriptName, :SQLStatement, :ScriptDesc, :DatabaseName
def initialize(scriptname=nil, sqlstatement=nil, scriptdesc=nil, databasename=nil)
@ScriptName = scriptname
@SQLStatement = sqlstatement
@ScriptDesc = scriptdesc
@DatabaseName = databasename
end
def deserialize(params)
@ScriptName = params['ScriptName']
@SQLStatement = params['SQLStatement']
@ScriptDesc = params['ScriptDesc']
@DatabaseName = params['DatabaseName']
end
end
# CreateScript返回参数结构体
class CreateScriptResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# CreateSparkApp请求参数结构体
class CreateSparkAppRequest < TencentCloud::Common::AbstractModel
# @param AppName: spark应用名
# @type AppName: String
# @param AppType: 1代表spark jar应用，2代表spark streaming应用
# @type AppType: Integer
# @param DataEngine: 执行spark作业的数据引擎
# @type DataEngine: String
# @param AppFile: spark应用的执行入口
# @type AppFile: String
# @param RoleArn: 执行spark作业的角色ID
# @type RoleArn: Integer
# @param AppDriverSize: spark作业driver资源规格大小, 可取small,medium,large,xlarge
# @type AppDriverSize: String
# @param AppExecutorSize: spark作业executor资源规格大小, 可取small,medium,large,xlarge
# @type AppExecutorSize: String
# @param AppExecutorNums: spark作业executor个数
# @type AppExecutorNums: Integer
# @param Eni: 该字段已下线，请使用字段Datasource
# @type Eni: String
# @param IsLocal: 是否本地上传，可去cos,lakefs
# @type IsLocal: String
# @param MainClass: spark jar作业时的主类
# @type MainClass: String
# @param AppConf: spark配置，以换行符分隔
# @type AppConf: String
# @param IsLocalJars: 是否本地上传，包含cos,lakefs
# @type IsLocalJars: String
# @param AppJars: spark jar作业依赖jars，以逗号分隔
# @type AppJars: String
# @param IsLocalFiles: 是否本地上传，包含cos,lakefs
# @type IsLocalFiles: String
# @param AppFiles: spark作业依赖资源，以逗号分隔
# @type AppFiles: String
# @param CmdArgs: spark作业命令行参数
# @type CmdArgs: String
# @param MaxRetries: 只对spark流任务生效
# @type MaxRetries: Integer
# @param DataSource: 数据源名
# @type DataSource: String
# @param IsLocalPythonFiles: pyspark：依赖上传方式，1、cos；2、lakefs（控制台使用，该方式不支持直接接口调用）
# @type IsLocalPythonFiles: String
# @param AppPythonFiles: pyspark：python依赖, 除py文件外，还支持zip/egg等归档格式，多文件以逗号分隔
# @type AppPythonFiles: String
attr_accessor :AppName, :AppType, :DataEngine, :AppFile, :RoleArn, :AppDriverSize, :AppExecutorSize, :AppExecutorNums, :Eni, :IsLocal, :MainClass, :AppConf, :IsLocalJars, :AppJars, :IsLocalFiles, :AppFiles, :CmdArgs, :MaxRetries, :DataSource, :IsLocalPythonFiles, :AppPythonFiles
def initialize(appname=nil, apptype=nil, dataengine=nil, appfile=nil, rolearn=nil, appdriversize=nil, appexecutorsize=nil, appexecutornums=nil, eni=nil, islocal=nil, mainclass=nil, appconf=nil, islocaljars=nil, appjars=nil, islocalfiles=nil, appfiles=nil, cmdargs=nil, maxretries=nil, datasource=nil, islocalpythonfiles=nil, apppythonfiles=nil)
@AppName = appname
@AppType = apptype
@DataEngine = dataengine
@AppFile = appfile
@RoleArn = rolearn
@AppDriverSize = appdriversize
@AppExecutorSize = appexecutorsize
@AppExecutorNums = appexecutornums
@Eni = eni
@IsLocal = islocal
@MainClass = mainclass
@AppConf = appconf
@IsLocalJars = islocaljars
@AppJars = appjars
@IsLocalFiles = islocalfiles
@AppFiles = appfiles
@CmdArgs = cmdargs
@MaxRetries = maxretries
@DataSource = datasource
@IsLocalPythonFiles = islocalpythonfiles
@AppPythonFiles = apppythonfiles
end
def deserialize(params)
@AppName = params['AppName']
@AppType = params['AppType']
@DataEngine = params['DataEngine']
@AppFile = params['AppFile']
@RoleArn = params['RoleArn']
@AppDriverSize = params['AppDriverSize']
@AppExecutorSize = params['AppExecutorSize']
@AppExecutorNums = params['AppExecutorNums']
@Eni = params['Eni']
@IsLocal = params['IsLocal']
@MainClass = params['MainClass']
@AppConf = params['AppConf']
@IsLocalJars = params['IsLocalJars']
@AppJars = params['AppJars']
@IsLocalFiles = params['IsLocalFiles']
@AppFiles = params['AppFiles']
@CmdArgs = params['CmdArgs']
@MaxRetries = params['MaxRetries']
@DataSource = params['DataSource']
@IsLocalPythonFiles = params['IsLocalPythonFiles']
@AppPythonFiles = params['AppPythonFiles']
end
end
# CreateSparkApp返回参数结构体
class CreateSparkAppResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# CreateSparkAppTask请求参数结构体
class CreateSparkAppTaskRequest < TencentCloud::Common::AbstractModel
# @param JobName: spark作业名
# @type JobName: String
# @param CmdArgs: spark作业的命令行参数，以空格分隔；一般用于周期性调用使用
# @type CmdArgs: String
attr_accessor :JobName, :CmdArgs
def initialize(jobname=nil, cmdargs=nil)
@JobName = jobname
@CmdArgs = cmdargs
end
def deserialize(params)
@JobName = params['JobName']
@CmdArgs = params['CmdArgs']
end
end
# CreateSparkAppTask返回参数结构体
class CreateSparkAppTaskResponse < TencentCloud::Common::AbstractModel
# @param BatchId: 批Id
# @type BatchId: String
# @param TaskId: 任务Id
# @type TaskId: String
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :BatchId, :TaskId, :RequestId
def initialize(batchid=nil, taskid=nil, requestid=nil)
@BatchId = batchid
@TaskId = taskid
@RequestId = requestid
end
def deserialize(params)
@BatchId = params['BatchId']
@TaskId = params['TaskId']
@RequestId = params['RequestId']
end
end
# CreateStoreLocation请求参数结构体
class CreateStoreLocationRequest < TencentCloud::Common::AbstractModel
# @param StoreLocation: 计算结果存储cos路径，如：cosn://bucketname/
# @type StoreLocation: String
attr_accessor :StoreLocation
def initialize(storelocation=nil)
@StoreLocation = storelocation
end
def deserialize(params)
@StoreLocation = params['StoreLocation']
end
end
# CreateStoreLocation返回参数结构体
class CreateStoreLocationResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# CreateTable请求参数结构体
class CreateTableRequest < TencentCloud::Common::AbstractModel
# @param TableInfo: 数据表配置信息
# @type TableInfo: :class:`Tencentcloud::Dlc.v20210125.models.TableInfo`
attr_accessor :TableInfo
def initialize(tableinfo=nil)
@TableInfo = tableinfo
end
def deserialize(params)
unless params['TableInfo'].nil?
@TableInfo = TableInfo.new
@TableInfo.deserialize(params['TableInfo'])
end
end
end
# CreateTable返回参数结构体
class CreateTableResponse < TencentCloud::Common::AbstractModel
# @param Execution: 生成的建表执行语句对象。
# @type Execution: :class:`Tencentcloud::Dlc.v20210125.models.Execution`
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :Execution, :RequestId
def initialize(execution=nil, requestid=nil)
@Execution = execution
@RequestId = requestid
end
def deserialize(params)
unless params['Execution'].nil?
@Execution = Execution.new
@Execution.deserialize(params['Execution'])
end
@RequestId = params['RequestId']
end
end
# CreateTask请求参数结构体
class CreateTaskRequest < TencentCloud::Common::AbstractModel
# @param Task: 计算任务，该参数中包含任务类型及其相关配置信息
# @type Task: :class:`Tencentcloud::Dlc.v20210125.models.Task`
# @param DatabaseName: 数据库名称。如果SQL语句中有数据库名称，优先使用SQL语句中的数据库，否则使用该参数指定的数据库（注：当提交建库sql时，该字段传空字符串）。
# @type DatabaseName: String
# @param DatasourceConnectionName: 默认数据源名称。
# @type DatasourceConnectionName: String
# @param DataEngineName: 数据引擎名称，不填提交到默认集群
# @type DataEngineName: String
attr_accessor :Task, :DatabaseName, :DatasourceConnectionName, :DataEngineName
def initialize(task=nil, databasename=nil, datasourceconnectionname=nil, dataenginename=nil)
@Task = task
@DatabaseName = databasename
@DatasourceConnectionName = datasourceconnectionname
@DataEngineName = dataenginename
end
def deserialize(params)
unless params['Task'].nil?
@Task = Task.new
@Task.deserialize(params['Task'])
end
@DatabaseName = params['DatabaseName']
@DatasourceConnectionName = params['DatasourceConnectionName']
@DataEngineName = params['DataEngineName']
end
end
# CreateTask返回参数结构体
class CreateTaskResponse < TencentCloud::Common::AbstractModel
# @param TaskId: 任务ID
# 注意：此字段可能返回 null，表示取不到有效值。
# @type TaskId: String
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :TaskId, :RequestId
def initialize(taskid=nil, requestid=nil)
@TaskId = taskid
@RequestId = requestid
end
def deserialize(params)
@TaskId = params['TaskId']
@RequestId = params['RequestId']
end
end
# CreateTasksInOrder请求参数结构体
class CreateTasksInOrderRequest < TencentCloud::Common::AbstractModel
# @param DatabaseName: 数据库名称。如果SQL语句中有数据库名称，优先使用SQL语句中的数据库，否则使用该参数指定的数据库。
# @type DatabaseName: String
# @param Tasks: SQL任务信息
# @type Tasks: :class:`Tencentcloud::Dlc.v20210125.models.TasksInfo`
# @param DatasourceConnectionName: 数据源名称，默认为COSDataCatalog
# @type DatasourceConnectionName: String
attr_accessor :DatabaseName, :Tasks, :DatasourceConnectionName
def initialize(databasename=nil, tasks=nil, datasourceconnectionname=nil)
@DatabaseName = databasename
@Tasks = tasks
@DatasourceConnectionName = datasourceconnectionname
end
def deserialize(params)
@DatabaseName = params['DatabaseName']
unless params['Tasks'].nil?
@Tasks = TasksInfo.new
@Tasks.deserialize(params['Tasks'])
end
@DatasourceConnectionName = params['DatasourceConnectionName']
end
end
# CreateTasksInOrder返回参数结构体
class CreateTasksInOrderResponse < TencentCloud::Common::AbstractModel
# @param BatchId: 本批次提交的任务的批次Id
# @type BatchId: String
# @param TaskIdSet: 任务Id集合，按照执行顺序排列
# @type TaskIdSet: Array
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :BatchId, :TaskIdSet, :RequestId
def initialize(batchid=nil, taskidset=nil, requestid=nil)
@BatchId = batchid
@TaskIdSet = taskidset
@RequestId = requestid
end
def deserialize(params)
@BatchId = params['BatchId']
@TaskIdSet = params['TaskIdSet']
@RequestId = params['RequestId']
end
end
# CreateTasks请求参数结构体
class CreateTasksRequest < TencentCloud::Common::AbstractModel
# @param DatabaseName: 数据库名称。如果SQL语句中有数据库名称，优先使用SQL语句中的数据库，否则使用该参数指定的数据库（注：当提交建库sql时，该字段传空字符串）。
# @type DatabaseName: String
# @param Tasks: SQL任务信息
# @type Tasks: :class:`Tencentcloud::Dlc.v20210125.models.TasksInfo`
# @param DatasourceConnectionName: 数据源名称，默认为DataLakeCatalog
# @type DatasourceConnectionName: String
# @param DataEngineName: 计算引擎名称，不填任务提交到默认集群
# @type DataEngineName: String
attr_accessor :DatabaseName, :Tasks, :DatasourceConnectionName, :DataEngineName
def initialize(databasename=nil, tasks=nil, datasourceconnectionname=nil, dataenginename=nil)
@DatabaseName = databasename
@Tasks = tasks
@DatasourceConnectionName = datasourceconnectionname
@DataEngineName = dataenginename
end
def deserialize(params)
@DatabaseName = params['DatabaseName']
unless params['Tasks'].nil?
@Tasks = TasksInfo.new
@Tasks.deserialize(params['Tasks'])
end
@DatasourceConnectionName = params['DatasourceConnectionName']
@DataEngineName = params['DataEngineName']
end
end
# CreateTasks返回参数结构体
class CreateTasksResponse < TencentCloud::Common::AbstractModel
# @param BatchId: 本批次提交的任务的批次Id
# @type BatchId: String
# @param TaskIdSet: 任务Id集合，按照执行顺序排列
# @type TaskIdSet: Array
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :BatchId, :TaskIdSet, :RequestId
def initialize(batchid=nil, taskidset=nil, requestid=nil)
@BatchId = batchid
@TaskIdSet = taskidset
@RequestId = requestid
end
def deserialize(params)
@BatchId = params['BatchId']
@TaskIdSet = params['TaskIdSet']
@RequestId = params['RequestId']
end
end
# CreateUser请求参数结构体
class CreateUserRequest < TencentCloud::Common::AbstractModel
# @param UserId: 需要授权的子用户uin，可以通过腾讯云控制台右上角 → “账号信息” → “账号ID进行查看”。
# @type UserId: String
# @param UserDescription: 用户描述信息，方便区分不同用户
# @type UserDescription: String
# @param PolicySet: 绑定到用户的权限集合
# @type PolicySet: Array
# @param UserType: 用户类型。ADMIN：管理员 COMMON：一般用户。当用户类型为管理员的时候，不能设置权限集合和绑定的工作组集合，管理员默认拥有所有权限。该参数不填默认为COMMON
# @type UserType: String
# @param WorkGroupIds: 绑定到用户的工作组ID集合。
# @type WorkGroupIds: Array
# @param UserAlias: 用户别名，字符长度小50
# @type UserAlias: String
attr_accessor :UserId, :UserDescription, :PolicySet, :UserType, :WorkGroupIds, :UserAlias
def initialize(userid=nil, userdescription=nil, policyset=nil, usertype=nil, workgroupids=nil, useralias=nil)
@UserId = userid
@UserDescription = userdescription
@PolicySet = policyset
@UserType = usertype
@WorkGroupIds = workgroupids
@UserAlias = useralias
end
def deserialize(params)
@UserId = params['UserId']
@UserDescription = params['UserDescription']
unless params['PolicySet'].nil?
@PolicySet = []
params['PolicySet'].each do |i|
policy_tmp = Policy.new
policy_tmp.deserialize(i)
@PolicySet << policy_tmp
end
end
@UserType = params['UserType']
@WorkGroupIds = params['WorkGroupIds']
@UserAlias = params['UserAlias']
end
end
# CreateUser返回参数结构体
class CreateUserResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# CreateWorkGroup请求参数结构体
class CreateWorkGroupRequest < TencentCloud::Common::AbstractModel
# @param WorkGroupName: 工作组名称
# @type WorkGroupName: String
# @param WorkGroupDescription: 工作组描述
# @type WorkGroupDescription: String
# @param PolicySet: 工作组绑定的鉴权策略集合
# @type PolicySet: Array
# @param UserIds: 需要绑定到工作组的用户Id集合
# @type UserIds: Array
attr_accessor :WorkGroupName, :WorkGroupDescription, :PolicySet, :UserIds
def initialize(workgroupname=nil, workgroupdescription=nil, policyset=nil, userids=nil)
@WorkGroupName = workgroupname
@WorkGroupDescription = workgroupdescription
@PolicySet = policyset
@UserIds = userids
end
def deserialize(params)
@WorkGroupName = params['WorkGroupName']
@WorkGroupDescription = params['WorkGroupDescription']
unless params['PolicySet'].nil?
@PolicySet = []
params['PolicySet'].each do |i|
policy_tmp = Policy.new
policy_tmp.deserialize(i)
@PolicySet << policy_tmp
end
end
@UserIds = params['UserIds']
end
end
# CreateWorkGroup返回参数结构体
class CreateWorkGroupResponse < TencentCloud::Common::AbstractModel
# @param WorkGroupId: 工作组Id，全局唯一
# @type WorkGroupId: Integer
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :WorkGroupId, :RequestId
def initialize(workgroupid=nil, requestid=nil)
@WorkGroupId = workgroupid
@RequestId = requestid
end
def deserialize(params)
@WorkGroupId = params['WorkGroupId']
@RequestId = params['RequestId']
end
end
# 迁移列对象
class DMSColumn < TencentCloud::Common::AbstractModel
# @param Name: 名称
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Name: String
# @param Description: 描述
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Description: String
# @param Type: 类型
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Type: String
# @param Position: 排序
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Position: Integer
# @param Params: 附加参数
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Params: Array
# @param BizParams: 业务参数
# 注意：此字段可能返回 null，表示取不到有效值。
# @type BizParams: Array
# @param IsPartition: 是否分区
# 注意：此字段可能返回 null，表示取不到有效值。
# @type IsPartition: Boolean
attr_accessor :Name, :Description, :Type, :Position, :Params, :BizParams, :IsPartition
def initialize(name=nil, description=nil, type=nil, position=nil, params=nil, bizparams=nil, ispartition=nil)
@Name = name
@Description = description
@Type = type
@Position = position
@Params = params
@BizParams = bizparams
@IsPartition = ispartition
end
def deserialize(params)
@Name = params['Name']
@Description = params['Description']
@Type = params['Type']
@Position = params['Position']
unless params['Params'].nil?
@Params = []
params['Params'].each do |i|
kvpair_tmp = KVPair.new
kvpair_tmp.deserialize(i)
@Params << kvpair_tmp
end
end
unless params['BizParams'].nil?
@BizParams = []
params['BizParams'].each do |i|
kvpair_tmp = KVPair.new
kvpair_tmp.deserialize(i)
@BizParams << kvpair_tmp
end
end
@IsPartition = params['IsPartition']
end
end
# 列排序对象
class DMSColumnOrder < TencentCloud::Common::AbstractModel
# @param Col: 列名
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Col: String
# @param Order: 排序
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Order: Integer
attr_accessor :Col, :Order
def initialize(col=nil, order=nil)
@Col = col
@Order = order
end
def deserialize(params)
@Col = params['Col']
@Order = params['Order']
end
end
# 迁移元数据分区对象
class DMSPartition < TencentCloud::Common::AbstractModel
# @param DatabaseName: 数据库名称
# @type DatabaseName: String
# @param SchemaName: 数据目录名称
# @type SchemaName: String
# @param TableName: 表名称
# @type TableName: String
# @param DataVersion: 数据版本
# @type DataVersion: Integer
# @param Name: 分区名称
# @type Name: String
# @param Values: 值列表
# @type Values: Array
# @param StorageSize: 存储大小
# @type StorageSize: Integer
# @param RecordCount: 记录数量
# @type RecordCount: Integer
# @param CreateTime: 创建时间
# @type CreateTime: String
# @param ModifiedTime: 修改时间
# @type ModifiedTime: String
# @param LastAccessTime: 最后访问时间
# @type LastAccessTime: String
# @param Params: 附件属性
# @type Params: Array
# @param Sds: 存储对象
# @type Sds: :class:`Tencentcloud::Dlc.v20210125.models.DMSSds`
attr_accessor :DatabaseName, :SchemaName, :TableName, :DataVersion, :Name, :Values, :StorageSize, :RecordCount, :CreateTime, :ModifiedTime, :LastAccessTime, :Params, :Sds
def initialize(databasename=nil, schemaname=nil, tablename=nil, dataversion=nil, name=nil, values=nil, storagesize=nil, recordcount=nil, createtime=nil, modifiedtime=nil, lastaccesstime=nil, params=nil, sds=nil)
@DatabaseName = databasename
@SchemaName = schemaname
@TableName = tablename
@DataVersion = dataversion
@Name = name
@Values = values
@StorageSize = storagesize
@RecordCount = recordcount
@CreateTime = createtime
@ModifiedTime = modifiedtime
@LastAccessTime = lastaccesstime
@Params = params
@Sds = sds
end
def deserialize(params)
@DatabaseName = params['DatabaseName']
@SchemaName = params['SchemaName']
@TableName = params['TableName']
@DataVersion = params['DataVersion']
@Name = params['Name']
@Values = params['Values']
@StorageSize = params['StorageSize']
@RecordCount = params['RecordCount']
@CreateTime = params['CreateTime']
@ModifiedTime = params['ModifiedTime']
@LastAccessTime = params['LastAccessTime']
unless params['Params'].nil?
@Params = []
params['Params'].each do |i|
kvpair_tmp = KVPair.new
kvpair_tmp.deserialize(i)
@Params << kvpair_tmp
end
end
unless params['Sds'].nil?
@Sds = DMSSds.new
@Sds.deserialize(params['Sds'])
end
end
end
# 元数据存储描述属性
class DMSSds < TencentCloud::Common::AbstractModel
# @param Location: 存储地址
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Location: String
# @param InputFormat: 输入格式
# 注意：此字段可能返回 null，表示取不到有效值。
# @type InputFormat: String
# @param OutputFormat: 输出格式
# 注意：此字段可能返回 null，表示取不到有效值。
# @type OutputFormat: String
# @param NumBuckets: bucket数量
# 注意：此字段可能返回 null，表示取不到有效值。
# @type NumBuckets: Integer
# @param Compressed: 是是否压缩
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Compressed: Boolean
# @param StoredAsSubDirectories: 是否有子目录
# 注意：此字段可能返回 null，表示取不到有效值。
# @type StoredAsSubDirectories: Boolean
# @param SerdeLib: 序列化lib
# 注意：此字段可能返回 null，表示取不到有效值。
# @type SerdeLib: String
# @param SerdeName: 序列化名称
# 注意：此字段可能返回 null，表示取不到有效值。
# @type SerdeName: String
# @param BucketCols: 桶名称
# 注意：此字段可能返回 null，表示取不到有效值。
# @type BucketCols: Array
# @param SerdeParams: 序列化参数
# 注意：此字段可能返回 null，表示取不到有效值。
# @type SerdeParams: Array
# @param Params: 附加参数
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Params: Array
# @param SortCols: 列排序(Expired)
# 注意：此字段可能返回 null，表示取不到有效值。
# @type SortCols: :class:`Tencentcloud::Dlc.v20210125.models.DMSColumnOrder`
# @param Cols: 列
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Cols: Array
# @param SortColumns: 列排序字段
# 注意：此字段可能返回 null，表示取不到有效值。
# @type SortColumns: Array
attr_accessor :Location, :InputFormat, :OutputFormat, :NumBuckets, :Compressed, :StoredAsSubDirectories, :SerdeLib, :SerdeName, :BucketCols, :SerdeParams, :Params, :SortCols, :Cols, :SortColumns
def initialize(location=nil, inputformat=nil, outputformat=nil, numbuckets=nil, compressed=nil, storedassubdirectories=nil, serdelib=nil, serdename=nil, bucketcols=nil, serdeparams=nil, params=nil, sortcols=nil, cols=nil, sortcolumns=nil)
@Location = location
@InputFormat = inputformat
@OutputFormat = outputformat
@NumBuckets = numbuckets
@Compressed = compressed
@StoredAsSubDirectories = storedassubdirectories
@SerdeLib = serdelib
@SerdeName = serdename
@BucketCols = bucketcols
@SerdeParams = serdeparams
@Params = params
@SortCols = sortcols
@Cols = cols
@SortColumns = sortcolumns
end
def deserialize(params)
@Location = params['Location']
@InputFormat = params['InputFormat']
@OutputFormat = params['OutputFormat']
@NumBuckets = params['NumBuckets']
@Compressed = params['Compressed']
@StoredAsSubDirectories = params['StoredAsSubDirectories']
@SerdeLib = params['SerdeLib']
@SerdeName = params['SerdeName']
@BucketCols = params['BucketCols']
unless params['SerdeParams'].nil?
@SerdeParams = []
params['SerdeParams'].each do |i|
kvpair_tmp = KVPair.new
kvpair_tmp.deserialize(i)
@SerdeParams << kvpair_tmp
end
end
unless params['Params'].nil?
@Params = []
params['Params'].each do |i|
kvpair_tmp = KVPair.new
kvpair_tmp.deserialize(i)
@Params << kvpair_tmp
end
end
unless params['SortCols'].nil?
@SortCols = DMSColumnOrder.new
@SortCols.deserialize(params['SortCols'])
end
unless params['Cols'].nil?
@Cols = []
params['Cols'].each do |i|
dmscolumn_tmp = DMSColumn.new
dmscolumn_tmp.deserialize(i)
@Cols << dmscolumn_tmp
end
end
unless params['SortColumns'].nil?
@SortColumns = []
params['SortColumns'].each do |i|
dmscolumnorder_tmp = DMSColumnOrder.new
dmscolumnorder_tmp.deserialize(i)
@SortColumns << dmscolumnorder_tmp
end
end
end
end
# DMSTable基本信息
class DMSTable < TencentCloud::Common::AbstractModel
# @param ViewOriginalText: 视图文本
# 注意：此字段可能返回 null，表示取不到有效值。
# @type ViewOriginalText: String
# @param ViewExpandedText: 视图文本
# 注意：此字段可能返回 null，表示取不到有效值。
# @type ViewExpandedText: String
# @param Retention: hive维护版本
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Retention: Integer
# @param Sds: 存储对象
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Sds: :class:`Tencentcloud::Dlc.v20210125.models.DMSSds`
# @param PartitionKeys: 分区列
# 注意：此字段可能返回 null，表示取不到有效值。
# @type PartitionKeys: Array
# @param Partitions: 分区
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Partitions: Array
# @param Type: 表类型
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Type: String
# @param DbName: 数据库名称
# 注意：此字段可能返回 null，表示取不到有效值。
# @type DbName: String
# @param SchemaName: Schema名称
# 注意：此字段可能返回 null，表示取不到有效值。
# @type SchemaName: String
# @param StorageSize: 存储大小
# 注意：此字段可能返回 null，表示取不到有效值。
# @type StorageSize: Integer
# @param RecordCount: 记录数量
# 注意：此字段可能返回 null，表示取不到有效值。
# @type RecordCount: Integer
# @param LifeTime: 生命周期
# 注意：此字段可能返回 null，表示取不到有效值。
# @type LifeTime: Integer
# @param LastAccessTime: 最后访问时间
# 注意：此字段可能返回 null，表示取不到有效值。
# @type LastAccessTime: String
# @param DataUpdateTime: 数据更新时间
# 注意：此字段可能返回 null，表示取不到有效值。
# @type DataUpdateTime: String
# @param StructUpdateTime: 结构更新时间
# 注意：此字段可能返回 null，表示取不到有效值。
# @type StructUpdateTime: String
# @param Columns: 列
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Columns: Array
# @param Name: 表名
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Name: String
attr_accessor :ViewOriginalText, :ViewExpandedText, :Retention, :Sds, :PartitionKeys, :Partitions, :Type, :DbName, :SchemaName, :StorageSize, :RecordCount, :LifeTime, :LastAccessTime, :DataUpdateTime, :StructUpdateTime, :Columns, :Name
def initialize(vieworiginaltext=nil, viewexpandedtext=nil, retention=nil, sds=nil, partitionkeys=nil, partitions=nil, type=nil, dbname=nil, schemaname=nil, storagesize=nil, recordcount=nil, lifetime=nil, lastaccesstime=nil, dataupdatetime=nil, structupdatetime=nil, columns=nil, name=nil)
@ViewOriginalText = vieworiginaltext
@ViewExpandedText = viewexpandedtext
@Retention = retention
@Sds = sds
@PartitionKeys = partitionkeys
@Partitions = partitions
@Type = type
@DbName = dbname
@SchemaName = schemaname
@StorageSize = storagesize
@RecordCount = recordcount
@LifeTime = lifetime
@LastAccessTime = lastaccesstime
@DataUpdateTime = dataupdatetime
@StructUpdateTime = structupdatetime
@Columns = columns
@Name = name
end
def deserialize(params)
@ViewOriginalText = params['ViewOriginalText']
@ViewExpandedText = params['ViewExpandedText']
@Retention = params['Retention']
unless params['Sds'].nil?
@Sds = DMSSds.new
@Sds.deserialize(params['Sds'])
end
unless params['PartitionKeys'].nil?
@PartitionKeys = []
params['PartitionKeys'].each do |i|
dmscolumn_tmp = DMSColumn.new
dmscolumn_tmp.deserialize(i)
@PartitionKeys << dmscolumn_tmp
end
end
unless params['Partitions'].nil?
@Partitions = []
params['Partitions'].each do |i|
dmspartition_tmp = DMSPartition.new
dmspartition_tmp.deserialize(i)
@Partitions << dmspartition_tmp
end
end
@Type = params['Type']
@DbName = params['DbName']
@SchemaName = params['SchemaName']
@StorageSize = params['StorageSize']
@RecordCount = params['RecordCount']
@LifeTime = params['LifeTime']
@LastAccessTime = params['LastAccessTime']
@DataUpdateTime = params['DataUpdateTime']
@StructUpdateTime = params['StructUpdateTime']
unless params['Columns'].nil?
@Columns = []
params['Columns'].each do |i|
dmscolumn_tmp = DMSColumn.new
dmscolumn_tmp.deserialize(i)
@Columns << dmscolumn_tmp
end
end
@Name = params['Name']
end
end
# DMSTable信息
class DMSTableInfo < TencentCloud::Common::AbstractModel
# @param Table: DMS表信息
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Table: :class:`Tencentcloud::Dlc.v20210125.models.DMSTable`
# @param Asset: 基础对象信息
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Asset: :class:`Tencentcloud::Dlc.v20210125.models.Asset`
attr_accessor :Table, :Asset
def initialize(table=nil, asset=nil)
@Table = table
@Asset = asset
end
def deserialize(params)
unless params['Table'].nil?
@Table = DMSTable.new
@Table.deserialize(params['Table'])
end
unless params['Asset'].nil?
@Asset = Asset.new
@Asset.deserialize(params['Asset'])
end
end
end
# 数据表数据格式。
class DataFormat < TencentCloud::Common::AbstractModel
# @param TextFile: 文本格式，TextFile。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type TextFile: :class:`Tencentcloud::Dlc.v20210125.models.TextFile`
# @param CSV: 文本格式，CSV。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type CSV: :class:`Tencentcloud::Dlc.v20210125.models.CSV`
# @param Json: 文本格式，Json。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Json: :class:`Tencentcloud::Dlc.v20210125.models.Other`
# @param Parquet: Parquet格式
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Parquet: :class:`Tencentcloud::Dlc.v20210125.models.Other`
# @param ORC: ORC格式
# 注意：此字段可能返回 null，表示取不到有效值。
# @type ORC: :class:`Tencentcloud::Dlc.v20210125.models.Other`
# @param AVRO: AVRO格式
# 注意：此字段可能返回 null，表示取不到有效值。
# @type AVRO: :class:`Tencentcloud::Dlc.v20210125.models.Other`
attr_accessor :TextFile, :CSV, :Json, :Parquet, :ORC, :AVRO
def initialize(textfile=nil, csv=nil, json=nil, parquet=nil, orc=nil, avro=nil)
@TextFile = textfile
@CSV = csv
@Json = json
@Parquet = parquet
@ORC = orc
@AVRO = avro
end
def deserialize(params)
unless params['TextFile'].nil?
@TextFile = TextFile.new
@TextFile.deserialize(params['TextFile'])
end
unless params['CSV'].nil?
@CSV = CSV.new
@CSV.deserialize(params['CSV'])
end
unless params['Json'].nil?
@Json = Other.new
@Json.deserialize(params['Json'])
end
unless params['Parquet'].nil?
@Parquet = Other.new
@Parquet.deserialize(params['Parquet'])
end
unless params['ORC'].nil?
@ORC = Other.new
@ORC.deserialize(params['ORC'])
end
unless params['AVRO'].nil?
@AVRO = Other.new
@AVRO.deserialize(params['AVRO'])
end
end
end
# 数据库对象
class DatabaseInfo < TencentCloud::Common::AbstractModel
# @param DatabaseName: 数据库名称，长度0~128，支持数字、字母下划线，不允许数字大头，统一转换为小写。
# @type DatabaseName: String
# @param Comment: 数据库描述信息，长度 0~500。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Comment: String
# @param Properties: 数据库属性列表。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Properties: Array
# @param Location: 数据库cos路径
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Location: String
attr_accessor :DatabaseName, :Comment, :Properties, :Location
def initialize(databasename=nil, comment=nil, properties=nil, location=nil)
@DatabaseName = databasename
@Comment = comment
@Properties = properties
@Location = location
end
def deserialize(params)
@DatabaseName = params['DatabaseName']
@Comment = params['Comment']
unless params['Properties'].nil?
@Properties = []
params['Properties'].each do |i|
property_tmp = Property.new
property_tmp.deserialize(i)
@Properties << property_tmp
end
end
@Location = params['Location']
end
end
# 数据库对象
class DatabaseResponseInfo < TencentCloud::Common::AbstractModel
# @param DatabaseName: 数据库名称。
# @type DatabaseName: String
# @param Comment: 数据库描述信息，长度 0~256。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Comment: String
# @param Properties: 允许针对数据库的属性元数据信息进行指定。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Properties: Array
# @param CreateTime: 数据库创建时间戳，单位：s。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type CreateTime: String
# @param ModifiedTime: 数据库更新时间戳，单位：s。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type ModifiedTime: String
attr_accessor :DatabaseName, :Comment, :Properties, :CreateTime, :ModifiedTime
def initialize(databasename=nil, comment=nil, properties=nil, createtime=nil, modifiedtime=nil)
@DatabaseName = databasename
@Comment = comment
@Properties = properties
@CreateTime = createtime
@ModifiedTime = modifiedtime
end
def deserialize(params)
@DatabaseName = params['DatabaseName']
@Comment = params['Comment']
unless params['Properties'].nil?
@Properties = []
params['Properties'].each do |i|
property_tmp = Property.new
property_tmp.deserialize(i)
@Properties << property_tmp
end
end
@CreateTime = params['CreateTime']
@ModifiedTime = params['ModifiedTime']
end
end
# DeleteScript请求参数结构体
class DeleteScriptRequest < TencentCloud::Common::AbstractModel
# @param ScriptIds: 脚本id，其可以通过DescribeScripts接口提取
# @type ScriptIds: Array
attr_accessor :ScriptIds
def initialize(scriptids=nil)
@ScriptIds = scriptids
end
def deserialize(params)
@ScriptIds = params['ScriptIds']
end
end
# DeleteScript返回参数结构体
class DeleteScriptResponse < TencentCloud::Common::AbstractModel
# @param ScriptsAffected: 删除的脚本数量
# @type ScriptsAffected: Integer
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :ScriptsAffected, :RequestId
def initialize(scriptsaffected=nil, requestid=nil)
@ScriptsAffected = scriptsaffected
@RequestId = requestid
end
def deserialize(params)
@ScriptsAffected = params['ScriptsAffected']
@RequestId = params['RequestId']
end
end
# DeleteSparkApp请求参数结构体
class DeleteSparkAppRequest < TencentCloud::Common::AbstractModel
# @param AppName: spark应用名
# @type AppName: String
attr_accessor :AppName
def initialize(appname=nil)
@AppName = appname
end
def deserialize(params)
@AppName = params['AppName']
end
end
# DeleteSparkApp返回参数结构体
class DeleteSparkAppResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# DeleteUser请求参数结构体
class DeleteUserRequest < TencentCloud::Common::AbstractModel
# @param UserIds: 需要删除的用户的Id
# @type UserIds: Array
attr_accessor :UserIds
def initialize(userids=nil)
@UserIds = userids
end
def deserialize(params)
@UserIds = params['UserIds']
end
end
# DeleteUser返回参数结构体
class DeleteUserResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# DeleteUsersFromWorkGroup请求参数结构体
class DeleteUsersFromWorkGroupRequest < TencentCloud::Common::AbstractModel
# @param AddInfo: 要删除的用户信息
# @type AddInfo: :class:`Tencentcloud::Dlc.v20210125.models.UserIdSetOfWorkGroupId`
attr_accessor :AddInfo
def initialize(addinfo=nil)
@AddInfo = addinfo
end
def deserialize(params)
unless params['AddInfo'].nil?
@AddInfo = UserIdSetOfWorkGroupId.new
@AddInfo.deserialize(params['AddInfo'])
end
end
end
# DeleteUsersFromWorkGroup返回参数结构体
class DeleteUsersFromWorkGroupResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# DeleteWorkGroup请求参数结构体
class DeleteWorkGroupRequest < TencentCloud::Common::AbstractModel
# @param WorkGroupIds: 要删除的工作组Id集合
# @type WorkGroupIds: Array
attr_accessor :WorkGroupIds
def initialize(workgroupids=nil)
@WorkGroupIds = workgroupids
end
def deserialize(params)
@WorkGroupIds = params['WorkGroupIds']
end
end
# DeleteWorkGroup返回参数结构体
class DeleteWorkGroupResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# DescribeDMSDatabase请求参数结构体
class DescribeDMSDatabaseRequest < TencentCloud::Common::AbstractModel
def initialize()
end
def deserialize(params)
end
end
# DescribeDMSDatabase返回参数结构体
class DescribeDMSDatabaseResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# DescribeDMSPartitions请求参数结构体
class DescribeDMSPartitionsRequest < TencentCloud::Common::AbstractModel
# @param DatabaseName: 数据库名
# @type DatabaseName: String
# @param TableName: 表名称
# @type TableName: String
# @param SchemaName: schema名称
# @type SchemaName: String
# @param Name: 名称
# @type Name: String
# @param Values: 单个分区名称，精准匹配
# @type Values: Array
# @param PartitionNames: 多个分区名称，精准匹配
# @type PartitionNames: Array
# @param PartValues: 多个分区字段的匹配，模糊匹配
# @type PartValues: Array
# @param Filter: 过滤SQL
# @type Filter: String
# @param MaxParts: 最大分区数量
# @type MaxParts: Integer
# @param Offset: 翻页跳过数量
# @type Offset: Integer
# @param Limit: 页面数量
# @type Limit: Integer
attr_accessor :DatabaseName, :TableName, :SchemaName, :Name, :Values, :PartitionNames, :PartValues, :Filter, :MaxParts, :Offset, :Limit
def initialize(databasename=nil, tablename=nil, schemaname=nil, name=nil, values=nil, partitionnames=nil, partvalues=nil, filter=nil, maxparts=nil, offset=nil, limit=nil)
@DatabaseName = databasename
@TableName = tablename
@SchemaName = schemaname
@Name = name
@Values = values
@PartitionNames = partitionnames
@PartValues = partvalues
@Filter = filter
@MaxParts = maxparts
@Offset = offset
@Limit = limit
end
def deserialize(params)
@DatabaseName = params['DatabaseName']
@TableName = params['TableName']
@SchemaName = params['SchemaName']
@Name = params['Name']
@Values = params['Values']
@PartitionNames = params['PartitionNames']
@PartValues = params['PartValues']
@Filter = params['Filter']
@MaxParts = params['MaxParts']
@Offset = params['Offset']
@Limit = params['Limit']
end
end
# DescribeDMSPartitions返回参数结构体
class DescribeDMSPartitionsResponse < TencentCloud::Common::AbstractModel
# @param Partitions: 分区信息
# @type Partitions: Array
# @param Total: 总数
# @type Total: Integer
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :Partitions, :Total, :RequestId
def initialize(partitions=nil, total=nil, requestid=nil)
@Partitions = partitions
@Total = total
@RequestId = requestid
end
def deserialize(params)
unless params['Partitions'].nil?
@Partitions = []
params['Partitions'].each do |i|
dmspartition_tmp = DMSPartition.new
dmspartition_tmp.deserialize(i)
@Partitions << dmspartition_tmp
end
end
@Total = params['Total']
@RequestId = params['RequestId']
end
end
# DescribeDMSTable请求参数结构体
class DescribeDMSTableRequest < TencentCloud::Common::AbstractModel
# @param DbName: 数据库名称
# @type DbName: String
# @param SchemaName: 数据库schema名称
# @type SchemaName: String
# @param Name: 表名称
# @type Name: String
# @param Catalog: 数据目录
# @type Catalog: String
# @param Keyword: 查询关键词
# @type Keyword: String
# @param Pattern: 查询模式
# @type Pattern: String
# @param Type: 表类型
# @type Type: String
attr_accessor :DbName, :SchemaName, :Name, :Catalog, :Keyword, :Pattern, :Type
def initialize(dbname=nil, schemaname=nil, name=nil, catalog=nil, keyword=nil, pattern=nil, type=nil)
@DbName = dbname
@SchemaName = schemaname
@Name = name
@Catalog = catalog
@Keyword = keyword
@Pattern = pattern
@Type = type
end
def deserialize(params)
@DbName = params['DbName']
@SchemaName = params['SchemaName']
@Name = params['Name']
@Catalog = params['Catalog']
@Keyword = params['Keyword']
@Pattern = params['Pattern']
@Type = params['Type']
end
end
# DescribeDMSTable返回参数结构体
class DescribeDMSTableResponse < TencentCloud::Common::AbstractModel
# @param Asset: 基础对象
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Asset: :class:`Tencentcloud::Dlc.v20210125.models.Asset`
# @param ViewOriginalText: 视图文本
# 注意：此字段可能返回 null，表示取不到有效值。
# @type ViewOriginalText: String
# @param ViewExpandedText: 视图文本
# 注意：此字段可能返回 null，表示取不到有效值。
# @type ViewExpandedText: String
# @param Retention: hive维护版本
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Retention: Integer
# @param Sds: 存储对象
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Sds: :class:`Tencentcloud::Dlc.v20210125.models.DMSSds`
# @param PartitionKeys: 分区列
# 注意：此字段可能返回 null，表示取不到有效值。
# @type PartitionKeys: Array
# @param Partitions: 分区
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Partitions: Array
# @param Type: 表类型
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Type: String
# @param DbName: 数据库名称
# 注意：此字段可能返回 null，表示取不到有效值。
# @type DbName: String
# @param SchemaName: Schame名称
# 注意：此字段可能返回 null，表示取不到有效值。
# @type SchemaName: String
# @param StorageSize: 存储大小
# 注意：此字段可能返回 null，表示取不到有效值。
# @type StorageSize: Integer
# @param RecordCount: 记录数量
# 注意：此字段可能返回 null，表示取不到有效值。
# @type RecordCount: Integer
# @param LifeTime: 生命周期
# 注意：此字段可能返回 null，表示取不到有效值。
# @type LifeTime: Integer
# @param LastAccessTime: 最后访问时间
# 注意：此字段可能返回 null，表示取不到有效值。
# @type LastAccessTime: String
# @param DataUpdateTime: 数据更新时间
# 注意：此字段可能返回 null，表示取不到有效值。
# @type DataUpdateTime: String
# @param StructUpdateTime: 结构更新时间
# 注意：此字段可能返回 null，表示取不到有效值。
# @type StructUpdateTime: String
# @param Columns: 列
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Columns: Array
# @param Name: 表名称
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Name: String
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :Asset, :ViewOriginalText, :ViewExpandedText, :Retention, :Sds, :PartitionKeys, :Partitions, :Type, :DbName, :SchemaName, :StorageSize, :RecordCount, :LifeTime, :LastAccessTime, :DataUpdateTime, :StructUpdateTime, :Columns, :Name, :RequestId
def initialize(asset=nil, vieworiginaltext=nil, viewexpandedtext=nil, retention=nil, sds=nil, partitionkeys=nil, partitions=nil, type=nil, dbname=nil, schemaname=nil, storagesize=nil, recordcount=nil, lifetime=nil, lastaccesstime=nil, dataupdatetime=nil, structupdatetime=nil, columns=nil, name=nil, requestid=nil)
@Asset = asset
@ViewOriginalText = vieworiginaltext
@ViewExpandedText = viewexpandedtext
@Retention = retention
@Sds = sds
@PartitionKeys = partitionkeys
@Partitions = partitions
@Type = type
@DbName = dbname
@SchemaName = schemaname
@StorageSize = storagesize
@RecordCount = recordcount
@LifeTime = lifetime
@LastAccessTime = lastaccesstime
@DataUpdateTime = dataupdatetime
@StructUpdateTime = structupdatetime
@Columns = columns
@Name = name
@RequestId = requestid
end
def deserialize(params)
unless params['Asset'].nil?
@Asset = Asset.new
@Asset.deserialize(params['Asset'])
end
@ViewOriginalText = params['ViewOriginalText']
@ViewExpandedText = params['ViewExpandedText']
@Retention = params['Retention']
unless params['Sds'].nil?
@Sds = DMSSds.new
@Sds.deserialize(params['Sds'])
end
unless params['PartitionKeys'].nil?
@PartitionKeys = []
params['PartitionKeys'].each do |i|
dmscolumn_tmp = DMSColumn.new
dmscolumn_tmp.deserialize(i)
@PartitionKeys << dmscolumn_tmp
end
end
unless params['Partitions'].nil?
@Partitions = []
params['Partitions'].each do |i|
dmspartition_tmp = DMSPartition.new
dmspartition_tmp.deserialize(i)
@Partitions << dmspartition_tmp
end
end
@Type = params['Type']
@DbName = params['DbName']
@SchemaName = params['SchemaName']
@StorageSize = params['StorageSize']
@RecordCount = params['RecordCount']
@LifeTime = params['LifeTime']
@LastAccessTime = params['LastAccessTime']
@DataUpdateTime = params['DataUpdateTime']
@StructUpdateTime = params['StructUpdateTime']
unless params['Columns'].nil?
@Columns = []
params['Columns'].each do |i|
dmscolumn_tmp = DMSColumn.new
dmscolumn_tmp.deserialize(i)
@Columns << dmscolumn_tmp
end
end
@Name = params['Name']
@RequestId = params['RequestId']
end
end
# DescribeDMSTables请求参数结构体
class DescribeDMSTablesRequest < TencentCloud::Common::AbstractModel
# @param DbName: 数据库名称
# @type DbName: String
# @param SchemaName: 数据库schema名称
# @type SchemaName: String
# @param Name: 表名称
# @type Name: String
# @param Catalog: 数据目录
# @type Catalog: String
# @param Keyword: 查询关键词
# @type Keyword: String
# @param Pattern: 查询模式
# @type Pattern: String
# @param Type: 表类型
# @type Type: String
# @param StartTime: 筛选参数：更新开始时间
# @type StartTime: String
# @param EndTime: 筛选参数：更新结束时间
# @type EndTime: String
# @param Limit: 分页参数
# @type Limit: Integer
# @param Offset: 分页参数
# @type Offset: Integer
# @param Sort: 排序字段：create_time：创建时间
# @type Sort: String
# @param Asc: 排序字段：true：升序（默认），false：降序
# @type Asc: Boolean
attr_accessor :DbName, :SchemaName, :Name, :Catalog, :Keyword, :Pattern, :Type, :StartTime, :EndTime, :Limit, :Offset, :Sort, :Asc
def initialize(dbname=nil, schemaname=nil, name=nil, catalog=nil, keyword=nil, pattern=nil, type=nil, starttime=nil, endtime=nil, limit=nil, offset=nil, sort=nil, asc=nil)
@DbName = dbname
@SchemaName = schemaname
@Name = name
@Catalog = catalog
@Keyword = keyword
@Pattern = pattern
@Type = type
@StartTime = starttime
@EndTime = endtime
@Limit = limit
@Offset = offset
@Sort = sort
@Asc = asc
end
def deserialize(params)
@DbName = params['DbName']
@SchemaName = params['SchemaName']
@Name = params['Name']
@Catalog = params['Catalog']
@Keyword = params['Keyword']
@Pattern = params['Pattern']
@Type = params['Type']
@StartTime = params['StartTime']
@EndTime = params['EndTime']
@Limit = params['Limit']
@Offset = params['Offset']
@Sort = params['Sort']
@Asc = params['Asc']
end
end
# DescribeDMSTables返回参数结构体
class DescribeDMSTablesResponse < TencentCloud::Common::AbstractModel
# @param TableList: DMS元数据列表信息
# 注意：此字段可能返回 null，表示取不到有效值。
# @type TableList: Array
# @param TotalCount: 统计值
# 注意：此字段可能返回 null，表示取不到有效值。
# @type TotalCount: Integer
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :TableList, :TotalCount, :RequestId
def initialize(tablelist=nil, totalcount=nil, requestid=nil)
@TableList = tablelist
@TotalCount = totalcount
@RequestId = requestid
end
def deserialize(params)
unless params['TableList'].nil?
@TableList = []
params['TableList'].each do |i|
dmstableinfo_tmp = DMSTableInfo.new
dmstableinfo_tmp.deserialize(i)
@TableList << dmstableinfo_tmp
end
end
@TotalCount = params['TotalCount']
@RequestId = params['RequestId']
end
end
# DescribeDatabases请求参数结构体
class DescribeDatabasesRequest < TencentCloud::Common::AbstractModel
# @param Limit: 返回数量，默认为10，最大值为100。
# @type Limit: Integer
# @param Offset: 数据偏移量，从0开始，默认为0。
# @type Offset: Integer
# @param KeyWord: 模糊匹配，库名关键字。
# @type KeyWord: String
# @param DatasourceConnectionName: 数据源唯名称，该名称可以通过DescribeDatasourceConnection接口查询到。默认为DataLakeCatalog
# @type DatasourceConnectionName: String
# @param Sort: 排序字段，当前版本仅支持按库名排序
# @type Sort: String
# @param Asc: 排序类型：false：降序（默认）、true：升序
# @type Asc: Boolean
attr_accessor :Limit, :Offset, :KeyWord, :DatasourceConnectionName, :Sort, :Asc
def initialize(limit=nil, offset=nil, keyword=nil, datasourceconnectionname=nil, sort=nil, asc=nil)
@Limit = limit
@Offset = offset
@KeyWord = keyword
@DatasourceConnectionName = datasourceconnectionname
@Sort = sort
@Asc = asc
end
def deserialize(params)
@Limit = params['Limit']
@Offset = params['Offset']
@KeyWord = params['KeyWord']
@DatasourceConnectionName = params['DatasourceConnectionName']
@Sort = params['Sort']
@Asc = params['Asc']
end
end
# DescribeDatabases返回参数结构体
class DescribeDatabasesResponse < TencentCloud::Common::AbstractModel
# @param DatabaseList: 数据库对象列表。
# @type DatabaseList: Array
# @param TotalCount: 实例总数。
# @type TotalCount: Integer
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :DatabaseList, :TotalCount, :RequestId
def initialize(databaselist=nil, totalcount=nil, requestid=nil)
@DatabaseList = databaselist
@TotalCount = totalcount
@RequestId = requestid
end
def deserialize(params)
unless params['DatabaseList'].nil?
@DatabaseList = []
params['DatabaseList'].each do |i|
databaseresponseinfo_tmp = DatabaseResponseInfo.new
databaseresponseinfo_tmp.deserialize(i)
@DatabaseList << databaseresponseinfo_tmp
end
end
@TotalCount = params['TotalCount']
@RequestId = params['RequestId']
end
end
# DescribeScripts请求参数结构体
class DescribeScriptsRequest < TencentCloud::Common::AbstractModel
# @param Limit: 返回数量，默认为10，最大值为100。
# @type Limit: Integer
# @param Offset: 偏移量，默认为0。
# @type Offset: Integer
# @param SortBy: 按字段排序，支持如下字段类型，update-time
# @type SortBy: String
# @param Sorting: 排序方式，desc表示正序，asc表示反序，默认asc
# @type Sorting: String
# @param Filters: 过滤条件，如下支持的过滤类型，传参Name应为其一
# script-id - String - （过滤条件）script-id取值形如：157de0d1-26b4-4df2-a2d0-b64afc406c25。
# script-name-keyword - String - （过滤条件）数据表名称,形如：script-test。
# @type Filters: Array
attr_accessor :Limit, :Offset, :SortBy, :Sorting, :Filters
def initialize(limit=nil, offset=nil, sortby=nil, sorting=nil, filters=nil)
@Limit = limit
@Offset = offset
@SortBy = sortby
@Sorting = sorting
@Filters = filters
end
def deserialize(params)
@Limit = params['Limit']
@Offset = params['Offset']
@SortBy = params['SortBy']
@Sorting = params['Sorting']
unless params['Filters'].nil?
@Filters = []
params['Filters'].each do |i|
filter_tmp = Filter.new
filter_tmp.deserialize(i)
@Filters << filter_tmp
end
end
end
end
# DescribeScripts返回参数结构体
class DescribeScriptsResponse < TencentCloud::Common::AbstractModel
# @param Scripts: Script列表
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Scripts: Array
# @param TotalCount: 实例总数
# @type TotalCount: Integer
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :Scripts, :TotalCount, :RequestId
def initialize(scripts=nil, totalcount=nil, requestid=nil)
@Scripts = scripts
@TotalCount = totalcount
@RequestId = requestid
end
def deserialize(params)
unless params['Scripts'].nil?
@Scripts = []
params['Scripts'].each do |i|
script_tmp = Script.new
script_tmp.deserialize(i)
@Scripts << script_tmp
end
end
@TotalCount = params['TotalCount']
@RequestId = params['RequestId']
end
end
# DescribeSparkAppJob请求参数结构体
class DescribeSparkAppJobRequest < TencentCloud::Common::AbstractModel
# @param JobId: spark作业Id，与JobName同时存在时，JobName无效
# @type JobId: String
# @param JobName: spark作业名
# @type JobName: String
attr_accessor :JobId, :JobName
def initialize(jobid=nil, jobname=nil)
@JobId = jobid
@JobName = jobname
end
def deserialize(params)
@JobId = params['JobId']
@JobName = params['JobName']
end
end
# DescribeSparkAppJob返回参数结构体
class DescribeSparkAppJobResponse < TencentCloud::Common::AbstractModel
# @param Job: spark作业详情
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Job: :class:`Tencentcloud::Dlc.v20210125.models.SparkJobInfo`
# @param IsExists: 查询的spark作业是否存在
# @type IsExists: Boolean
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :Job, :IsExists, :RequestId
def initialize(job=nil, isexists=nil, requestid=nil)
@Job = job
@IsExists = isexists
@RequestId = requestid
end
def deserialize(params)
unless params['Job'].nil?
@Job = SparkJobInfo.new
@Job.deserialize(params['Job'])
end
@IsExists = params['IsExists']
@RequestId = params['RequestId']
end
end
# DescribeSparkAppJobs请求参数结构体
class DescribeSparkAppJobsRequest < TencentCloud::Common::AbstractModel
# @param SortBy: 返回结果按照该字段排序
# @type SortBy: String
# @param Sorting: 正序或者倒序，例如：desc
# @type Sorting: String
# @param Filters: 按照该参数过滤
# @type Filters: Array
# @param StartTime: 更新时间起始点
# @type StartTime: String
# @param EndTime: 更新时间截止点
# @type EndTime: String
# @param Offset: 查询列表偏移量
# @type Offset: Integer
# @param Limit: 查询列表限制数量
# @type Limit: Integer
attr_accessor :SortBy, :Sorting, :Filters, :StartTime, :EndTime, :Offset, :Limit
def initialize(sortby=nil, sorting=nil, filters=nil, starttime=nil, endtime=nil, offset=nil, limit=nil)
@SortBy = sortby
@Sorting = sorting
@Filters = filters
@StartTime = starttime
@EndTime = endtime
@Offset = offset
@Limit = limit
end
def deserialize(params)
@SortBy = params['SortBy']
@Sorting = params['Sorting']
unless params['Filters'].nil?
@Filters = []
params['Filters'].each do |i|
filter_tmp = Filter.new
filter_tmp.deserialize(i)
@Filters << filter_tmp
end
end
@StartTime = params['StartTime']
@EndTime = params['EndTime']
@Offset = params['Offset']
@Limit = params['Limit']
end
end
# DescribeSparkAppJobs返回参数结构体
class DescribeSparkAppJobsResponse < TencentCloud::Common::AbstractModel
# @param SparkAppJobs: spark作业列表详情
# @type SparkAppJobs: Array
# @param TotalCount: spark作业总数
# @type TotalCount: Integer
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :SparkAppJobs, :TotalCount, :RequestId
def initialize(sparkappjobs=nil, totalcount=nil, requestid=nil)
@SparkAppJobs = sparkappjobs
@TotalCount = totalcount
@RequestId = requestid
end
def deserialize(params)
unless params['SparkAppJobs'].nil?
@SparkAppJobs = []
params['SparkAppJobs'].each do |i|
sparkjobinfo_tmp = SparkJobInfo.new
sparkjobinfo_tmp.deserialize(i)
@SparkAppJobs << sparkjobinfo_tmp
end
end
@TotalCount = params['TotalCount']
@RequestId = params['RequestId']
end
end
# DescribeSparkAppTasks请求参数结构体
class DescribeSparkAppTasksRequest < TencentCloud::Common::AbstractModel
# @param JobId: spark作业Id
# @type JobId: String
# @param Offset: 分页查询偏移量
# @type Offset: Integer
# @param Limit: 分页查询Limit
# @type Limit: Integer
# @param TaskId: 执行实例id
# @type TaskId: String
attr_accessor :JobId, :Offset, :Limit, :TaskId
def initialize(jobid=nil, offset=nil, limit=nil, taskid=nil)
@JobId = jobid
@Offset = offset
@Limit = limit
@TaskId = taskid
end
def deserialize(params)
@JobId = params['JobId']
@Offset = params['Offset']
@Limit = params['Limit']
@TaskId = params['TaskId']
end
end
# DescribeSparkAppTasks返回参数结构体
class DescribeSparkAppTasksResponse < TencentCloud::Common::AbstractModel
# @param Tasks: 任务结果（该字段已废弃）
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Tasks: :class:`Tencentcloud::Dlc.v20210125.models.TaskResponseInfo`
# @param TotalCount: 任务总数
# @type TotalCount: Integer
# @param SparkAppTasks: 任务结果列表
# 注意：此字段可能返回 null，表示取不到有效值。
# @type SparkAppTasks: Array
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :Tasks, :TotalCount, :SparkAppTasks, :RequestId
def initialize(tasks=nil, totalcount=nil, sparkapptasks=nil, requestid=nil)
@Tasks = tasks
@TotalCount = totalcount
@SparkAppTasks = sparkapptasks
@RequestId = requestid
end
def deserialize(params)
unless params['Tasks'].nil?
@Tasks = TaskResponseInfo.new
@Tasks.deserialize(params['Tasks'])
end
@TotalCount = params['TotalCount']
unless params['SparkAppTasks'].nil?
@SparkAppTasks = []
params['SparkAppTasks'].each do |i|
taskresponseinfo_tmp = TaskResponseInfo.new
taskresponseinfo_tmp.deserialize(i)
@SparkAppTasks << taskresponseinfo_tmp
end
end
@RequestId = params['RequestId']
end
end
# DescribeStoreLocation请求参数结构体
class DescribeStoreLocationRequest < TencentCloud::Common::AbstractModel
def initialize()
end
def deserialize(params)
end
end
# DescribeStoreLocation返回参数结构体
class DescribeStoreLocationResponse < TencentCloud::Common::AbstractModel
# @param StoreLocation: 返回用户设置的结果存储位置路径，如果未设置则返回空字符串：""
# 注意：此字段可能返回 null，表示取不到有效值。
# @type StoreLocation: String
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :StoreLocation, :RequestId
def initialize(storelocation=nil, requestid=nil)
@StoreLocation = storelocation
@RequestId = requestid
end
def deserialize(params)
@StoreLocation = params['StoreLocation']
@RequestId = params['RequestId']
end
end
# DescribeTable请求参数结构体
class DescribeTableRequest < TencentCloud::Common::AbstractModel
# @param TableName: 查询对象表名称
# @type TableName: String
# @param DatabaseName: 查询表所在的数据库名称。
# @type DatabaseName: String
# @param DatasourceConnectionName: 查询表所在的数据源名称
# @type DatasourceConnectionName: String
attr_accessor :TableName, :DatabaseName, :DatasourceConnectionName
def initialize(tablename=nil, databasename=nil, datasourceconnectionname=nil)
@TableName = tablename
@DatabaseName = databasename
@DatasourceConnectionName = datasourceconnectionname
end
def deserialize(params)
@TableName = params['TableName']
@DatabaseName = params['DatabaseName']
@DatasourceConnectionName = params['DatasourceConnectionName']
end
end
# DescribeTable返回参数结构体
class DescribeTableResponse < TencentCloud::Common::AbstractModel
# @param Table: 数据表对象
# @type Table: :class:`Tencentcloud::Dlc.v20210125.models.TableResponseInfo`
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :Table, :RequestId
def initialize(table=nil, requestid=nil)
@Table = table
@RequestId = requestid
end
def deserialize(params)
unless params['Table'].nil?
@Table = TableResponseInfo.new
@Table.deserialize(params['Table'])
end
@RequestId = params['RequestId']
end
end
# DescribeTables请求参数结构体
class DescribeTablesRequest < TencentCloud::Common::AbstractModel
# @param DatabaseName: 列出该数据库下所属数据表。
# @type DatabaseName: String
# @param Limit: 返回数量，默认为10，最大值为100。
# @type Limit: Integer
# @param Offset: 数据偏移量，从0开始，默认为0。
# @type Offset: Integer
# @param Filters: 过滤条件，如下支持的过滤类型，传参Name应为其一
# table-name - String - （过滤条件）数据表名称,形如：table-001。
# table-id - String - （过滤条件）table id形如：12342。
# @type Filters: Array
# @param DatasourceConnectionName: 指定查询的数据源名称，默认为DataLakeCatalog
# @type DatasourceConnectionName: String
# @param StartTime: 起始时间：用于对更新时间的筛选
# @type StartTime: String
# @param EndTime: 终止时间：用于对更新时间的筛选
# @type EndTime: String
# @param Sort: 排序字段，支持：ModifiedTime（默认）；CreateTime
# @type Sort: String
# @param Asc: 排序字段，false：降序（默认）；true：升序
# @type Asc: Boolean
# @param TableType: table type，表类型查询,可用值:EXTERNAL_TABLE,INDEX_TABLE,MANAGED_TABLE,MATERIALIZED_VIEW,TABLE,VIEW,VIRTUAL_VIEW
# @type TableType: String
# @param TableFormat: 筛选字段-表格式：不传（默认）为查全部；LAKEFS：托管表；ICEBERG：非托管iceberg表；HIVE：非托管hive表；OTHER：非托管其它；
# @type TableFormat: String
attr_accessor :DatabaseName, :Limit, :Offset, :Filters, :DatasourceConnectionName, :StartTime, :EndTime, :Sort, :Asc, :TableType, :TableFormat
def initialize(databasename=nil, limit=nil, offset=nil, filters=nil, datasourceconnectionname=nil, starttime=nil, endtime=nil, sort=nil, asc=nil, tabletype=nil, tableformat=nil)
@DatabaseName = databasename
@Limit = limit
@Offset = offset
@Filters = filters
@DatasourceConnectionName = datasourceconnectionname
@StartTime = starttime
@EndTime = endtime
@Sort = sort
@Asc = asc
@TableType = tabletype
@TableFormat = tableformat
end
def deserialize(params)
@DatabaseName = params['DatabaseName']
@Limit = params['Limit']
@Offset = params['Offset']
unless params['Filters'].nil?
@Filters = []
params['Filters'].each do |i|
filter_tmp = Filter.new
filter_tmp.deserialize(i)
@Filters << filter_tmp
end
end
@DatasourceConnectionName = params['DatasourceConnectionName']
@StartTime = params['StartTime']
@EndTime = params['EndTime']
@Sort = params['Sort']
@Asc = params['Asc']
@TableType = params['TableType']
@TableFormat = params['TableFormat']
end
end
# DescribeTables返回参数结构体
class DescribeTablesResponse < TencentCloud::Common::AbstractModel
# @param TableList: 数据表对象列表。
# @type TableList: Array
# @param TotalCount: 实例总数。
# @type TotalCount: Integer
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :TableList, :TotalCount, :RequestId
def initialize(tablelist=nil, totalcount=nil, requestid=nil)
@TableList = tablelist
@TotalCount = totalcount
@RequestId = requestid
end
def deserialize(params)
unless params['TableList'].nil?
@TableList = []
params['TableList'].each do |i|
tableresponseinfo_tmp = TableResponseInfo.new
tableresponseinfo_tmp.deserialize(i)
@TableList << tableresponseinfo_tmp
end
end
@TotalCount = params['TotalCount']
@RequestId = params['RequestId']
end
end
# DescribeTaskResult请求参数结构体
class DescribeTaskResultRequest < TencentCloud::Common::AbstractModel
# @param TaskId: 任务唯一ID
# @type TaskId: String
# @param NextToken: 上一次请求响应返回的分页信息。第一次可以不带，从头开始返回数据，每次返回1000行数据。
# @type NextToken: String
# @param MaxResults: 返回结果的最大行数，范围0~1000，默认为1000.
# @type MaxResults: Integer
attr_accessor :TaskId, :NextToken, :MaxResults
def initialize(taskid=nil, nexttoken=nil, maxresults=nil)
@TaskId = taskid
@NextToken = nexttoken
@MaxResults = maxresults
end
def deserialize(params)
@TaskId = params['TaskId']
@NextToken = params['NextToken']
@MaxResults = params['MaxResults']
end
end
# DescribeTaskResult返回参数结构体
class DescribeTaskResultResponse < TencentCloud::Common::AbstractModel
# @param TaskInfo: 查询的任务信息，返回为空表示输入任务ID对应的任务不存在。只有当任务状态为成功（2）的时候，才会返回任务的结果。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type TaskInfo: :class:`Tencentcloud::Dlc.v20210125.models.TaskResultInfo`
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :TaskInfo, :RequestId
def initialize(taskinfo=nil, requestid=nil)
@TaskInfo = taskinfo
@RequestId = requestid
end
def deserialize(params)
unless params['TaskInfo'].nil?
@TaskInfo = TaskResultInfo.new
@TaskInfo.deserialize(params['TaskInfo'])
end
@RequestId = params['RequestId']
end
end
# DescribeTasks请求参数结构体
class DescribeTasksRequest < TencentCloud::Common::AbstractModel
# @param Limit: 返回数量，默认为10，最大值为100。
# @type Limit: Integer
# @param Offset: 偏移量，默认为0。
# @type Offset: Integer
# @param Filters: 过滤条件，如下支持的过滤类型，传参Name应为以下其中一个,其中task-id支持最大50个过滤个数，其他过滤参数支持的总数不超过5个。
# task-id - String - （任务ID准确过滤）task-id取值形如：e386471f-139a-4e59-877f-50ece8135b99。
# task-state - String - （任务状态过滤）取值范围 0(初始化)， 1(运行中)， 2(成功)， -1(失败)。
# task-sql-keyword - String - （SQL语句关键字模糊过滤）取值形如：DROP TABLE。
# task-operator- string （子uin过滤）
# task-kind - string （任务类型过滤）
# @type Filters: Array
# @param SortBy: 排序字段，支持如下字段类型，create-time（创建时间，默认）、update-time（更新时间）
# @type SortBy: String
# @param Sorting: 排序方式，desc表示正序，asc表示反序， 默认为asc。
# @type Sorting: String
# @param StartTime: 起始时间点，格式为yyyy-mm-dd HH:MM:SS。默认为45天前的当前时刻
# @type StartTime: String
# @param EndTime: 结束时间点，格式为yyyy-mm-dd HH:MM:SS时间跨度在(0,30天]，支持最近45天数据查询。默认为当前时刻
# @type EndTime: String
# @param DataEngineName: 支持计算资源名字筛选
# @type DataEngineName: String
attr_accessor :Limit, :Offset, :Filters, :SortBy, :Sorting, :StartTime, :EndTime, :DataEngineName
def initialize(limit=nil, offset=nil, filters=nil, sortby=nil, sorting=nil, starttime=nil, endtime=nil, dataenginename=nil)
@Limit = limit
@Offset = offset
@Filters = filters
@SortBy = sortby
@Sorting = sorting
@StartTime = starttime
@EndTime = endtime
@DataEngineName = dataenginename
end
def deserialize(params)
@Limit = params['Limit']
@Offset = params['Offset']
unless params['Filters'].nil?
@Filters = []
params['Filters'].each do |i|
filter_tmp = Filter.new
filter_tmp.deserialize(i)
@Filters << filter_tmp
end
end
@SortBy = params['SortBy']
@Sorting = params['Sorting']
@StartTime = params['StartTime']
@EndTime = params['EndTime']
@DataEngineName = params['DataEngineName']
end
end
# DescribeTasks返回参数结构体
class DescribeTasksResponse < TencentCloud::Common::AbstractModel
# @param TaskList: 任务对象列表。
# @type TaskList: Array
# @param TotalCount: 实例总数。
# @type TotalCount: Integer
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :TaskList, :TotalCount, :RequestId
def initialize(tasklist=nil, totalcount=nil, requestid=nil)
@TaskList = tasklist
@TotalCount = totalcount
@RequestId = requestid
end
def deserialize(params)
unless params['TaskList'].nil?
@TaskList = []
params['TaskList'].each do |i|
taskresponseinfo_tmp = TaskResponseInfo.new
taskresponseinfo_tmp.deserialize(i)
@TaskList << taskresponseinfo_tmp
end
end
@TotalCount = params['TotalCount']
@RequestId = params['RequestId']
end
end
# DescribeUsers请求参数结构体
class DescribeUsersRequest < TencentCloud::Common::AbstractModel
# @param UserId: 指定查询的子用户uin，用户需要通过CreateUser接口创建。
# @type UserId: String
# @param Offset: 偏移量，默认为0
# @type Offset: Integer
# @param Limit: 返回数量，默认20，最大值100
# @type Limit: Integer
# @param SortBy: 排序字段，支持如下字段类型，create-time
# @type SortBy: String
# @param Sorting: 排序方式，desc表示正序，asc表示反序， 默认为asc
# @type Sorting: String
# @param Filters: 过滤条件，支持如下字段类型，user-type：根据用户类型过滤。user-keyword：根据用户名称过滤
# @type Filters: Array
attr_accessor :UserId, :Offset, :Limit, :SortBy, :Sorting, :Filters
def initialize(userid=nil, offset=nil, limit=nil, sortby=nil, sorting=nil, filters=nil)
@UserId = userid
@Offset = offset
@Limit = limit
@SortBy = sortby
@Sorting = sorting
@Filters = filters
end
def deserialize(params)
@UserId = params['UserId']
@Offset = params['Offset']
@Limit = params['Limit']
@SortBy = params['SortBy']
@Sorting = params['Sorting']
unless params['Filters'].nil?
@Filters = []
params['Filters'].each do |i|
filter_tmp = Filter.new
filter_tmp.deserialize(i)
@Filters << filter_tmp
end
end
end
end
# DescribeUsers返回参数结构体
class DescribeUsersResponse < TencentCloud::Common::AbstractModel
# @param TotalCount: 查询到的用户总数
# @type TotalCount: Integer
# @param UserSet: 查询到的授权用户信息集合
# @type UserSet: Array
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :TotalCount, :UserSet, :RequestId
def initialize(totalcount=nil, userset=nil, requestid=nil)
@TotalCount = totalcount
@UserSet = userset
@RequestId = requestid
end
def deserialize(params)
@TotalCount = params['TotalCount']
unless params['UserSet'].nil?
@UserSet = []
params['UserSet'].each do |i|
userinfo_tmp = UserInfo.new
userinfo_tmp.deserialize(i)
@UserSet << userinfo_tmp
end
end
@RequestId = params['RequestId']
end
end
# DescribeViews请求参数结构体
class DescribeViewsRequest < TencentCloud::Common::AbstractModel
# @param DatabaseName: 列出该数据库下所属数据表。
# @type DatabaseName: String
# @param Limit: 返回数量，默认为10，最大值为100。
# @type Limit: Integer
# @param Offset: 数据偏移量，从0开始，默认为0。
# @type Offset: Integer
# @param Filters: 过滤条件，如下支持的过滤类型，传参Name应为其一
# view-name - String - （过滤条件）数据表名称,形如：view-001。
# view-id - String - （过滤条件）view id形如：12342。
# @type Filters: Array
# @param DatasourceConnectionName: 数据库所属的数据源名称
# @type DatasourceConnectionName: String
# @param Sort: 排序字段
# @type Sort: String
# @param Asc: 排序规则，true:升序；false:降序
# @type Asc: Boolean
# @param StartTime: 按视图更新时间筛选，开始时间，如2021-11-11 00:00:00
# @type StartTime: String
# @param EndTime: 按视图更新时间筛选，结束时间，如2021-11-12 00:00:00
# @type EndTime: String
attr_accessor :DatabaseName, :Limit, :Offset, :Filters, :DatasourceConnectionName, :Sort, :Asc, :StartTime, :EndTime
def initialize(databasename=nil, limit=nil, offset=nil, filters=nil, datasourceconnectionname=nil, sort=nil, asc=nil, starttime=nil, endtime=nil)
@DatabaseName = databasename
@Limit = limit
@Offset = offset
@Filters = filters
@DatasourceConnectionName = datasourceconnectionname
@Sort = sort
@Asc = asc
@StartTime = starttime
@EndTime = endtime
end
def deserialize(params)
@DatabaseName = params['DatabaseName']
@Limit = params['Limit']
@Offset = params['Offset']
unless params['Filters'].nil?
@Filters = []
params['Filters'].each do |i|
filter_tmp = Filter.new
filter_tmp.deserialize(i)
@Filters << filter_tmp
end
end
@DatasourceConnectionName = params['DatasourceConnectionName']
@Sort = params['Sort']
@Asc = params['Asc']
@StartTime = params['StartTime']
@EndTime = params['EndTime']
end
end
# DescribeViews返回参数结构体
class DescribeViewsResponse < TencentCloud::Common::AbstractModel
# @param ViewList: 视图对象列表。
# @type ViewList: Array
# @param TotalCount: 实例总数。
# @type TotalCount: Integer
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :ViewList, :TotalCount, :RequestId
def initialize(viewlist=nil, totalcount=nil, requestid=nil)
@ViewList = viewlist
@TotalCount = totalcount
@RequestId = requestid
end
def deserialize(params)
unless params['ViewList'].nil?
@ViewList = []
params['ViewList'].each do |i|
viewresponseinfo_tmp = ViewResponseInfo.new
viewresponseinfo_tmp.deserialize(i)
@ViewList << viewresponseinfo_tmp
end
end
@TotalCount = params['TotalCount']
@RequestId = params['RequestId']
end
end
# DescribeWorkGroups请求参数结构体
class DescribeWorkGroupsRequest < TencentCloud::Common::AbstractModel
# @param WorkGroupId: 查询的工作组Id，不填或填0表示不过滤。
# @type WorkGroupId: Integer
# @param Filters: 过滤条件，当前仅支持按照工作组名称进行模糊搜索。Key为workgroup-name
# @type Filters: Array
# @param Offset: 偏移量，默认为0
# @type Offset: Integer
# @param Limit: 返回数量，默认20，最大值100
# @type Limit: Integer
# @param SortBy: 排序字段，支持如下字段类型，create-time
# @type SortBy: String
# @param Sorting: 排序方式，desc表示正序，asc表示反序， 默认为asc
# @type Sorting: String
attr_accessor :WorkGroupId, :Filters, :Offset, :Limit, :SortBy, :Sorting
def initialize(workgroupid=nil, filters=nil, offset=nil, limit=nil, sortby=nil, sorting=nil)
@WorkGroupId = workgroupid
@Filters = filters
@Offset = offset
@Limit = limit
@SortBy = sortby
@Sorting = sorting
end
def deserialize(params)
@WorkGroupId = params['WorkGroupId']
unless params['Filters'].nil?
@Filters = []
params['Filters'].each do |i|
filter_tmp = Filter.new
filter_tmp.deserialize(i)
@Filters << filter_tmp
end
end
@Offset = params['Offset']
@Limit = params['Limit']
@SortBy = params['SortBy']
@Sorting = params['Sorting']
end
end
# DescribeWorkGroups返回参数结构体
class DescribeWorkGroupsResponse < TencentCloud::Common::AbstractModel
# @param TotalCount: 工作组总数
# @type TotalCount: Integer
# @param WorkGroupSet: 工作组信息集合
# @type WorkGroupSet: Array
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :TotalCount, :WorkGroupSet, :RequestId
def initialize(totalcount=nil, workgroupset=nil, requestid=nil)
@TotalCount = totalcount
@WorkGroupSet = workgroupset
@RequestId = requestid
end
def deserialize(params)
@TotalCount = params['TotalCount']
unless params['WorkGroupSet'].nil?
@WorkGroupSet = []
params['WorkGroupSet'].each do |i|
workgroupinfo_tmp = WorkGroupInfo.new
workgroupinfo_tmp.deserialize(i)
@WorkGroupSet << workgroupinfo_tmp
end
end
@RequestId = params['RequestId']
end
end
# DetachUserPolicy请求参数结构体
class DetachUserPolicyRequest < TencentCloud::Common::AbstractModel
# @param UserId: 用户Id，和CAM侧Uin匹配
# @type UserId: String
# @param PolicySet: 解绑的权限集合
# @type PolicySet: Array
attr_accessor :UserId, :PolicySet
def initialize(userid=nil, policyset=nil)
@UserId = userid
@PolicySet = policyset
end
def deserialize(params)
@UserId = params['UserId']
unless params['PolicySet'].nil?
@PolicySet = []
params['PolicySet'].each do |i|
policy_tmp = Policy.new
policy_tmp.deserialize(i)
@PolicySet << policy_tmp
end
end
end
end
# DetachUserPolicy返回参数结构体
class DetachUserPolicyResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# DetachWorkGroupPolicy请求参数结构体
class DetachWorkGroupPolicyRequest < TencentCloud::Common::AbstractModel
# @param WorkGroupId: 工作组Id
# @type WorkGroupId: Integer
# @param PolicySet: 解绑的权限集合
# @type PolicySet: Array
attr_accessor :WorkGroupId, :PolicySet
def initialize(workgroupid=nil, policyset=nil)
@WorkGroupId = workgroupid
@PolicySet = policyset
end
def deserialize(params)
@WorkGroupId = params['WorkGroupId']
unless params['PolicySet'].nil?
@PolicySet = []
params['PolicySet'].each do |i|
policy_tmp = Policy.new
policy_tmp.deserialize(i)
@PolicySet << policy_tmp
end
end
end
end
# DetachWorkGroupPolicy返回参数结构体
class DetachWorkGroupPolicyResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# DropDMSDatabase请求参数结构体
class DropDMSDatabaseRequest < TencentCloud::Common::AbstractModel
def initialize()
end
def deserialize(params)
end
end
# DropDMSDatabase返回参数结构体
class DropDMSDatabaseResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# DropDMSPartitions请求参数结构体
class DropDMSPartitionsRequest < TencentCloud::Common::AbstractModel
# @param DatabaseName: 数据库名称
# @type DatabaseName: String
# @param SchemaName: 数据库Schema名称
# @type SchemaName: String
# @param TableName: 数据表名称
# @type TableName: String
# @param Name: 分区名称
# @type Name: String
# @param Values: 单个分区名称
# @type Values: Array
# @param DeleteData: 是否删除分区数据
# @type DeleteData: Boolean
attr_accessor :DatabaseName, :SchemaName, :TableName, :Name, :Values, :DeleteData
def initialize(databasename=nil, schemaname=nil, tablename=nil, name=nil, values=nil, deletedata=nil)
@DatabaseName = databasename
@SchemaName = schemaname
@TableName = tablename
@Name = name
@Values = values
@DeleteData = deletedata
end
def deserialize(params)
@DatabaseName = params['DatabaseName']
@SchemaName = params['SchemaName']
@TableName = params['TableName']
@Name = params['Name']
@Values = params['Values']
@DeleteData = params['DeleteData']
end
end
# DropDMSPartitions返回参数结构体
class DropDMSPartitionsResponse < TencentCloud::Common::AbstractModel
# @param Status: 状态
# @type Status: Boolean
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :Status, :RequestId
def initialize(status=nil, requestid=nil)
@Status = status
@RequestId = requestid
end
def deserialize(params)
@Status = params['Status']
@RequestId = params['RequestId']
end
end
# DropDMSTable请求参数结构体
class DropDMSTableRequest < TencentCloud::Common::AbstractModel
# @param DbName: 数据库名称
# @type DbName: String
# @param Name: 表名称
# @type Name: String
# @param DeleteData: 是否删除数据
# @type DeleteData: Boolean
# @param EnvProps: 环境属性
# @type EnvProps: :class:`Tencentcloud::Dlc.v20210125.models.KVPair`
attr_accessor :DbName, :Name, :DeleteData, :EnvProps
def initialize(dbname=nil, name=nil, deletedata=nil, envprops=nil)
@DbName = dbname
@Name = name
@DeleteData = deletedata
@EnvProps = envprops
end
def deserialize(params)
@DbName = params['DbName']
@Name = params['Name']
@DeleteData = params['DeleteData']
unless params['EnvProps'].nil?
@EnvProps = KVPair.new
@EnvProps.deserialize(params['EnvProps'])
end
end
end
# DropDMSTable返回参数结构体
class DropDMSTableResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# SQL语句对象
class Execution < TencentCloud::Common::AbstractModel
# @param SQL: 自动生成SQL语句。
# @type SQL: String
attr_accessor :SQL
def initialize(sql=nil)
@SQL = sql
end
def deserialize(params)
@SQL = params['SQL']
end
end
# 查询列表过滤条件参数
class Filter < TencentCloud::Common::AbstractModel
# @param Name: 属性名称, 若存在多个Filter时，Filter间的关系为逻辑或（OR）关系。
# @type Name: String
# @param Values: 属性值, 若同一个Filter存在多个Values，同一Filter下Values间的关系为逻辑或（OR）关系。
# @type Values: Array
attr_accessor :Name, :Values
def initialize(name=nil, values=nil)
@Name = name
@Values = values
end
def deserialize(params)
@Name = params['Name']
@Values = params['Values']
end
end
# 日志详情
class JobLogResult < TencentCloud::Common::AbstractModel
# @param Time: 日志时间戳，毫秒
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Time: Integer
# @param TopicId: 日志topic id
# 注意：此字段可能返回 null，表示取不到有效值。
# @type TopicId: String
# @param TopicName: 日志topic name
# 注意：此字段可能返回 null，表示取不到有效值。
# @type TopicName: String
# @param LogJson: 日志内容，json字符串
# 注意：此字段可能返回 null，表示取不到有效值。
# @type LogJson: String
attr_accessor :Time, :TopicId, :TopicName, :LogJson
def initialize(time=nil, topicid=nil, topicname=nil, logjson=nil)
@Time = time
@TopicId = topicid
@TopicName = topicname
@LogJson = logjson
end
def deserialize(params)
@Time = params['Time']
@TopicId = params['TopicId']
@TopicName = params['TopicName']
@LogJson = params['LogJson']
end
end
# 配置格式
class KVPair < TencentCloud::Common::AbstractModel
# @param Key: 配置的key值
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Key: String
# @param Value: 配置的value值
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Value: String
attr_accessor :Key, :Value
def initialize(key=nil, value=nil)
@Key = key
@Value = value
end
def deserialize(params)
@Key = params['Key']
@Value = params['Value']
end
end
# ListTaskJobLogDetail请求参数结构体
class ListTaskJobLogDetailRequest < TencentCloud::Common::AbstractModel
# @param TaskId: 列表返回的Id
# @type TaskId: String
# @param StartTime: 开始运行时间，unix时间戳（毫秒）
# @type StartTime: Integer
# @param EndTime: 结束运行时间，unix时间戳（毫秒）
# @type EndTime: Integer
# @param Limit: 分页大小，最大100，配合Context一起使用
# @type Limit: Integer
# @param Context: 下一次分页参数，第一次传空
# @type Context: String
attr_accessor :TaskId, :StartTime, :EndTime, :Limit, :Context
def initialize(taskid=nil, starttime=nil, endtime=nil, limit=nil, context=nil)
@TaskId = taskid
@StartTime = starttime
@EndTime = endtime
@Limit = limit
@Context = context
end
def deserialize(params)
@TaskId = params['TaskId']
@StartTime = params['StartTime']
@EndTime = params['EndTime']
@Limit = params['Limit']
@Context = params['Context']
end
end
# ListTaskJobLogDetail返回参数结构体
class ListTaskJobLogDetailResponse < TencentCloud::Common::AbstractModel
# @param Context: 下一次分页参数
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Context: String
# @param ListOver: 是否获取完结
# 注意：此字段可能返回 null，表示取不到有效值。
# @type ListOver: Boolean
# @param Results: 日志详情
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Results: Array
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :Context, :ListOver, :Results, :RequestId
def initialize(context=nil, listover=nil, results=nil, requestid=nil)
@Context = context
@ListOver = listover
@Results = results
@RequestId = requestid
end
def deserialize(params)
@Context = params['Context']
@ListOver = params['ListOver']
unless params['Results'].nil?
@Results = []
params['Results'].each do |i|
joblogresult_tmp = JobLogResult.new
joblogresult_tmp.deserialize(i)
@Results << joblogresult_tmp
end
end
@RequestId = params['RequestId']
end
end
# 元数据加锁内容
class LockComponentInfo < TencentCloud::Common::AbstractModel
# @param DbName: 数据库名称
# @type DbName: String
# @param TableName: 表名称
# @type TableName: String
# @param Partition: 分区
# @type Partition: String
# @param LockType: 锁类型：SHARED_READ、SHARED_WRITE、EXCLUSIVE
# @type LockType: String
# @param LockLevel: 锁级别：DB、TABLE、PARTITION
# @type LockLevel: String
# @param DataOperationType: 锁操作：SELECT,INSERT,UPDATE,DELETE,UNSET,NO_TXN
# @type DataOperationType: String
# @param IsAcid: 是否保持Acid
# @type IsAcid: Boolean
# @param IsDynamicPartitionWrite: 是否动态分区写
# @type IsDynamicPartitionWrite: Boolean
attr_accessor :DbName, :TableName, :Partition, :LockType, :LockLevel, :DataOperationType, :IsAcid, :IsDynamicPartitionWrite
def initialize(dbname=nil, tablename=nil, partition=nil, locktype=nil, locklevel=nil, dataoperationtype=nil, isacid=nil, isdynamicpartitionwrite=nil)
@DbName = dbname
@TableName = tablename
@Partition = partition
@LockType = locktype
@LockLevel = locklevel
@DataOperationType = dataoperationtype
@IsAcid = isacid
@IsDynamicPartitionWrite = isdynamicpartitionwrite
end
def deserialize(params)
@DbName = params['DbName']
@TableName = params['TableName']
@Partition = params['Partition']
@LockType = params['LockType']
@LockLevel = params['LockLevel']
@DataOperationType = params['DataOperationType']
@IsAcid = params['IsAcid']
@IsDynamicPartitionWrite = params['IsDynamicPartitionWrite']
end
end
# LockMetaData请求参数结构体
class LockMetaDataRequest < TencentCloud::Common::AbstractModel
# @param LockComponentList: 加锁内容
# @type LockComponentList: Array
# @param DatasourceConnectionName: 数据源名称
# @type DatasourceConnectionName: String
# @param TxnId: 事务id
# @type TxnId: Integer
# @param AgentInfo: 客户端信息
# @type AgentInfo: String
# @param Hostname: 主机名
# @type Hostname: String
attr_accessor :LockComponentList, :DatasourceConnectionName, :TxnId, :AgentInfo, :Hostname
def initialize(lockcomponentlist=nil, datasourceconnectionname=nil, txnid=nil, agentinfo=nil, hostname=nil)
@LockComponentList = lockcomponentlist
@DatasourceConnectionName = datasourceconnectionname
@TxnId = txnid
@AgentInfo = agentinfo
@Hostname = hostname
end
def deserialize(params)
unless params['LockComponentList'].nil?
@LockComponentList = []
params['LockComponentList'].each do |i|
lockcomponentinfo_tmp = LockComponentInfo.new
lockcomponentinfo_tmp.deserialize(i)
@LockComponentList << lockcomponentinfo_tmp
end
end
@DatasourceConnectionName = params['DatasourceConnectionName']
@TxnId = params['TxnId']
@AgentInfo = params['AgentInfo']
@Hostname = params['Hostname']
end
end
# LockMetaData返回参数结构体
class LockMetaDataResponse < TencentCloud::Common::AbstractModel
# @param LockId: 锁id
# @type LockId: Integer
# @param LockState: 锁状态：ACQUIRED、WAITING、ABORT、NOT_ACQUIRED
# @type LockState: String
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :LockId, :LockState, :RequestId
def initialize(lockid=nil, lockstate=nil, requestid=nil)
@LockId = lockid
@LockState = lockstate
@RequestId = requestid
end
def deserialize(params)
@LockId = params['LockId']
@LockState = params['LockState']
@RequestId = params['RequestId']
end
end
# ModifySparkApp请求参数结构体
class ModifySparkAppRequest < TencentCloud::Common::AbstractModel
# @param AppName: spark应用名
# @type AppName: String
# @param AppType: 1代表spark jar应用，2代表spark streaming应用
# @type AppType: Integer
# @param DataEngine: 执行spark作业的数据引擎
# @type DataEngine: String
# @param AppFile: spark应用的执行入口
# @type AppFile: String
# @param RoleArn: 执行spark作业的角色ID
# @type RoleArn: Integer
# @param AppDriverSize: spark作业driver资源规格大小, 可取small,medium,large,xlarge
# @type AppDriverSize: String
# @param AppExecutorSize: spark作业executor资源规格大小, 可取small,medium,large,xlarge
# @type AppExecutorSize: String
# @param AppExecutorNums: spark作业executor个数
# @type AppExecutorNums: Integer
# @param SparkAppId: spark应用Id
# @type SparkAppId: String
# @param Eni: 该字段已下线，请使用字段Datasource
# @type Eni: String
# @param IsLocal: 是否本地上传，可取cos,lakefs
# @type IsLocal: String
# @param MainClass: spark jar作业时的主类
# @type MainClass: String
# @param AppConf: spark配置，以换行符分隔
# @type AppConf: String
# @param IsLocalJars: jar资源依赖上传方式，1、cos；2、lakefs（控制台使用，该方式不支持直接接口调用）
# @type IsLocalJars: String
# @param AppJars: spark jar作业依赖jars，以逗号分隔
# @type AppJars: String
# @param IsLocalFiles: file资源依赖上传方式，1、cos；2、lakefs（控制台使用，该方式不支持直接接口调用）
# @type IsLocalFiles: String
# @param AppFiles: spark作业依赖资源，以逗号分隔
# @type AppFiles: String
# @param IsLocalPythonFiles: pyspark：依赖上传方式，1、cos；2、lakefs（控制台使用，该方式不支持直接接口调用）
# @type IsLocalPythonFiles: String
# @param AppPythonFiles: pyspark：python依赖, 除py文件外，还支持zip/egg等归档格式，多文件以逗号分隔
# @type AppPythonFiles: String
# @param CmdArgs: spark作业命令行参数
# @type CmdArgs: String
# @param MaxRetries: 只对spark流任务生效
# @type MaxRetries: Integer
# @param DataSource: 数据源名
# @type DataSource: String
attr_accessor :AppName, :AppType, :DataEngine, :AppFile, :RoleArn, :AppDriverSize, :AppExecutorSize, :AppExecutorNums, :SparkAppId, :Eni, :IsLocal, :MainClass, :AppConf, :IsLocalJars, :AppJars, :IsLocalFiles, :AppFiles, :IsLocalPythonFiles, :AppPythonFiles, :CmdArgs, :MaxRetries, :DataSource
def initialize(appname=nil, apptype=nil, dataengine=nil, appfile=nil, rolearn=nil, appdriversize=nil, appexecutorsize=nil, appexecutornums=nil, sparkappid=nil, eni=nil, islocal=nil, mainclass=nil, appconf=nil, islocaljars=nil, appjars=nil, islocalfiles=nil, appfiles=nil, islocalpythonfiles=nil, apppythonfiles=nil, cmdargs=nil, maxretries=nil, datasource=nil)
@AppName = appname
@AppType = apptype
@DataEngine = dataengine
@AppFile = appfile
@RoleArn = rolearn
@AppDriverSize = appdriversize
@AppExecutorSize = appexecutorsize
@AppExecutorNums = appexecutornums
@SparkAppId = sparkappid
@Eni = eni
@IsLocal = islocal
@MainClass = mainclass
@AppConf = appconf
@IsLocalJars = islocaljars
@AppJars = appjars
@IsLocalFiles = islocalfiles
@AppFiles = appfiles
@IsLocalPythonFiles = islocalpythonfiles
@AppPythonFiles = apppythonfiles
@CmdArgs = cmdargs
@MaxRetries = maxretries
@DataSource = datasource
end
def deserialize(params)
@AppName = params['AppName']
@AppType = params['AppType']
@DataEngine = params['DataEngine']
@AppFile = params['AppFile']
@RoleArn = params['RoleArn']
@AppDriverSize = params['AppDriverSize']
@AppExecutorSize = params['AppExecutorSize']
@AppExecutorNums = params['AppExecutorNums']
@SparkAppId = params['SparkAppId']
@Eni = params['Eni']
@IsLocal = params['IsLocal']
@MainClass = params['MainClass']
@AppConf = params['AppConf']
@IsLocalJars = params['IsLocalJars']
@AppJars = params['AppJars']
@IsLocalFiles = params['IsLocalFiles']
@AppFiles = params['AppFiles']
@IsLocalPythonFiles = params['IsLocalPythonFiles']
@AppPythonFiles = params['AppPythonFiles']
@CmdArgs = params['CmdArgs']
@MaxRetries = params['MaxRetries']
@DataSource = params['DataSource']
end
end
# ModifySparkApp返回参数结构体
class ModifySparkAppResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# ModifyUser请求参数结构体
class ModifyUserRequest < TencentCloud::Common::AbstractModel
# @param UserId: 用户Id，和CAM侧Uin匹配
# @type UserId: String
# @param UserDescription: 用户描述
# @type UserDescription: String
attr_accessor :UserId, :UserDescription
def initialize(userid=nil, userdescription=nil)
@UserId = userid
@UserDescription = userdescription
end
def deserialize(params)
@UserId = params['UserId']
@UserDescription = params['UserDescription']
end
end
# ModifyUser返回参数结构体
class ModifyUserResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# ModifyWorkGroup请求参数结构体
class ModifyWorkGroupRequest < TencentCloud::Common::AbstractModel
# @param WorkGroupId: 工作组Id
# @type WorkGroupId: Integer
# @param WorkGroupDescription: 工作组描述
# @type WorkGroupDescription: String
attr_accessor :WorkGroupId, :WorkGroupDescription
def initialize(workgroupid=nil, workgroupdescription=nil)
@WorkGroupId = workgroupid
@WorkGroupDescription = workgroupdescription
end
def deserialize(params)
@WorkGroupId = params['WorkGroupId']
@WorkGroupDescription = params['WorkGroupDescription']
end
end
# ModifyWorkGroup返回参数结构体
class ModifyWorkGroupResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# 数据格式其它类型。
class Other < TencentCloud::Common::AbstractModel
# @param Format: 枚举类型，默认值为Json，可选值为[Json, Parquet, ORC, AVRD]之一。
# @type Format: String
attr_accessor :Format
def initialize(format=nil)
@Format = format
end
def deserialize(params)
@Format = params['Format']
end
end
# 数据表分块信息。
class Partition < TencentCloud::Common::AbstractModel
# @param Name: 分区列名。
# @type Name: String
# @param Type: 分区类型。
# @type Type: String
# @param Comment: 对分区的描述。
# @type Comment: String
# @param Transform: 隐式分区转换策略
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Transform: String
# @param TransformArgs: 转换策略参数
# 注意：此字段可能返回 null，表示取不到有效值。
# @type TransformArgs: Array
# @param CreateTime: 创建时间
# 注意：此字段可能返回 null，表示取不到有效值。
# @type CreateTime: Integer
attr_accessor :Name, :Type, :Comment, :Transform, :TransformArgs, :CreateTime
def initialize(name=nil, type=nil, comment=nil, transform=nil, transformargs=nil, createtime=nil)
@Name = name
@Type = type
@Comment = comment
@Transform = transform
@TransformArgs = transformargs
@CreateTime = createtime
end
def deserialize(params)
@Name = params['Name']
@Type = params['Type']
@Comment = params['Comment']
@Transform = params['Transform']
@TransformArgs = params['TransformArgs']
@CreateTime = params['CreateTime']
end
end
# 权限对象
class Policy < TencentCloud::Common::AbstractModel
# @param Database: 需要授权的数据库名，填*代表当前Catalog下所有数据库。当授权类型为管理员级别时，只允许填“*”，当授权类型为数据连接级别时只允许填空，其他类型下可以任意指定数据库。
# @type Database: String
# @param Catalog: 需要授权的数据源名称，管理员级别下只支持填*（代表该级别全部资源）；数据源级别和数据库级别鉴权的情况下，只支持填COSDataCatalog或者*；在数据表级别鉴权下可以填写用户自定义数据源。不填情况下默认为DataLakeCatalog。注意：如果是对用户自定义数据源进行鉴权，DLC能够管理的权限是用户接入数据源的时候提供的账户的子集。
# @type Catalog: String
# @param Table: 需要授权的表名，填*代表当前Database下所有表。当授权类型为管理员级别时，只允许填“*”，当授权类型为数据连接级别、数据库级别时只允许填空，其他类型下可以任意指定数据表。
# @type Table: String
# @param Operation: 授权的权限操作，对于不同级别的鉴权提供不同操作。管理员权限：ALL，不填默认为ALL；数据连接级鉴权：CREATE；数据库级别鉴权：ALL、CREATE、ALTER、DROP；数据表权限：ALL、SELECT、INSERT、ALTER、DELETE、DROP、UPDATE。注意：在数据表权限下，指定的数据源不为COSDataCatalog的时候，只支持SELECT操作。
# @type Operation: String
# @param PolicyType: 授权类型，现在支持八种授权类型：ADMIN:管理员级别鉴权 DATASOURCE：数据连接级别鉴权 DATABASE：数据库级别鉴权 TABLE：表级别鉴权 VIEW：视图级别鉴权 FUNCTION：函数级别鉴权 COLUMN：列级别鉴权 ENGINE：数据引擎鉴权。不填默认为管理员级别鉴权。
# @type PolicyType: String
# @param Function: 需要授权的函数名，填*代表当前Catalog下所有函数。当授权类型为管理员级别时，只允许填“*”，当授权类型为数据连接级别时只允许填空，其他类型下可以任意指定函数。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Function: String
# @param View: 需要授权的视图，填*代表当前Database下所有视图。当授权类型为管理员级别时，只允许填“*”，当授权类型为数据连接级别、数据库级别时只允许填空，其他类型下可以任意指定视图。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type View: String
# @param Column: 需要授权的列，填*代表当前所有列。当授权类型为管理员级别时，只允许填“*”
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Column: String
# @param DataEngine: 需要授权的数据引擎，填*代表当前所有引擎。当授权类型为管理员级别时，只允许填“*”
# 注意：此字段可能返回 null，表示取不到有效值。
# @type DataEngine: String
# @param ReAuth: 用户是否可以进行二次授权。当为true的时候，被授权的用户可以将本次获取的权限再次授权给其他子用户。默认为false
# 注意：此字段可能返回 null，表示取不到有效值。
# @type ReAuth: Boolean
# @param Source: 权限来源，入参不填。USER：权限来自用户本身；WORKGROUP：权限来自绑定的工作组
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Source: String
# @param Mode: 授权模式，入参不填。COMMON：普通模式；SENIOR：高级模式。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Mode: String
# @param Operator: 操作者，入参不填。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Operator: String
# @param CreateTime: 权限创建的时间，入参不填
# 注意：此字段可能返回 null，表示取不到有效值。
# @type CreateTime: String
# @param SourceId: 权限所属工作组的ID，只有当该权限的来源为工作组时才会有值。即仅当Source字段的值为WORKGROUP时该字段才有值。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type SourceId: Integer
# @param SourceName: 权限所属工作组的名称，只有当该权限的来源为工作组时才会有值。即仅当Source字段的值为WORKGROUP时该字段才有值。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type SourceName: String
attr_accessor :Database, :Catalog, :Table, :Operation, :PolicyType, :Function, :View, :Column, :DataEngine, :ReAuth, :Source, :Mode, :Operator, :CreateTime, :SourceId, :SourceName
def initialize(database=nil, catalog=nil, table=nil, operation=nil, policytype=nil, function=nil, view=nil, column=nil, dataengine=nil, reauth=nil, source=nil, mode=nil, operator=nil, createtime=nil, sourceid=nil, sourcename=nil)
@Database = database
@Catalog = catalog
@Table = table
@Operation = operation
@PolicyType = policytype
@Function = function
@View = view
@Column = column
@DataEngine = dataengine
@ReAuth = reauth
@Source = source
@Mode = mode
@Operator = operator
@CreateTime = createtime
@SourceId = sourceid
@SourceName = sourcename
end
def deserialize(params)
@Database = params['Database']
@Catalog = params['Catalog']
@Table = params['Table']
@Operation = params['Operation']
@PolicyType = params['PolicyType']
@Function = params['Function']
@View = params['View']
@Column = params['Column']
@DataEngine = params['DataEngine']
@ReAuth = params['ReAuth']
@Source = params['Source']
@Mode = params['Mode']
@Operator = params['Operator']
@CreateTime = params['CreateTime']
@SourceId = params['SourceId']
@SourceName = params['SourceName']
end
end
# 数据库和数据表属性信息
class Property < TencentCloud::Common::AbstractModel
# @param Key: 属性key名称。
# @type Key: String
# @param Value: 属性key对应的value。
# @type Value: String
attr_accessor :Key, :Value
def initialize(key=nil, value=nil)
@Key = key
@Value = value
end
def deserialize(params)
@Key = params['Key']
@Value = params['Value']
end
end
# SQL查询任务
class SQLTask < TencentCloud::Common::AbstractModel
# @param SQL: base64加密后的SQL语句
# @type SQL: String
# @param Config: 任务的配置信息
# @type Config: Array
attr_accessor :SQL, :Config
def initialize(sql=nil, config=nil)
@SQL = sql
@Config = config
end
def deserialize(params)
@SQL = params['SQL']
unless params['Config'].nil?
@Config = []
params['Config'].each do |i|
kvpair_tmp = KVPair.new
kvpair_tmp.deserialize(i)
@Config << kvpair_tmp
end
end
end
end
# script实例。
class Script < TencentCloud::Common::AbstractModel
# @param ScriptId: 脚本Id，长度36字节。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type ScriptId: String
# @param ScriptName: 脚本名称，长度0-25。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type ScriptName: String
# @param ScriptDesc: 脚本描述，长度0-50。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type ScriptDesc: String
# @param DatabaseName: 默认关联数据库。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type DatabaseName: String
# @param SQLStatement: SQL描述，长度0-10000。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type SQLStatement: String
# @param UpdateTime: 更新时间戳， 单位：ms。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type UpdateTime: Integer
attr_accessor :ScriptId, :ScriptName, :ScriptDesc, :DatabaseName, :SQLStatement, :UpdateTime
def initialize(scriptid=nil, scriptname=nil, scriptdesc=nil, databasename=nil, sqlstatement=nil, updatetime=nil)
@ScriptId = scriptid
@ScriptName = scriptname
@ScriptDesc = scriptdesc
@DatabaseName = databasename
@SQLStatement = sqlstatement
@UpdateTime = updatetime
end
def deserialize(params)
@ScriptId = params['ScriptId']
@ScriptName = params['ScriptName']
@ScriptDesc = params['ScriptDesc']
@DatabaseName = params['DatabaseName']
@SQLStatement = params['SQLStatement']
@UpdateTime = params['UpdateTime']
end
end
# spark作业详情
class SparkJobInfo < TencentCloud::Common::AbstractModel
# @param JobId: spark作业ID
# @type JobId: String
# @param JobName: spark作业名
# @type JobName: String
# @param JobType: spark作业类型，可去1或者2，1表示batch作业， 2表示streaming作业
# @type JobType: Integer
# @param DataEngine: 引擎名
# @type DataEngine: String
# @param Eni: 该字段已下线，请使用字段Datasource
# @type Eni: String
# @param IsLocal: 程序包是否本地上传，cos或者lakefs
# @type IsLocal: String
# @param JobFile: 程序包路径
# @type JobFile: String
# @param RoleArn: 角色ID
# @type RoleArn: Integer
# @param MainClass: spark作业运行主类
# @type MainClass: String
# @param CmdArgs: 命令行参数，spark作业命令行参数，空格分隔
# @type CmdArgs: String
# @param JobConf: spark原生配置，换行符分隔
# @type JobConf: String
# @param IsLocalJars: 依赖jars是否本地上传，cos或者lakefs
# @type IsLocalJars: String
# @param JobJars: spark作业依赖jars，逗号分隔
# @type JobJars: String
# @param IsLocalFiles: 依赖文件是否本地上传，cos或者lakefs
# @type IsLocalFiles: String
# @param JobFiles: spark作业依赖文件，逗号分隔
# @type JobFiles: String
# @param JobDriverSize: spark作业driver资源大小
# @type JobDriverSize: String
# @param JobExecutorSize: spark作业executor资源大小
# @type JobExecutorSize: String
# @param JobExecutorNums: spark作业executor个数
# @type JobExecutorNums: Integer
# @param JobMaxAttempts: spark流任务最大重试次数
# @type JobMaxAttempts: Integer
# @param JobCreator: spark作业创建者
# @type JobCreator: String
# @param JobCreateTime: spark作业创建时间
# @type JobCreateTime: Integer
# @param JobUpdateTime: spark作业更新时间
# @type JobUpdateTime: Integer
# @param CurrentTaskId: spark作业最近任务ID
# @type CurrentTaskId: String
# @param JobStatus: spark作业最近运行状态
# @type JobStatus: Integer
# @param StreamingStat: spark流作业统计
# 注意：此字段可能返回 null，表示取不到有效值。
# @type StreamingStat: :class:`Tencentcloud::Dlc.v20210125.models.StreamingStatistics`
# @param DataSource: 数据源名
# 注意：此字段可能返回 null，表示取不到有效值。
# @type DataSource: String
# @param IsLocalPythonFiles: pyspark：依赖上传方式，1、cos；2、lakefs（控制台使用，该方式不支持直接接口调用）
# 注意：此字段可能返回 null，表示取不到有效值。
# @type IsLocalPythonFiles: String
# @param AppPythonFiles: pyspark：python依赖, 除py文件外，还支持zip/egg等归档格式，多文件以逗号分隔
# 注意：此字段可能返回 null，表示取不到有效值。
# @type AppPythonFiles: String
attr_accessor :JobId, :JobName, :JobType, :DataEngine, :Eni, :IsLocal, :JobFile, :RoleArn, :MainClass, :CmdArgs, :JobConf, :IsLocalJars, :JobJars, :IsLocalFiles, :JobFiles, :JobDriverSize, :JobExecutorSize, :JobExecutorNums, :JobMaxAttempts, :JobCreator, :JobCreateTime, :JobUpdateTime, :CurrentTaskId, :JobStatus, :StreamingStat, :DataSource, :IsLocalPythonFiles, :AppPythonFiles
def initialize(jobid=nil, jobname=nil, jobtype=nil, dataengine=nil, eni=nil, islocal=nil, jobfile=nil, rolearn=nil, mainclass=nil, cmdargs=nil, jobconf=nil, islocaljars=nil, jobjars=nil, islocalfiles=nil, jobfiles=nil, jobdriversize=nil, jobexecutorsize=nil, jobexecutornums=nil, jobmaxattempts=nil, jobcreator=nil, jobcreatetime=nil, jobupdatetime=nil, currenttaskid=nil, jobstatus=nil, streamingstat=nil, datasource=nil, islocalpythonfiles=nil, apppythonfiles=nil)
@JobId = jobid
@JobName = jobname
@JobType = jobtype
@DataEngine = dataengine
@Eni = eni
@IsLocal = islocal
@JobFile = jobfile
@RoleArn = rolearn
@MainClass = mainclass
@CmdArgs = cmdargs
@JobConf = jobconf
@IsLocalJars = islocaljars
@JobJars = jobjars
@IsLocalFiles = islocalfiles
@JobFiles = jobfiles
@JobDriverSize = jobdriversize
@JobExecutorSize = jobexecutorsize
@JobExecutorNums = jobexecutornums
@JobMaxAttempts = jobmaxattempts
@JobCreator = jobcreator
@JobCreateTime = jobcreatetime
@JobUpdateTime = jobupdatetime
@CurrentTaskId = currenttaskid
@JobStatus = jobstatus
@StreamingStat = streamingstat
@DataSource = datasource
@IsLocalPythonFiles = islocalpythonfiles
@AppPythonFiles = apppythonfiles
end
def deserialize(params)
@JobId = params['JobId']
@JobName = params['JobName']
@JobType = params['JobType']
@DataEngine = params['DataEngine']
@Eni = params['Eni']
@IsLocal = params['IsLocal']
@JobFile = params['JobFile']
@RoleArn = params['RoleArn']
@MainClass = params['MainClass']
@CmdArgs = params['CmdArgs']
@JobConf = params['JobConf']
@IsLocalJars = params['IsLocalJars']
@JobJars = params['JobJars']
@IsLocalFiles = params['IsLocalFiles']
@JobFiles = params['JobFiles']
@JobDriverSize = params['JobDriverSize']
@JobExecutorSize = params['JobExecutorSize']
@JobExecutorNums = params['JobExecutorNums']
@JobMaxAttempts = params['JobMaxAttempts']
@JobCreator = params['JobCreator']
@JobCreateTime = params['JobCreateTime']
@JobUpdateTime = params['JobUpdateTime']
@CurrentTaskId = params['CurrentTaskId']
@JobStatus = params['JobStatus']
unless params['StreamingStat'].nil?
@StreamingStat = StreamingStatistics.new
@StreamingStat.deserialize(params['StreamingStat'])
end
@DataSource = params['DataSource']
@IsLocalPythonFiles = params['IsLocalPythonFiles']
@AppPythonFiles = params['AppPythonFiles']
end
end
# spark流任务统计信息
class StreamingStatistics < TencentCloud::Common::AbstractModel
# @param StartTime: 任务开始时间
# @type StartTime: String
# @param Receivers: 数据接收器数
# @type Receivers: Integer
# @param NumActiveReceivers: 运行中的接收器数
# @type NumActiveReceivers: Integer
# @param NumInactiveReceivers: 不活跃的接收器数
# @type NumInactiveReceivers: Integer
# @param NumActiveBatches: 运行中的批数
# @type NumActiveBatches: Integer
# @param NumRetainedCompletedBatches: 待处理的批数
# @type NumRetainedCompletedBatches: Integer
# @param NumTotalCompletedBatches: 已完成的批数
# @type NumTotalCompletedBatches: Integer
# @param AverageInputRate: 平均输入速率
# @type AverageInputRate: Float
# @param AverageSchedulingDelay: 平均等待时长
# @type AverageSchedulingDelay: Float
# @param AverageProcessingTime: 平均处理时长
# @type AverageProcessingTime: Float
# @param AverageTotalDelay: 平均延时
# @type AverageTotalDelay: Float
attr_accessor :StartTime, :Receivers, :NumActiveReceivers, :NumInactiveReceivers, :NumActiveBatches, :NumRetainedCompletedBatches, :NumTotalCompletedBatches, :AverageInputRate, :AverageSchedulingDelay, :AverageProcessingTime, :AverageTotalDelay
def initialize(starttime=nil, receivers=nil, numactivereceivers=nil, numinactivereceivers=nil, numactivebatches=nil, numretainedcompletedbatches=nil, numtotalcompletedbatches=nil, averageinputrate=nil, averageschedulingdelay=nil, averageprocessingtime=nil, averagetotaldelay=nil)
@StartTime = starttime
@Receivers = receivers
@NumActiveReceivers = numactivereceivers
@NumInactiveReceivers = numinactivereceivers
@NumActiveBatches = numactivebatches
@NumRetainedCompletedBatches = numretainedcompletedbatches
@NumTotalCompletedBatches = numtotalcompletedbatches
@AverageInputRate = averageinputrate
@AverageSchedulingDelay = averageschedulingdelay
@AverageProcessingTime = averageprocessingtime
@AverageTotalDelay = averagetotaldelay
end
def deserialize(params)
@StartTime = params['StartTime']
@Receivers = params['Receivers']
@NumActiveReceivers = params['NumActiveReceivers']
@NumInactiveReceivers = params['NumInactiveReceivers']
@NumActiveBatches = params['NumActiveBatches']
@NumRetainedCompletedBatches = params['NumRetainedCompletedBatches']
@NumTotalCompletedBatches = params['NumTotalCompletedBatches']
@AverageInputRate = params['AverageInputRate']
@AverageSchedulingDelay = params['AverageSchedulingDelay']
@AverageProcessingTime = params['AverageProcessingTime']
@AverageTotalDelay = params['AverageTotalDelay']
end
end
# 数据表配置信息
class TableBaseInfo < TencentCloud::Common::AbstractModel
# @param DatabaseName: 该数据表所属数据库名字
# @type DatabaseName: String
# @param TableName: 数据表名字
# @type TableName: String
# @param DatasourceConnectionName: 该数据表所属数据源名字
# 注意：此字段可能返回 null，表示取不到有效值。
# @type DatasourceConnectionName: String
# @param TableComment: 该数据表备注
# 注意：此字段可能返回 null，表示取不到有效值。
# @type TableComment: String
# @param Type: 具体类型，表or视图
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Type: String
# @param TableFormat: 数据格式类型，hive，iceberg等
# 注意：此字段可能返回 null，表示取不到有效值。
# @type TableFormat: String
attr_accessor :DatabaseName, :TableName, :DatasourceConnectionName, :TableComment, :Type, :TableFormat
def initialize(databasename=nil, tablename=nil, datasourceconnectionname=nil, tablecomment=nil, type=nil, tableformat=nil)
@DatabaseName = databasename
@TableName = tablename
@DatasourceConnectionName = datasourceconnectionname
@TableComment = tablecomment
@Type = type
@TableFormat = tableformat
end
def deserialize(params)
@DatabaseName = params['DatabaseName']
@TableName = params['TableName']
@DatasourceConnectionName = params['DatasourceConnectionName']
@TableComment = params['TableComment']
@Type = params['Type']
@TableFormat = params['TableFormat']
end
end
# 返回数据表的相关信息。
class TableInfo < TencentCloud::Common::AbstractModel
# @param TableBaseInfo: 数据表配置信息。
# @type TableBaseInfo: :class:`Tencentcloud::Dlc.v20210125.models.TableBaseInfo`
# @param DataFormat: 数据表格式。每次入参可选如下其一的KV结构，[TextFile，CSV，Json, Parquet, ORC, AVRD]。
# @type DataFormat: :class:`Tencentcloud::Dlc.v20210125.models.DataFormat`
# @param Columns: 数据表列信息。
# @type Columns: Array
# @param Partitions: 数据表分块信息。
# @type Partitions: Array
# @param Location: 数据存储路径。当前仅支持cos路径，格式如下：cosn://bucket-name/filepath。
# @type Location: String
attr_accessor :TableBaseInfo, :DataFormat, :Columns, :Partitions, :Location
def initialize(tablebaseinfo=nil, dataformat=nil, columns=nil, partitions=nil, location=nil)
@TableBaseInfo = tablebaseinfo
@DataFormat = dataformat
@Columns = columns
@Partitions = partitions
@Location = location
end
def deserialize(params)
unless params['TableBaseInfo'].nil?
@TableBaseInfo = TableBaseInfo.new
@TableBaseInfo.deserialize(params['TableBaseInfo'])
end
unless params['DataFormat'].nil?
@DataFormat = DataFormat.new
@DataFormat.deserialize(params['DataFormat'])
end
unless params['Columns'].nil?
@Columns = []
params['Columns'].each do |i|
column_tmp = Column.new
column_tmp.deserialize(i)
@Columns << column_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
@Location = params['Location']
end
end
# 查询表信息对象
class TableResponseInfo < TencentCloud::Common::AbstractModel
# @param TableBaseInfo: 数据表基本信息。
# @type TableBaseInfo: :class:`Tencentcloud::Dlc.v20210125.models.TableBaseInfo`
# @param Columns: 数据表列信息。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Columns: Array
# @param Partitions: 数据表分块信息。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Partitions: Array
# @param Location: 数据存储路径。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Location: String
# @param Properties: 数据表属性信息。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Properties: Array
# @param ModifiedTime: 数据表更新时间, 单位: ms。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type ModifiedTime: String
# @param CreateTime: 数据表创建时间,单位: ms。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type CreateTime: String
# @param InputFormat: 数据格式。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type InputFormat: String
# @param StorageSize: 数据表存储大小（单位：Byte）
# 注意：此字段可能返回 null，表示取不到有效值。
# @type StorageSize: Integer
# @param RecordCount: 数据表行数
# 注意：此字段可能返回 null，表示取不到有效值。
# @type RecordCount: Integer
attr_accessor :TableBaseInfo, :Columns, :Partitions, :Location, :Properties, :ModifiedTime, :CreateTime, :InputFormat, :StorageSize, :RecordCount
def initialize(tablebaseinfo=nil, columns=nil, partitions=nil, location=nil, properties=nil, modifiedtime=nil, createtime=nil, inputformat=nil, storagesize=nil, recordcount=nil)
@TableBaseInfo = tablebaseinfo
@Columns = columns
@Partitions = partitions
@Location = location
@Properties = properties
@ModifiedTime = modifiedtime
@CreateTime = createtime
@InputFormat = inputformat
@StorageSize = storagesize
@RecordCount = recordcount
end
def deserialize(params)
unless params['TableBaseInfo'].nil?
@TableBaseInfo = TableBaseInfo.new
@TableBaseInfo.deserialize(params['TableBaseInfo'])
end
unless params['Columns'].nil?
@Columns = []
params['Columns'].each do |i|
column_tmp = Column.new
column_tmp.deserialize(i)
@Columns << column_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
@Location = params['Location']
unless params['Properties'].nil?
@Properties = []
params['Properties'].each do |i|
property_tmp = Property.new
property_tmp.deserialize(i)
@Properties << property_tmp
end
end
@ModifiedTime = params['ModifiedTime']
@CreateTime = params['CreateTime']
@InputFormat = params['InputFormat']
@StorageSize = params['StorageSize']
@RecordCount = params['RecordCount']
end
end
# 任务类型，任务如SQL查询等。
class Task < TencentCloud::Common::AbstractModel
# @param SQLTask: SQL查询任务
# @type SQLTask: :class:`Tencentcloud::Dlc.v20210125.models.SQLTask`
# @param SparkSQLTask: Spark SQL查询任务
# @type SparkSQLTask: :class:`Tencentcloud::Dlc.v20210125.models.SQLTask`
attr_accessor :SQLTask, :SparkSQLTask
def initialize(sqltask=nil, sparksqltask=nil)
@SQLTask = sqltask
@SparkSQLTask = sparksqltask
end
def deserialize(params)
unless params['SQLTask'].nil?
@SQLTask = SQLTask.new
@SQLTask.deserialize(params['SQLTask'])
end
unless params['SparkSQLTask'].nil?
@SparkSQLTask = SQLTask.new
@SparkSQLTask.deserialize(params['SparkSQLTask'])
end
end
end
# 任务实例
class TaskResponseInfo < TencentCloud::Common::AbstractModel
# @param DatabaseName: 任务所属Database的名称。
# @type DatabaseName: String
# @param DataAmount: 任务数据量。
# @type DataAmount: Integer
# @param Id: 任务Id。
# @type Id: String
# @param UsedTime: 计算时长，单位： ms。
# @type UsedTime: Integer
# @param OutputPath: 任务输出路径。
# @type OutputPath: String
# @param CreateTime: 任务创建时间。
# @type CreateTime: String
# @param State: 任务状态：0 初始化， 1 执行中， 2 执行成功，-1 执行失败，-3 已取消。
# @type State: Integer
# @param SQLType: 任务SQL类型，DDL|DML等
# @type SQLType: String
# @param SQL: 任务SQL语句
# @type SQL: String
# @param ResultExpired: 结果是否过期。
# @type ResultExpired: Boolean
# @param RowAffectInfo: 数据影响统计信息。
# @type RowAffectInfo: String
# @param DataSet: 任务结果数据表。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type DataSet: String
# @param Error: 失败信息, 例如：errorMessage。该字段已废弃。
# @type Error: String
# @param Percentage: 任务执行进度num/100(%)
# @type Percentage: Integer
# @param OutputMessage: 任务执行输出信息。
# @type OutputMessage: String
# @param TaskType: 执行SQL的引擎类型
# @type TaskType: String
# @param ProgressDetail: 任务进度明细
# 注意：此字段可能返回 null，表示取不到有效值。
# @type ProgressDetail: String
# @param UpdateTime: 任务结束时间
# 注意：此字段可能返回 null，表示取不到有效值。
# @type UpdateTime: String
# @param DataEngineId: 计算资源id
# 注意：此字段可能返回 null，表示取不到有效值。
# @type DataEngineId: String
# @param OperateUin: 执行sql的子uin
# 注意：此字段可能返回 null，表示取不到有效值。
# @type OperateUin: String
# @param DataEngineName: 计算资源名字
# 注意：此字段可能返回 null，表示取不到有效值。
# @type DataEngineName: String
# @param InputType: 导入类型是本地导入还是cos
# 注意：此字段可能返回 null，表示取不到有效值。
# @type InputType: String
# @param InputConf: 导入配置
# 注意：此字段可能返回 null，表示取不到有效值。
# @type InputConf: String
# @param DataNumber: 数据条数
# 注意：此字段可能返回 null，表示取不到有效值。
# @type DataNumber: Integer
# @param CanDownload: 查询数据能不能下载
# 注意：此字段可能返回 null，表示取不到有效值。
# @type CanDownload: Boolean
# @param UserAlias: 用户别名
# 注意：此字段可能返回 null，表示取不到有效值。
# @type UserAlias: String
# @param SparkJobName: spark应用作业名
# 注意：此字段可能返回 null，表示取不到有效值。
# @type SparkJobName: String
# @param SparkJobId: spark应用作业Id
# 注意：此字段可能返回 null，表示取不到有效值。
# @type SparkJobId: String
# @param SparkJobFile: spark应用入口jar文件
# 注意：此字段可能返回 null，表示取不到有效值。
# @type SparkJobFile: String
# @param UiUrl: spark ui url
# 注意：此字段可能返回 null，表示取不到有效值。
# @type UiUrl: String
attr_accessor :DatabaseName, :DataAmount, :Id, :UsedTime, :OutputPath, :CreateTime, :State, :SQLType, :SQL, :ResultExpired, :RowAffectInfo, :DataSet, :Error, :Percentage, :OutputMessage, :TaskType, :ProgressDetail, :UpdateTime, :DataEngineId, :OperateUin, :DataEngineName, :InputType, :InputConf, :DataNumber, :CanDownload, :UserAlias, :SparkJobName, :SparkJobId, :SparkJobFile, :UiUrl
def initialize(databasename=nil, dataamount=nil, id=nil, usedtime=nil, outputpath=nil, createtime=nil, state=nil, sqltype=nil, sql=nil, resultexpired=nil, rowaffectinfo=nil, dataset=nil, error=nil, percentage=nil, outputmessage=nil, tasktype=nil, progressdetail=nil, updatetime=nil, dataengineid=nil, operateuin=nil, dataenginename=nil, inputtype=nil, inputconf=nil, datanumber=nil, candownload=nil, useralias=nil, sparkjobname=nil, sparkjobid=nil, sparkjobfile=nil, uiurl=nil)
@DatabaseName = databasename
@DataAmount = dataamount
@Id = id
@UsedTime = usedtime
@OutputPath = outputpath
@CreateTime = createtime
@State = state
@SQLType = sqltype
@SQL = sql
@ResultExpired = resultexpired
@RowAffectInfo = rowaffectinfo
@DataSet = dataset
@Error = error
@Percentage = percentage
@OutputMessage = outputmessage
@TaskType = tasktype
@ProgressDetail = progressdetail
@UpdateTime = updatetime
@DataEngineId = dataengineid
@OperateUin = operateuin
@DataEngineName = dataenginename
@InputType = inputtype
@InputConf = inputconf
@DataNumber = datanumber
@CanDownload = candownload
@UserAlias = useralias
@SparkJobName = sparkjobname
@SparkJobId = sparkjobid
@SparkJobFile = sparkjobfile
@UiUrl = uiurl
end
def deserialize(params)
@DatabaseName = params['DatabaseName']
@DataAmount = params['DataAmount']
@Id = params['Id']
@UsedTime = params['UsedTime']
@OutputPath = params['OutputPath']
@CreateTime = params['CreateTime']
@State = params['State']
@SQLType = params['SQLType']
@SQL = params['SQL']
@ResultExpired = params['ResultExpired']
@RowAffectInfo = params['RowAffectInfo']
@DataSet = params['DataSet']
@Error = params['Error']
@Percentage = params['Percentage']
@OutputMessage = params['OutputMessage']
@TaskType = params['TaskType']
@ProgressDetail = params['ProgressDetail']
@UpdateTime = params['UpdateTime']
@DataEngineId = params['DataEngineId']
@OperateUin = params['OperateUin']
@DataEngineName = params['DataEngineName']
@InputType = params['InputType']
@InputConf = params['InputConf']
@DataNumber = params['DataNumber']
@CanDownload = params['CanDownload']
@UserAlias = params['UserAlias']
@SparkJobName = params['SparkJobName']
@SparkJobId = params['SparkJobId']
@SparkJobFile = params['SparkJobFile']
@UiUrl = params['UiUrl']
end
end
# 任务结果信息
class TaskResultInfo < TencentCloud::Common::AbstractModel
# @param TaskId: 任务唯一ID
# @type TaskId: String
# @param DatasourceConnectionName: 数据源名称，当前任务执行时候选中的默认数据源
# 注意：此字段可能返回 null，表示取不到有效值。
# @type DatasourceConnectionName: String
# @param DatabaseName: 数据库名称，当前任务执行时候选中的默认数据库
# 注意：此字段可能返回 null，表示取不到有效值。
# @type DatabaseName: String
# @param SQL: 当前执行的SQL，一个任务包含一个SQL
# @type SQL: String
# @param SQLType: 执行任务的类型，现在分为DDL、DML、DQL
# @type SQLType: String
# @param State: 任务当前的状态，0：初始化 1：任务运行中 2：任务执行成功 -1：任务执行失败 -3：用户手动终止。只有任务执行成功的情况下，才会返回任务执行的结果
# @type State: Integer
# @param DataAmount: 扫描的数据量，单位byte
# @type DataAmount: Integer
# @param UsedTime: 任务执行耗时，单位秒
# @type UsedTime: Integer
# @param OutputPath: 任务结果输出的COS桶地址
# @type OutputPath: String
# @param CreateTime: 任务创建时间，时间戳
# @type CreateTime: String
# @param OutputMessage: 任务执行信息，成功时返回success，失败时返回失败原因
# @type OutputMessage: String
# @param RowAffectInfo: 被影响的行数
# @type RowAffectInfo: String
# @param ResultSchema: 结果的schema信息
# 注意：此字段可能返回 null，表示取不到有效值。
# @type ResultSchema: Array
# @param ResultSet: 结果信息，反转义后，外层数组的每个元素为一行数据
# 注意：此字段可能返回 null，表示取不到有效值。
# @type ResultSet: String
# @param NextToken: 分页信息，如果没有更多结果数据，nextToken为空
# @type NextToken: String
# @param Percentage: 任务执行进度num/100(%)
# @type Percentage: Integer
# @param ProgressDetail: 任务进度明细
# @type ProgressDetail: String
# @param DisplayFormat: 控制台展示格式。table：表格展示 text：文本展示
# @type DisplayFormat: String
attr_accessor :TaskId, :DatasourceConnectionName, :DatabaseName, :SQL, :SQLType, :State, :DataAmount, :UsedTime, :OutputPath, :CreateTime, :OutputMessage, :RowAffectInfo, :ResultSchema, :ResultSet, :NextToken, :Percentage, :ProgressDetail, :DisplayFormat
def initialize(taskid=nil, datasourceconnectionname=nil, databasename=nil, sql=nil, sqltype=nil, state=nil, dataamount=nil, usedtime=nil, outputpath=nil, createtime=nil, outputmessage=nil, rowaffectinfo=nil, resultschema=nil, resultset=nil, nexttoken=nil, percentage=nil, progressdetail=nil, displayformat=nil)
@TaskId = taskid
@DatasourceConnectionName = datasourceconnectionname
@DatabaseName = databasename
@SQL = sql
@SQLType = sqltype
@State = state
@DataAmount = dataamount
@UsedTime = usedtime
@OutputPath = outputpath
@CreateTime = createtime
@OutputMessage = outputmessage
@RowAffectInfo = rowaffectinfo
@ResultSchema = resultschema
@ResultSet = resultset
@NextToken = nexttoken
@Percentage = percentage
@ProgressDetail = progressdetail
@DisplayFormat = displayformat
end
def deserialize(params)
@TaskId = params['TaskId']
@DatasourceConnectionName = params['DatasourceConnectionName']
@DatabaseName = params['DatabaseName']
@SQL = params['SQL']
@SQLType = params['SQLType']
@State = params['State']
@DataAmount = params['DataAmount']
@UsedTime = params['UsedTime']
@OutputPath = params['OutputPath']
@CreateTime = params['CreateTime']
@OutputMessage = params['OutputMessage']
@RowAffectInfo = params['RowAffectInfo']
unless params['ResultSchema'].nil?
@ResultSchema = []
params['ResultSchema'].each do |i|
column_tmp = Column.new
column_tmp.deserialize(i)
@ResultSchema << column_tmp
end
end
@ResultSet = params['ResultSet']
@NextToken = params['NextToken']
@Percentage = params['Percentage']
@ProgressDetail = params['ProgressDetail']
@DisplayFormat = params['DisplayFormat']
end
end
# 批量顺序执行任务集合
class TasksInfo < TencentCloud::Common::AbstractModel
# @param TaskType: 任务类型，SQLTask：SQL查询任务。SparkSQLTask：Spark SQL查询任务
# @type TaskType: String
# @param FailureTolerance: 容错策略。Proceed：前面任务出错/取消后继续执行后面的任务。Terminate：前面的任务出错/取消之后终止后面任务的执行，后面的任务全部标记为已取消。
# @type FailureTolerance: String
# @param SQL: base64加密后的SQL语句，用";"号分隔每个SQL语句，一次最多提交50个任务。严格按照前后顺序执行
# @type SQL: String
# @param Config: 任务的配置信息，当前仅支持SparkSQLTask任务。
# @type Config: Array
# @param Params: 任务的用户自定义参数信息
# @type Params: Array
attr_accessor :TaskType, :FailureTolerance, :SQL, :Config, :Params
def initialize(tasktype=nil, failuretolerance=nil, sql=nil, config=nil, params=nil)
@TaskType = tasktype
@FailureTolerance = failuretolerance
@SQL = sql
@Config = config
@Params = params
end
def deserialize(params)
@TaskType = params['TaskType']
@FailureTolerance = params['FailureTolerance']
@SQL = params['SQL']
unless params['Config'].nil?
@Config = []
params['Config'].each do |i|
kvpair_tmp = KVPair.new
kvpair_tmp.deserialize(i)
@Config << kvpair_tmp
end
end
unless params['Params'].nil?
@Params = []
params['Params'].each do |i|
kvpair_tmp = KVPair.new
kvpair_tmp.deserialize(i)
@Params << kvpair_tmp
end
end
end
end
# 文本格式
class TextFile < TencentCloud::Common::AbstractModel
# @param Format: 文本类型，本参数取值为TextFile。
# @type Format: String
# @param Regex: 处理文本用的正则表达式。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Regex: String
attr_accessor :Format, :Regex
def initialize(format=nil, regex=nil)
@Format = format
@Regex = regex
end
def deserialize(params)
@Format = params['Format']
@Regex = params['Regex']
end
end
# UnbindWorkGroupsFromUser请求参数结构体
class UnbindWorkGroupsFromUserRequest < TencentCloud::Common::AbstractModel
# @param AddInfo: 解绑的工作组Id和用户Id的关联关系
# @type AddInfo: :class:`Tencentcloud::Dlc.v20210125.models.WorkGroupIdSetOfUserId`
attr_accessor :AddInfo
def initialize(addinfo=nil)
@AddInfo = addinfo
end
def deserialize(params)
unless params['AddInfo'].nil?
@AddInfo = WorkGroupIdSetOfUserId.new
@AddInfo.deserialize(params['AddInfo'])
end
end
end
# UnbindWorkGroupsFromUser返回参数结构体
class UnbindWorkGroupsFromUserResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# UnlockMetaData请求参数结构体
class UnlockMetaDataRequest < TencentCloud::Common::AbstractModel
# @param LockId: 锁ID
# @type LockId: Integer
# @param DatasourceConnectionName: 数据源名称
# @type DatasourceConnectionName: String
attr_accessor :LockId, :DatasourceConnectionName
def initialize(lockid=nil, datasourceconnectionname=nil)
@LockId = lockid
@DatasourceConnectionName = datasourceconnectionname
end
def deserialize(params)
@LockId = params['LockId']
@DatasourceConnectionName = params['DatasourceConnectionName']
end
end
# UnlockMetaData返回参数结构体
class UnlockMetaDataResponse < TencentCloud::Common::AbstractModel
# @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
# @type RequestId: String
attr_accessor :RequestId
def initialize(requestid=nil)
@RequestId = requestid
end
def deserialize(params)
@RequestId = params['RequestId']
end
end
# 绑定到同一个工作组的用户Id的集合
class UserIdSetOfWorkGroupId < TencentCloud::Common::AbstractModel
# @param WorkGroupId: 工作组Id
# @type WorkGroupId: Integer
# @param UserIds: 用户Id集合，和CAM侧Uin匹配
# @type UserIds: Array
attr_accessor :WorkGroupId, :UserIds
def initialize(workgroupid=nil, userids=nil)
@WorkGroupId = workgroupid
@UserIds = userids
end
def deserialize(params)
@WorkGroupId = params['WorkGroupId']
@UserIds = params['UserIds']
end
end
# 授权用户信息
class UserInfo < TencentCloud::Common::AbstractModel
# @param UserId: 用户Id，和子用户uin相同
# @type UserId: String
# @param UserDescription: 用户描述信息，方便区分不同用户
# 注意：此字段可能返回 null，表示取不到有效值。
# @type UserDescription: String
# @param PolicySet: 单独给用户绑定的权限集合
# 注意：此字段可能返回 null，表示取不到有效值。
# @type PolicySet: Array
# @param Creator: 当前用户的创建者
# @type Creator: String
# @param CreateTime: 创建时间，格式如2021-07-28 16:19:32
# @type CreateTime: String
# @param WorkGroupSet: 关联的工作组集合
# 注意：此字段可能返回 null，表示取不到有效值。
# @type WorkGroupSet: Array
# @param IsOwner: 是否是主账号
# 注意：此字段可能返回 null，表示取不到有效值。
# @type IsOwner: Boolean
# @param UserType: 用户类型。ADMIN：管理员 COMMON：普通用户。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type UserType: String
# @param UserAlias: 用户别名
# 注意：此字段可能返回 null，表示取不到有效值。
# @type UserAlias: String
attr_accessor :UserId, :UserDescription, :PolicySet, :Creator, :CreateTime, :WorkGroupSet, :IsOwner, :UserType, :UserAlias
def initialize(userid=nil, userdescription=nil, policyset=nil, creator=nil, createtime=nil, workgroupset=nil, isowner=nil, usertype=nil, useralias=nil)
@UserId = userid
@UserDescription = userdescription
@PolicySet = policyset
@Creator = creator
@CreateTime = createtime
@WorkGroupSet = workgroupset
@IsOwner = isowner
@UserType = usertype
@UserAlias = useralias
end
def deserialize(params)
@UserId = params['UserId']
@UserDescription = params['UserDescription']
unless params['PolicySet'].nil?
@PolicySet = []
params['PolicySet'].each do |i|
policy_tmp = Policy.new
policy_tmp.deserialize(i)
@PolicySet << policy_tmp
end
end
@Creator = params['Creator']
@CreateTime = params['CreateTime']
unless params['WorkGroupSet'].nil?
@WorkGroupSet = []
params['WorkGroupSet'].each do |i|
workgroupmessage_tmp = WorkGroupMessage.new
workgroupmessage_tmp.deserialize(i)
@WorkGroupSet << workgroupmessage_tmp
end
end
@IsOwner = params['IsOwner']
@UserType = params['UserType']
@UserAlias = params['UserAlias']
end
end
# 用户部分信息
class UserMessage < TencentCloud::Common::AbstractModel
# @param UserId: 用户Id，和CAM侧子用户Uin匹配
# @type UserId: String
# @param UserDescription: 用户描述
# 注意：此字段可能返回 null，表示取不到有效值。
# @type UserDescription: String
# @param Creator: 当前用户的创建者
# @type Creator: String
# @param CreateTime: 当前用户的创建时间，形如2021-07-28 16:19:32
# @type CreateTime: String
# @param UserAlias: 用户别名
# @type UserAlias: String
attr_accessor :UserId, :UserDescription, :Creator, :CreateTime, :UserAlias
def initialize(userid=nil, userdescription=nil, creator=nil, createtime=nil, useralias=nil)
@UserId = userid
@UserDescription = userdescription
@Creator = creator
@CreateTime = createtime
@UserAlias = useralias
end
def deserialize(params)
@UserId = params['UserId']
@UserDescription = params['UserDescription']
@Creator = params['Creator']
@CreateTime = params['CreateTime']
@UserAlias = params['UserAlias']
end
end
# 视图基本配置信息
class ViewBaseInfo < TencentCloud::Common::AbstractModel
# @param DatabaseName: 该视图所属数据库名字
# @type DatabaseName: String
# @param ViewName: 视图名称
# @type ViewName: String
attr_accessor :DatabaseName, :ViewName
def initialize(databasename=nil, viewname=nil)
@DatabaseName = databasename
@ViewName = viewname
end
def deserialize(params)
@DatabaseName = params['DatabaseName']
@ViewName = params['ViewName']
end
end
# 查询视图信息对象
class ViewResponseInfo < TencentCloud::Common::AbstractModel
# @param ViewBaseInfo: 视图基本信息。
# @type ViewBaseInfo: :class:`Tencentcloud::Dlc.v20210125.models.ViewBaseInfo`
# @param Columns: 视图列信息。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Columns: Array
# @param Properties: 视图属性信息。
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Properties: Array
# @param CreateTime: 视图创建时间。
# @type CreateTime: String
# @param ModifiedTime: 视图更新时间。
# @type ModifiedTime: String
attr_accessor :ViewBaseInfo, :Columns, :Properties, :CreateTime, :ModifiedTime
def initialize(viewbaseinfo=nil, columns=nil, properties=nil, createtime=nil, modifiedtime=nil)
@ViewBaseInfo = viewbaseinfo
@Columns = columns
@Properties = properties
@CreateTime = createtime
@ModifiedTime = modifiedtime
end
def deserialize(params)
unless params['ViewBaseInfo'].nil?
@ViewBaseInfo = ViewBaseInfo.new
@ViewBaseInfo.deserialize(params['ViewBaseInfo'])
end
unless params['Columns'].nil?
@Columns = []
params['Columns'].each do |i|
column_tmp = Column.new
column_tmp.deserialize(i)
@Columns << column_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
@CreateTime = params['CreateTime']
@ModifiedTime = params['ModifiedTime']
end
end
# 同一个用户绑定的工作组集合
class WorkGroupIdSetOfUserId < TencentCloud::Common::AbstractModel
# @param UserId: 用户Id，和CAM侧Uin匹配
# @type UserId: String
# @param WorkGroupIds: 工作组Id集合
# @type WorkGroupIds: Array
attr_accessor :UserId, :WorkGroupIds
def initialize(userid=nil, workgroupids=nil)
@UserId = userid
@WorkGroupIds = workgroupids
end
def deserialize(params)
@UserId = params['UserId']
@WorkGroupIds = params['WorkGroupIds']
end
end
# 工作组信息
class WorkGroupInfo < TencentCloud::Common::AbstractModel
# @param WorkGroupId: 查询到的工作组唯一Id
# @type WorkGroupId: Integer
# @param WorkGroupName: 工作组名称
# @type WorkGroupName: String
# @param WorkGroupDescription: 工作组描述
# 注意：此字段可能返回 null，表示取不到有效值。
# @type WorkGroupDescription: String
# @param UserNum: 工作组关联的用户数量
# @type UserNum: Integer
# @param UserSet: 工作组关联的用户集合
# 注意：此字段可能返回 null，表示取不到有效值。
# @type UserSet: Array
# @param PolicySet: 工作组绑定的权限集合
# 注意：此字段可能返回 null，表示取不到有效值。
# @type PolicySet: Array
# @param Creator: 工作组的创建人
# @type Creator: String
# @param CreateTime: 工作组的创建时间，形如2021-07-28 16:19:32
# @type CreateTime: String
attr_accessor :WorkGroupId, :WorkGroupName, :WorkGroupDescription, :UserNum, :UserSet, :PolicySet, :Creator, :CreateTime
def initialize(workgroupid=nil, workgroupname=nil, workgroupdescription=nil, usernum=nil, userset=nil, policyset=nil, creator=nil, createtime=nil)
@WorkGroupId = workgroupid
@WorkGroupName = workgroupname
@WorkGroupDescription = workgroupdescription
@UserNum = usernum
@UserSet = userset
@PolicySet = policyset
@Creator = creator
@CreateTime = createtime
end
def deserialize(params)
@WorkGroupId = params['WorkGroupId']
@WorkGroupName = params['WorkGroupName']
@WorkGroupDescription = params['WorkGroupDescription']
@UserNum = params['UserNum']
unless params['UserSet'].nil?
@UserSet = []
params['UserSet'].each do |i|
usermessage_tmp = UserMessage.new
usermessage_tmp.deserialize(i)
@UserSet << usermessage_tmp
end
end
unless params['PolicySet'].nil?
@PolicySet = []
params['PolicySet'].each do |i|
policy_tmp = Policy.new
policy_tmp.deserialize(i)
@PolicySet << policy_tmp
end
end
@Creator = params['Creator']
@CreateTime = params['CreateTime']
end
end
# 工作组部分信息
class WorkGroupMessage < TencentCloud::Common::AbstractModel
# @param WorkGroupId: 工作组唯一Id
# @type WorkGroupId: Integer
# @param WorkGroupName: 工作组名称
# @type WorkGroupName: String
# @param WorkGroupDescription: 工作组描述
# 注意：此字段可能返回 null，表示取不到有效值。
# @type WorkGroupDescription: String
# @param Creator: 创建者
# @type Creator: String
# @param CreateTime: 工作组创建的时间，形如2021-07-28 16:19:32
# @type CreateTime: String
attr_accessor :WorkGroupId, :WorkGroupName, :WorkGroupDescription, :Creator, :CreateTime
def initialize(workgroupid=nil, workgroupname=nil, workgroupdescription=nil, creator=nil, createtime=nil)
@WorkGroupId = workgroupid
@WorkGroupName = workgroupname
@WorkGroupDescription = workgroupdescription
@Creator = creator
@CreateTime = createtime
end
def deserialize(params)
@WorkGroupId = params['WorkGroupId']
@WorkGroupName = params['WorkGroupName']
@WorkGroupDescription = params['WorkGroupDescription']
@Creator = params['Creator']
@CreateTime = params['CreateTime']
end
end
end
end
end