# 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 Oceanus module V20190422 # 云联网描述信息 class CCN < TencentCloud::Common::AbstractModel # @param VpcId: 私有网络 ID # @type VpcId: String # @param SubnetId: 子网 ID # @type SubnetId: String # @param CcnId: 云联网 ID,如 ccn-rahigzjd # @type CcnId: String attr_accessor :VpcId, :SubnetId, :CcnId def initialize(vpcid=nil, subnetid=nil, ccnid=nil) @VpcId = vpcid @SubnetId = subnetid @CcnId = ccnid end def deserialize(params) @VpcId = params['VpcId'] @SubnetId = params['SubnetId'] @CcnId = params['CcnId'] end end # CheckSavepoint请求参数结构体 class CheckSavepointRequest < TencentCloud::Common::AbstractModel # @param JobId: 作业 id # @type JobId: String # @param SerialId: 快照资源 id # @type SerialId: String # @param RecordType: 快照类型 1: savepoint;2: checkpoint;3: cancelWithSavepoint # @type RecordType: Integer # @param SavepointPath: 快照路径,目前只支持 cos 路径 # @type SavepointPath: String # @param WorkSpaceId: 工作空间 id # @type WorkSpaceId: String attr_accessor :JobId, :SerialId, :RecordType, :SavepointPath, :WorkSpaceId def initialize(jobid=nil, serialid=nil, recordtype=nil, savepointpath=nil, workspaceid=nil) @JobId = jobid @SerialId = serialid @RecordType = recordtype @SavepointPath = savepointpath @WorkSpaceId = workspaceid end def deserialize(params) @JobId = params['JobId'] @SerialId = params['SerialId'] @RecordType = params['RecordType'] @SavepointPath = params['SavepointPath'] @WorkSpaceId = params['WorkSpaceId'] end end # CheckSavepoint返回参数结构体 class CheckSavepointResponse < TencentCloud::Common::AbstractModel # @param SerialId: 资源 id # @type SerialId: String # @param SavepointStatus: 1=可用,2=不可用 # @type SavepointStatus: Integer # @param RequestId: 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :SerialId, :SavepointStatus, :RequestId def initialize(serialid=nil, savepointstatus=nil, requestid=nil) @SerialId = serialid @SavepointStatus = savepointstatus @RequestId = requestid end def deserialize(params) @SerialId = params['SerialId'] @SavepointStatus = params['SavepointStatus'] @RequestId = params['RequestId'] end end # 描述用户创建的集群信息 class Cluster < TencentCloud::Common::AbstractModel # @param ClusterId: 集群 ID # @type ClusterId: String # @param Name: 集群名称 # @type Name: String # @param Region: 地域 # @type Region: String # @param AppId: 用户 AppID # @type AppId: Integer # @param OwnerUin: 主账号 UIN # @type OwnerUin: String # @param CreatorUin: 创建者 UIN # @type CreatorUin: String # @param Status: 集群状态, 1 未初始化,,3 初始化中,2 运行中 # @type Status: Integer # @param Remark: 描述 # @type Remark: String # @param CreateTime: 集群创建时间 # @type CreateTime: String # @param UpdateTime: 最后一次操作集群的时间 # @type UpdateTime: String # @param CuNum: CU 数量 # @type CuNum: Integer # @param CuMem: CU 内存规格 # @type CuMem: Integer # @param Zone: 可用区 # @type Zone: String # @param StatusDesc: 状态描述 # @type StatusDesc: String # @param CCNs: 网络 # @type CCNs: Array # @param NetEnvironmentType: 网络 # @type NetEnvironmentType: Integer # @param FreeCuNum: 空闲 CU # @type FreeCuNum: Integer # @param Tags: 集群绑定的标签 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Tags: Array # @param IsolatedTime: 集群隔离时间; 没隔离时间,则为 - # 注意:此字段可能返回 null,表示取不到有效值。 # @type IsolatedTime: String # @param ExpireTime: 集群过期时间; 没过期概念,则为 - # 注意:此字段可能返回 null,表示取不到有效值。 # @type ExpireTime: String # @param SecondsUntilExpiry: 距离过期还有多少秒; 没过期概念,则为 - # 注意:此字段可能返回 null,表示取不到有效值。 # @type SecondsUntilExpiry: String # @param AutoRenewFlag: 自动续费标记,0 表示默认状态 (用户未设置,即初始状态,用户开通了预付费不停服特权会进行自动续费), 1 表示自动续费,2表示明确不自动续费(用户设置) # 注意:此字段可能返回 null,表示取不到有效值。 # @type AutoRenewFlag: Integer # @param DefaultCOSBucket: 集群的默认 COS 存储桶 # 注意:此字段可能返回 null,表示取不到有效值。 # @type DefaultCOSBucket: String # @param CLSLogSet: 集群的CLS 日志集 LogSet # 注意:此字段可能返回 null,表示取不到有效值。 # @type CLSLogSet: String # @param CLSTopicId: 集群的CLS 日志主题 TopicId # 注意:此字段可能返回 null,表示取不到有效值。 # @type CLSTopicId: String # @param CLSLogName: 集群的CLS 日志集 名字 # 注意:此字段可能返回 null,表示取不到有效值。 # @type CLSLogName: String # @param CLSTopicName: 集群的CLS 日志主题 名字 # 注意:此字段可能返回 null,表示取不到有效值。 # @type CLSTopicName: String # @param Version: 集群的版本信息 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Version: :class:`Tencentcloud::Oceanus.v20190422.models.ClusterVersion` # @param FreeCu: 细粒度资源下的空闲CU # 注意:此字段可能返回 null,表示取不到有效值。 # @type FreeCu: Float # @param DefaultLogCollectConf: 集群的默认日志采集配置 # 注意:此字段可能返回 null,表示取不到有效值。 # @type DefaultLogCollectConf: String # @param CustomizedDNSEnabled: 取值:0-没有设置,1-已设置,2-不允许设置 # 注意:此字段可能返回 null,表示取不到有效值。 # @type CustomizedDNSEnabled: Integer # @param Correlations: 空间信息 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Correlations: Array # @param RunningCu: 运行CU # 注意:此字段可能返回 null,表示取不到有效值。 # @type RunningCu: Float # @param PayMode: 0 后付费,1 预付费 # 注意:此字段可能返回 null,表示取不到有效值。 # @type PayMode: Integer # @param IsNeedManageNode: 前端区分 集群是否需要2CU逻辑 因为历史集群 变配不需要, default 1 新集群都需要 # 注意:此字段可能返回 null,表示取不到有效值。 # @type IsNeedManageNode: Integer attr_accessor :ClusterId, :Name, :Region, :AppId, :OwnerUin, :CreatorUin, :Status, :Remark, :CreateTime, :UpdateTime, :CuNum, :CuMem, :Zone, :StatusDesc, :CCNs, :NetEnvironmentType, :FreeCuNum, :Tags, :IsolatedTime, :ExpireTime, :SecondsUntilExpiry, :AutoRenewFlag, :DefaultCOSBucket, :CLSLogSet, :CLSTopicId, :CLSLogName, :CLSTopicName, :Version, :FreeCu, :DefaultLogCollectConf, :CustomizedDNSEnabled, :Correlations, :RunningCu, :PayMode, :IsNeedManageNode def initialize(clusterid=nil, name=nil, region=nil, appid=nil, owneruin=nil, creatoruin=nil, status=nil, remark=nil, createtime=nil, updatetime=nil, cunum=nil, cumem=nil, zone=nil, statusdesc=nil, ccns=nil, netenvironmenttype=nil, freecunum=nil, tags=nil, isolatedtime=nil, expiretime=nil, secondsuntilexpiry=nil, autorenewflag=nil, defaultcosbucket=nil, clslogset=nil, clstopicid=nil, clslogname=nil, clstopicname=nil, version=nil, freecu=nil, defaultlogcollectconf=nil, customizeddnsenabled=nil, correlations=nil, runningcu=nil, paymode=nil, isneedmanagenode=nil) @ClusterId = clusterid @Name = name @Region = region @AppId = appid @OwnerUin = owneruin @CreatorUin = creatoruin @Status = status @Remark = remark @CreateTime = createtime @UpdateTime = updatetime @CuNum = cunum @CuMem = cumem @Zone = zone @StatusDesc = statusdesc @CCNs = ccns @NetEnvironmentType = netenvironmenttype @FreeCuNum = freecunum @Tags = tags @IsolatedTime = isolatedtime @ExpireTime = expiretime @SecondsUntilExpiry = secondsuntilexpiry @AutoRenewFlag = autorenewflag @DefaultCOSBucket = defaultcosbucket @CLSLogSet = clslogset @CLSTopicId = clstopicid @CLSLogName = clslogname @CLSTopicName = clstopicname @Version = version @FreeCu = freecu @DefaultLogCollectConf = defaultlogcollectconf @CustomizedDNSEnabled = customizeddnsenabled @Correlations = correlations @RunningCu = runningcu @PayMode = paymode @IsNeedManageNode = isneedmanagenode end def deserialize(params) @ClusterId = params['ClusterId'] @Name = params['Name'] @Region = params['Region'] @AppId = params['AppId'] @OwnerUin = params['OwnerUin'] @CreatorUin = params['CreatorUin'] @Status = params['Status'] @Remark = params['Remark'] @CreateTime = params['CreateTime'] @UpdateTime = params['UpdateTime'] @CuNum = params['CuNum'] @CuMem = params['CuMem'] @Zone = params['Zone'] @StatusDesc = params['StatusDesc'] unless params['CCNs'].nil? @CCNs = [] params['CCNs'].each do |i| ccn_tmp = CCN.new ccn_tmp.deserialize(i) @CCNs << ccn_tmp end end @NetEnvironmentType = params['NetEnvironmentType'] @FreeCuNum = params['FreeCuNum'] unless params['Tags'].nil? @Tags = [] params['Tags'].each do |i| tag_tmp = Tag.new tag_tmp.deserialize(i) @Tags << tag_tmp end end @IsolatedTime = params['IsolatedTime'] @ExpireTime = params['ExpireTime'] @SecondsUntilExpiry = params['SecondsUntilExpiry'] @AutoRenewFlag = params['AutoRenewFlag'] @DefaultCOSBucket = params['DefaultCOSBucket'] @CLSLogSet = params['CLSLogSet'] @CLSTopicId = params['CLSTopicId'] @CLSLogName = params['CLSLogName'] @CLSTopicName = params['CLSTopicName'] unless params['Version'].nil? @Version = ClusterVersion.new @Version.deserialize(params['Version']) end @FreeCu = params['FreeCu'] @DefaultLogCollectConf = params['DefaultLogCollectConf'] @CustomizedDNSEnabled = params['CustomizedDNSEnabled'] unless params['Correlations'].nil? @Correlations = [] params['Correlations'].each do |i| workspaceclusteritem_tmp = WorkSpaceClusterItem.new workspaceclusteritem_tmp.deserialize(i) @Correlations << workspaceclusteritem_tmp end end @RunningCu = params['RunningCu'] @PayMode = params['PayMode'] @IsNeedManageNode = params['IsNeedManageNode'] end end # 集群的版本相关信息 class ClusterVersion < TencentCloud::Common::AbstractModel # @param Flink: 集群的Flink版本 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Flink: String # @param SupportedFlink: 集群支持的Flink版本 # 注意:此字段可能返回 null,表示取不到有效值。 # @type SupportedFlink: Array attr_accessor :Flink, :SupportedFlink def initialize(flink=nil, supportedflink=nil) @Flink = flink @SupportedFlink = supportedflink end def deserialize(params) @Flink = params['Flink'] @SupportedFlink = params['SupportedFlink'] end end # 复制作业单条明细 class CopyJobItem < TencentCloud::Common::AbstractModel def initialize() end def deserialize(params) end end # 复制作业单条明细结果 class CopyJobResult < TencentCloud::Common::AbstractModel def initialize() end def deserialize(params) end end # CopyJobs请求参数结构体 class CopyJobsRequest < TencentCloud::Common::AbstractModel # @param JobItems: 复制明细列表 # @type JobItems: Array # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :JobItems, :WorkSpaceId def initialize(jobitems=nil, workspaceid=nil) @JobItems = jobitems @WorkSpaceId = workspaceid end def deserialize(params) unless params['JobItems'].nil? @JobItems = [] params['JobItems'].each do |i| copyjobitem_tmp = CopyJobItem.new copyjobitem_tmp.deserialize(i) @JobItems << copyjobitem_tmp end end @WorkSpaceId = params['WorkSpaceId'] end end # CopyJobs返回参数结构体 class CopyJobsResponse < TencentCloud::Common::AbstractModel # @param SuccessCount: 成功条数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type SuccessCount: Integer # @param FailCount: 失败条数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type FailCount: Integer # @param CopyJobsResults: 结果列表 # 注意:此字段可能返回 null,表示取不到有效值。 # @type CopyJobsResults: Array # @param RequestId: 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :SuccessCount, :FailCount, :CopyJobsResults, :RequestId def initialize(successcount=nil, failcount=nil, copyjobsresults=nil, requestid=nil) @SuccessCount = successcount @FailCount = failcount @CopyJobsResults = copyjobsresults @RequestId = requestid end def deserialize(params) @SuccessCount = params['SuccessCount'] @FailCount = params['FailCount'] unless params['CopyJobsResults'].nil? @CopyJobsResults = [] params['CopyJobsResults'].each do |i| copyjobresult_tmp = CopyJobResult.new copyjobresult_tmp.deserialize(i) @CopyJobsResults << copyjobresult_tmp end end @RequestId = params['RequestId'] end end # CreateFolder请求参数结构体 class CreateFolderRequest < TencentCloud::Common::AbstractModel # @param FolderName: 新建文件夹名 # @type FolderName: String # @param ParentId: 新建文件夹的父目录ID # @type ParentId: String # @param FolderType: 文件夹类型,0是任务文件夹,1是依赖文件夹 # @type FolderType: Integer # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :FolderName, :ParentId, :FolderType, :WorkSpaceId def initialize(foldername=nil, parentid=nil, foldertype=nil, workspaceid=nil) @FolderName = foldername @ParentId = parentid @FolderType = foldertype @WorkSpaceId = workspaceid end def deserialize(params) @FolderName = params['FolderName'] @ParentId = params['ParentId'] @FolderType = params['FolderType'] @WorkSpaceId = params['WorkSpaceId'] end end # CreateFolder返回参数结构体 class CreateFolderResponse < TencentCloud::Common::AbstractModel # @param FolderId: 新建文件夹的唯一ID # @type FolderId: String # @param RequestId: 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :FolderId, :RequestId def initialize(folderid=nil, requestid=nil) @FolderId = folderid @RequestId = requestid end def deserialize(params) @FolderId = params['FolderId'] @RequestId = params['RequestId'] end end # CreateJobConfig请求参数结构体 class CreateJobConfigRequest < TencentCloud::Common::AbstractModel # @param JobId: 作业Id # @type JobId: String # @param EntrypointClass: 主类 # @type EntrypointClass: String # @param ProgramArgs: 主类入参 # @type ProgramArgs: String # @param Remark: 备注 # @type Remark: String # @param ResourceRefs: 资源引用数组 # @type ResourceRefs: Array # @param DefaultParallelism: 作业默认并行度 # @type DefaultParallelism: Integer # @param Properties: 系统参数 # @type Properties: Array # @param AutoDelete: 1: 作业配置达到上限之后,自动删除可删除的最早版本 # @type AutoDelete: Integer # @param COSBucket: 作业使用的 COS 存储桶名 # @type COSBucket: String # @param LogCollect: 是否采集作业日志 # @type LogCollect: Boolean # @param JobManagerSpec: JobManager规格 # @type JobManagerSpec: Float # @param TaskManagerSpec: TaskManager规格 # @type TaskManagerSpec: Float # @param ClsLogsetId: CLS日志集ID # @type ClsLogsetId: String # @param ClsTopicId: CLS日志主题ID # @type ClsTopicId: String # @param LogCollectType: 日志采集类型 2:CLS;3:COS # @type LogCollectType: Integer # @param PythonVersion: pyflink作业运行时使用的python版本 # @type PythonVersion: String # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String # @param LogLevel: 日志级别 # @type LogLevel: String # @param AutoRecover: Oceanus 平台恢复作业开关 1:开启 -1: 关闭 # @type AutoRecover: Integer attr_accessor :JobId, :EntrypointClass, :ProgramArgs, :Remark, :ResourceRefs, :DefaultParallelism, :Properties, :AutoDelete, :COSBucket, :LogCollect, :JobManagerSpec, :TaskManagerSpec, :ClsLogsetId, :ClsTopicId, :LogCollectType, :PythonVersion, :WorkSpaceId, :LogLevel, :AutoRecover def initialize(jobid=nil, entrypointclass=nil, programargs=nil, remark=nil, resourcerefs=nil, defaultparallelism=nil, properties=nil, autodelete=nil, cosbucket=nil, logcollect=nil, jobmanagerspec=nil, taskmanagerspec=nil, clslogsetid=nil, clstopicid=nil, logcollecttype=nil, pythonversion=nil, workspaceid=nil, loglevel=nil, autorecover=nil) @JobId = jobid @EntrypointClass = entrypointclass @ProgramArgs = programargs @Remark = remark @ResourceRefs = resourcerefs @DefaultParallelism = defaultparallelism @Properties = properties @AutoDelete = autodelete @COSBucket = cosbucket @LogCollect = logcollect @JobManagerSpec = jobmanagerspec @TaskManagerSpec = taskmanagerspec @ClsLogsetId = clslogsetid @ClsTopicId = clstopicid @LogCollectType = logcollecttype @PythonVersion = pythonversion @WorkSpaceId = workspaceid @LogLevel = loglevel @AutoRecover = autorecover end def deserialize(params) @JobId = params['JobId'] @EntrypointClass = params['EntrypointClass'] @ProgramArgs = params['ProgramArgs'] @Remark = params['Remark'] unless params['ResourceRefs'].nil? @ResourceRefs = [] params['ResourceRefs'].each do |i| resourceref_tmp = ResourceRef.new resourceref_tmp.deserialize(i) @ResourceRefs << resourceref_tmp end end @DefaultParallelism = params['DefaultParallelism'] unless params['Properties'].nil? @Properties = [] params['Properties'].each do |i| property_tmp = Property.new property_tmp.deserialize(i) @Properties << property_tmp end end @AutoDelete = params['AutoDelete'] @COSBucket = params['COSBucket'] @LogCollect = params['LogCollect'] @JobManagerSpec = params['JobManagerSpec'] @TaskManagerSpec = params['TaskManagerSpec'] @ClsLogsetId = params['ClsLogsetId'] @ClsTopicId = params['ClsTopicId'] @LogCollectType = params['LogCollectType'] @PythonVersion = params['PythonVersion'] @WorkSpaceId = params['WorkSpaceId'] @LogLevel = params['LogLevel'] @AutoRecover = params['AutoRecover'] end end # CreateJobConfig返回参数结构体 class CreateJobConfigResponse < TencentCloud::Common::AbstractModel # @param Version: 作业配置版本号 # @type Version: Integer # @param RequestId: 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Version, :RequestId def initialize(version=nil, requestid=nil) @Version = version @RequestId = requestid end def deserialize(params) @Version = params['Version'] @RequestId = params['RequestId'] end end # CreateJob请求参数结构体 class CreateJobRequest < TencentCloud::Common::AbstractModel # @param Name: 作业名称,允许输入长度小于等于50个字符的中文、英文、数字、-(横线)、_(下划线)、.(点),且符号必须半角字符。注意作业名不能和现有作业同名 # @type Name: String # @param JobType: 作业的类型,1 表示 SQL 作业,2 表示 JAR 作业 # @type JobType: Integer # @param ClusterType: 集群的类型,1 表示共享集群,2 表示独享集群 # @type ClusterType: Integer # @param ClusterId: 当 ClusterType=2 时,必选,用来指定该作业提交的独享集群 ID # @type ClusterId: String # @param CuMem: 设置每 CU 的内存规格,单位为 GB,支持 2、4、8、16(需申请开通白名单后使用)。默认为 4,即 1 CU 对应 4 GB 的运行内存 # @type CuMem: Integer # @param Remark: 作业的备注信息,可以随意设置 # @type Remark: String # @param FolderId: 作业名所属文件夹ID,根目录为"root" # @type FolderId: String # @param FlinkVersion: 作业运行的Flink版本 # @type FlinkVersion: String # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :Name, :JobType, :ClusterType, :ClusterId, :CuMem, :Remark, :FolderId, :FlinkVersion, :WorkSpaceId def initialize(name=nil, jobtype=nil, clustertype=nil, clusterid=nil, cumem=nil, remark=nil, folderid=nil, flinkversion=nil, workspaceid=nil) @Name = name @JobType = jobtype @ClusterType = clustertype @ClusterId = clusterid @CuMem = cumem @Remark = remark @FolderId = folderid @FlinkVersion = flinkversion @WorkSpaceId = workspaceid end def deserialize(params) @Name = params['Name'] @JobType = params['JobType'] @ClusterType = params['ClusterType'] @ClusterId = params['ClusterId'] @CuMem = params['CuMem'] @Remark = params['Remark'] @FolderId = params['FolderId'] @FlinkVersion = params['FlinkVersion'] @WorkSpaceId = params['WorkSpaceId'] end end # CreateJob返回参数结构体 class CreateJobResponse < TencentCloud::Common::AbstractModel # @param JobId: 作业Id # @type JobId: String # @param RequestId: 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :JobId, :RequestId def initialize(jobid=nil, requestid=nil) @JobId = jobid @RequestId = requestid end def deserialize(params) @JobId = params['JobId'] @RequestId = params['RequestId'] end end # CreateResourceConfig请求参数结构体 class CreateResourceConfigRequest < TencentCloud::Common::AbstractModel # @param ResourceId: 资源ID # @type ResourceId: String # @param ResourceLoc: 位置信息 # @type ResourceLoc: :class:`Tencentcloud::Oceanus.v20190422.models.ResourceLoc` # @param Remark: 资源描述信息 # @type Remark: String # @param AutoDelete: 1: 资源版本达到上限,自动删除最早可删除的版本 # @type AutoDelete: Integer # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :ResourceId, :ResourceLoc, :Remark, :AutoDelete, :WorkSpaceId def initialize(resourceid=nil, resourceloc=nil, remark=nil, autodelete=nil, workspaceid=nil) @ResourceId = resourceid @ResourceLoc = resourceloc @Remark = remark @AutoDelete = autodelete @WorkSpaceId = workspaceid end def deserialize(params) @ResourceId = params['ResourceId'] unless params['ResourceLoc'].nil? @ResourceLoc = ResourceLoc.new @ResourceLoc.deserialize(params['ResourceLoc']) end @Remark = params['Remark'] @AutoDelete = params['AutoDelete'] @WorkSpaceId = params['WorkSpaceId'] end end # CreateResourceConfig返回参数结构体 class CreateResourceConfigResponse < TencentCloud::Common::AbstractModel # @param Version: 资源版本ID # @type Version: Integer # @param RequestId: 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Version, :RequestId def initialize(version=nil, requestid=nil) @Version = version @RequestId = requestid end def deserialize(params) @Version = params['Version'] @RequestId = params['RequestId'] end end # CreateResource请求参数结构体 class CreateResourceRequest < TencentCloud::Common::AbstractModel # @param ResourceLoc: 资源位置 # @type ResourceLoc: :class:`Tencentcloud::Oceanus.v20190422.models.ResourceLoc` # @param ResourceType: 资源类型。目前只支持 JAR,取值为 1 # @type ResourceType: Integer # @param Remark: 资源描述 # @type Remark: String # @param Name: 资源名称 # @type Name: String # @param ResourceConfigRemark: 资源版本描述 # @type ResourceConfigRemark: String # @param FolderId: 目录ID # @type FolderId: String # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :ResourceLoc, :ResourceType, :Remark, :Name, :ResourceConfigRemark, :FolderId, :WorkSpaceId def initialize(resourceloc=nil, resourcetype=nil, remark=nil, name=nil, resourceconfigremark=nil, folderid=nil, workspaceid=nil) @ResourceLoc = resourceloc @ResourceType = resourcetype @Remark = remark @Name = name @ResourceConfigRemark = resourceconfigremark @FolderId = folderid @WorkSpaceId = workspaceid end def deserialize(params) unless params['ResourceLoc'].nil? @ResourceLoc = ResourceLoc.new @ResourceLoc.deserialize(params['ResourceLoc']) end @ResourceType = params['ResourceType'] @Remark = params['Remark'] @Name = params['Name'] @ResourceConfigRemark = params['ResourceConfigRemark'] @FolderId = params['FolderId'] @WorkSpaceId = params['WorkSpaceId'] end end # CreateResource返回参数结构体 class CreateResourceResponse < TencentCloud::Common::AbstractModel # @param ResourceId: 资源ID # @type ResourceId: String # @param Version: 资源版本 # @type Version: Integer # @param RequestId: 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :ResourceId, :Version, :RequestId def initialize(resourceid=nil, version=nil, requestid=nil) @ResourceId = resourceid @Version = version @RequestId = requestid end def deserialize(params) @ResourceId = params['ResourceId'] @Version = params['Version'] @RequestId = params['RequestId'] end end # DeleteJobs请求参数结构体 class DeleteJobsRequest < TencentCloud::Common::AbstractModel # @param JobIds: 作业Id列表 # @type JobIds: Array # @param WorkSpaceId: 工作空间Id # @type WorkSpaceId: String attr_accessor :JobIds, :WorkSpaceId def initialize(jobids=nil, workspaceid=nil) @JobIds = jobids @WorkSpaceId = workspaceid end def deserialize(params) @JobIds = params['JobIds'] @WorkSpaceId = params['WorkSpaceId'] end end # DeleteJobs返回参数结构体 class DeleteJobsResponse < 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 # DeleteResourceConfigs请求参数结构体 class DeleteResourceConfigsRequest < TencentCloud::Common::AbstractModel # @param ResourceId: 资源ID # @type ResourceId: String # @param ResourceConfigVersions: 资源版本数组 # @type ResourceConfigVersions: Array # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :ResourceId, :ResourceConfigVersions, :WorkSpaceId def initialize(resourceid=nil, resourceconfigversions=nil, workspaceid=nil) @ResourceId = resourceid @ResourceConfigVersions = resourceconfigversions @WorkSpaceId = workspaceid end def deserialize(params) @ResourceId = params['ResourceId'] @ResourceConfigVersions = params['ResourceConfigVersions'] @WorkSpaceId = params['WorkSpaceId'] end end # DeleteResourceConfigs返回参数结构体 class DeleteResourceConfigsResponse < 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 # DeleteResources请求参数结构体 class DeleteResourcesRequest < TencentCloud::Common::AbstractModel # @param ResourceIds: 待删除资源ID列表 # @type ResourceIds: Array # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :ResourceIds, :WorkSpaceId def initialize(resourceids=nil, workspaceid=nil) @ResourceIds = resourceids @WorkSpaceId = workspaceid end def deserialize(params) @ResourceIds = params['ResourceIds'] @WorkSpaceId = params['WorkSpaceId'] end end # DeleteResources返回参数结构体 class DeleteResourcesResponse < 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 # DeleteTableConfig请求参数结构体 class DeleteTableConfigRequest < TencentCloud::Common::AbstractModel # @param JobId: 作业ID # @type JobId: String # @param DebugId: 调试作业ID # @type DebugId: Integer # @param TableName: 表名 # @type TableName: String # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :JobId, :DebugId, :TableName, :WorkSpaceId def initialize(jobid=nil, debugid=nil, tablename=nil, workspaceid=nil) @JobId = jobid @DebugId = debugid @TableName = tablename @WorkSpaceId = workspaceid end def deserialize(params) @JobId = params['JobId'] @DebugId = params['DebugId'] @TableName = params['TableName'] @WorkSpaceId = params['WorkSpaceId'] end end # DeleteTableConfig返回参数结构体 class DeleteTableConfigResponse < 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 # DescribeClusters请求参数结构体 class DescribeClustersRequest < TencentCloud::Common::AbstractModel # @param ClusterIds: 按照一个或者多个集群 ID 查询,每次请求的集群上限为 100 # @type ClusterIds: Array # @param Offset: 偏移量,默认 0 # @type Offset: Integer # @param Limit: 请求的集群数量,默认 20,最大值 100 # @type Limit: Integer # @param OrderType: 集群信息结果排序规则,1 按时间降序,2 按照时间升序,3 按照状态排序 # @type OrderType: Integer # @param Filters: 过滤规则 # @type Filters: Array # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :ClusterIds, :Offset, :Limit, :OrderType, :Filters, :WorkSpaceId def initialize(clusterids=nil, offset=nil, limit=nil, ordertype=nil, filters=nil, workspaceid=nil) @ClusterIds = clusterids @Offset = offset @Limit = limit @OrderType = ordertype @Filters = filters @WorkSpaceId = workspaceid end def deserialize(params) @ClusterIds = params['ClusterIds'] @Offset = params['Offset'] @Limit = params['Limit'] @OrderType = params['OrderType'] unless params['Filters'].nil? @Filters = [] params['Filters'].each do |i| filter_tmp = Filter.new filter_tmp.deserialize(i) @Filters << filter_tmp end end @WorkSpaceId = params['WorkSpaceId'] end end # DescribeClusters返回参数结构体 class DescribeClustersResponse < TencentCloud::Common::AbstractModel # @param TotalCount: 集群总数 # @type TotalCount: Integer # @param ClusterSet: 集群列表 # @type ClusterSet: Array # @param RequestId: 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :TotalCount, :ClusterSet, :RequestId def initialize(totalcount=nil, clusterset=nil, requestid=nil) @TotalCount = totalcount @ClusterSet = clusterset @RequestId = requestid end def deserialize(params) @TotalCount = params['TotalCount'] unless params['ClusterSet'].nil? @ClusterSet = [] params['ClusterSet'].each do |i| cluster_tmp = Cluster.new cluster_tmp.deserialize(i) @ClusterSet << cluster_tmp end end @RequestId = params['RequestId'] end end # DescribeJobConfigs请求参数结构体 class DescribeJobConfigsRequest < TencentCloud::Common::AbstractModel # @param JobId: 作业Id # @type JobId: String # @param JobConfigVersions: 作业配置版本 # @type JobConfigVersions: Array # @param Offset: 偏移量,默认0 # @type Offset: Integer # @param Limit: 分页大小,默认20,最大100 # @type Limit: Integer # @param Filters: 过滤条件 # @type Filters: Array # @param OnlyDraft: true 表示只展示草稿 # @type OnlyDraft: Boolean # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :JobId, :JobConfigVersions, :Offset, :Limit, :Filters, :OnlyDraft, :WorkSpaceId def initialize(jobid=nil, jobconfigversions=nil, offset=nil, limit=nil, filters=nil, onlydraft=nil, workspaceid=nil) @JobId = jobid @JobConfigVersions = jobconfigversions @Offset = offset @Limit = limit @Filters = filters @OnlyDraft = onlydraft @WorkSpaceId = workspaceid end def deserialize(params) @JobId = params['JobId'] @JobConfigVersions = params['JobConfigVersions'] @Offset = params['Offset'] @Limit = params['Limit'] unless params['Filters'].nil? @Filters = [] params['Filters'].each do |i| filter_tmp = Filter.new filter_tmp.deserialize(i) @Filters << filter_tmp end end @OnlyDraft = params['OnlyDraft'] @WorkSpaceId = params['WorkSpaceId'] end end # DescribeJobConfigs返回参数结构体 class DescribeJobConfigsResponse < TencentCloud::Common::AbstractModel # @param TotalCount: 总的配置版本数量 # @type TotalCount: Integer # @param JobConfigSet: 作业配置列表 # @type JobConfigSet: Array # @param RequestId: 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :TotalCount, :JobConfigSet, :RequestId def initialize(totalcount=nil, jobconfigset=nil, requestid=nil) @TotalCount = totalcount @JobConfigSet = jobconfigset @RequestId = requestid end def deserialize(params) @TotalCount = params['TotalCount'] unless params['JobConfigSet'].nil? @JobConfigSet = [] params['JobConfigSet'].each do |i| jobconfig_tmp = JobConfig.new jobconfig_tmp.deserialize(i) @JobConfigSet << jobconfig_tmp end end @RequestId = params['RequestId'] end end # DescribeJobSavepoint请求参数结构体 class DescribeJobSavepointRequest < TencentCloud::Common::AbstractModel # @param JobId: 作业 SerialId # @type JobId: String # @param Limit: 分页参数,单页总数 # @type Limit: Integer # @param Offset: 分页参数,偏移量 # @type Offset: Integer # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :JobId, :Limit, :Offset, :WorkSpaceId def initialize(jobid=nil, limit=nil, offset=nil, workspaceid=nil) @JobId = jobid @Limit = limit @Offset = offset @WorkSpaceId = workspaceid end def deserialize(params) @JobId = params['JobId'] @Limit = params['Limit'] @Offset = params['Offset'] @WorkSpaceId = params['WorkSpaceId'] end end # DescribeJobSavepoint返回参数结构体 class DescribeJobSavepointResponse < TencentCloud::Common::AbstractModel # @param TotalNumber: 快照列表总数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TotalNumber: Integer # @param Savepoint: 快照列表 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Savepoint: Array # @param RunningSavepoint: 进行中的快照列表 # 注意:此字段可能返回 null,表示取不到有效值。 # @type RunningSavepoint: Array # @param RunningTotalNumber: 进行中的快照列表总数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type RunningTotalNumber: Integer # @param RequestId: 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :TotalNumber, :Savepoint, :RunningSavepoint, :RunningTotalNumber, :RequestId def initialize(totalnumber=nil, savepoint=nil, runningsavepoint=nil, runningtotalnumber=nil, requestid=nil) @TotalNumber = totalnumber @Savepoint = savepoint @RunningSavepoint = runningsavepoint @RunningTotalNumber = runningtotalnumber @RequestId = requestid end def deserialize(params) @TotalNumber = params['TotalNumber'] unless params['Savepoint'].nil? @Savepoint = [] params['Savepoint'].each do |i| savepoint_tmp = Savepoint.new savepoint_tmp.deserialize(i) @Savepoint << savepoint_tmp end end unless params['RunningSavepoint'].nil? @RunningSavepoint = [] params['RunningSavepoint'].each do |i| savepoint_tmp = Savepoint.new savepoint_tmp.deserialize(i) @RunningSavepoint << savepoint_tmp end end @RunningTotalNumber = params['RunningTotalNumber'] @RequestId = params['RequestId'] end end # DescribeJobs请求参数结构体 class DescribeJobsRequest < TencentCloud::Common::AbstractModel # @param JobIds: 按照一个或者多个作业ID查询。作业ID形如:cql-11112222,每次请求的作业上限为100。参数不支持同时指定JobIds和Filters。 # @type JobIds: Array # @param Filters: 过滤条件,支持的 Filter.Name 为:作业名 Name、作业状态 Status、所属集群 ClusterId、作业id JobId、集群名称 ClusterName。 每次请求的 Filters 个数的上限为 5,Filter.Values 的个数上限为 5。参数不支持同时指定 JobIds 和 Filters。 # @type Filters: Array # @param Offset: 偏移量,默认为0 # @type Offset: Integer # @param Limit: 分页大小,默认为20,最大值为100 # @type Limit: Integer # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :JobIds, :Filters, :Offset, :Limit, :WorkSpaceId def initialize(jobids=nil, filters=nil, offset=nil, limit=nil, workspaceid=nil) @JobIds = jobids @Filters = filters @Offset = offset @Limit = limit @WorkSpaceId = workspaceid end def deserialize(params) @JobIds = params['JobIds'] 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'] @WorkSpaceId = params['WorkSpaceId'] end end # DescribeJobs返回参数结构体 class DescribeJobsResponse < TencentCloud::Common::AbstractModel # @param TotalCount: 作业总数 # @type TotalCount: Integer # @param JobSet: 作业列表 # @type JobSet: Array # @param RequestId: 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :TotalCount, :JobSet, :RequestId def initialize(totalcount=nil, jobset=nil, requestid=nil) @TotalCount = totalcount @JobSet = jobset @RequestId = requestid end def deserialize(params) @TotalCount = params['TotalCount'] unless params['JobSet'].nil? @JobSet = [] params['JobSet'].each do |i| jobv1_tmp = JobV1.new jobv1_tmp.deserialize(i) @JobSet << jobv1_tmp end end @RequestId = params['RequestId'] end end # DescribeResourceConfigs请求参数结构体 class DescribeResourceConfigsRequest < TencentCloud::Common::AbstractModel # @param ResourceId: 资源ID # @type ResourceId: String # @param Offset: 偏移量,仅当设置 Limit 时该参数有效 # @type Offset: Integer # @param Limit: 返回值大小,不填则返回全量数据 # @type Limit: Integer # @param ResourceConfigVersions: 资源配置Versions集合 # @type ResourceConfigVersions: Array # @param JobConfigVersion: 作业配置版本 # @type JobConfigVersion: Integer # @param JobId: 作业ID # @type JobId: String # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :ResourceId, :Offset, :Limit, :ResourceConfigVersions, :JobConfigVersion, :JobId, :WorkSpaceId def initialize(resourceid=nil, offset=nil, limit=nil, resourceconfigversions=nil, jobconfigversion=nil, jobid=nil, workspaceid=nil) @ResourceId = resourceid @Offset = offset @Limit = limit @ResourceConfigVersions = resourceconfigversions @JobConfigVersion = jobconfigversion @JobId = jobid @WorkSpaceId = workspaceid end def deserialize(params) @ResourceId = params['ResourceId'] @Offset = params['Offset'] @Limit = params['Limit'] @ResourceConfigVersions = params['ResourceConfigVersions'] @JobConfigVersion = params['JobConfigVersion'] @JobId = params['JobId'] @WorkSpaceId = params['WorkSpaceId'] end end # DescribeResourceConfigs返回参数结构体 class DescribeResourceConfigsResponse < TencentCloud::Common::AbstractModel # @param ResourceConfigSet: 资源配置描述数组 # @type ResourceConfigSet: Array # @param TotalCount: 资源配置数量 # @type TotalCount: Integer # @param RequestId: 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :ResourceConfigSet, :TotalCount, :RequestId def initialize(resourceconfigset=nil, totalcount=nil, requestid=nil) @ResourceConfigSet = resourceconfigset @TotalCount = totalcount @RequestId = requestid end def deserialize(params) unless params['ResourceConfigSet'].nil? @ResourceConfigSet = [] params['ResourceConfigSet'].each do |i| resourceconfigitem_tmp = ResourceConfigItem.new resourceconfigitem_tmp.deserialize(i) @ResourceConfigSet << resourceconfigitem_tmp end end @TotalCount = params['TotalCount'] @RequestId = params['RequestId'] end end # DescribeResourceRelatedJobs请求参数结构体 class DescribeResourceRelatedJobsRequest < TencentCloud::Common::AbstractModel # @param ResourceId: 资源ID # @type ResourceId: String # @param DESCByJobConfigCreateTime: 默认0; 1: 按照作业版本创建时间降序 # @type DESCByJobConfigCreateTime: Integer # @param Offset: 偏移量,默认为0 # @type Offset: Integer # @param Limit: 分页大小,默认为20,最大值为100 # @type Limit: Integer # @param ResourceConfigVersion: 资源版本号 # @type ResourceConfigVersion: Integer # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :ResourceId, :DESCByJobConfigCreateTime, :Offset, :Limit, :ResourceConfigVersion, :WorkSpaceId def initialize(resourceid=nil, descbyjobconfigcreatetime=nil, offset=nil, limit=nil, resourceconfigversion=nil, workspaceid=nil) @ResourceId = resourceid @DESCByJobConfigCreateTime = descbyjobconfigcreatetime @Offset = offset @Limit = limit @ResourceConfigVersion = resourceconfigversion @WorkSpaceId = workspaceid end def deserialize(params) @ResourceId = params['ResourceId'] @DESCByJobConfigCreateTime = params['DESCByJobConfigCreateTime'] @Offset = params['Offset'] @Limit = params['Limit'] @ResourceConfigVersion = params['ResourceConfigVersion'] @WorkSpaceId = params['WorkSpaceId'] end end # DescribeResourceRelatedJobs返回参数结构体 class DescribeResourceRelatedJobsResponse < TencentCloud::Common::AbstractModel # @param TotalCount: 总数 # @type TotalCount: Integer # @param RefJobInfos: 关联作业信息 # @type RefJobInfos: Array # @param RequestId: 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :TotalCount, :RefJobInfos, :RequestId def initialize(totalcount=nil, refjobinfos=nil, requestid=nil) @TotalCount = totalcount @RefJobInfos = refjobinfos @RequestId = requestid end def deserialize(params) @TotalCount = params['TotalCount'] unless params['RefJobInfos'].nil? @RefJobInfos = [] params['RefJobInfos'].each do |i| resourcerefjobinfo_tmp = ResourceRefJobInfo.new resourcerefjobinfo_tmp.deserialize(i) @RefJobInfos << resourcerefjobinfo_tmp end end @RequestId = params['RequestId'] end end # DescribeResources请求参数结构体 class DescribeResourcesRequest < TencentCloud::Common::AbstractModel # @param ResourceIds: 需要查询的资源ID数组,数量不超过100个。如果填写了该参数则忽略Filters参数。 # @type ResourceIds: Array # @param Offset: 偏移量,仅当设置 Limit 参数时有效 # @type Offset: Integer # @param Limit: 条数限制。如果不填,默认返回 20 条 # @type Limit: Integer # @param Filters:
  • ResourceName
  • #

    按照资源名字过滤,支持模糊过滤。传入的过滤名字不超过5个

    类型: String

    必选: 否

    # @type Filters: Array # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :ResourceIds, :Offset, :Limit, :Filters, :WorkSpaceId def initialize(resourceids=nil, offset=nil, limit=nil, filters=nil, workspaceid=nil) @ResourceIds = resourceids @Offset = offset @Limit = limit @Filters = filters @WorkSpaceId = workspaceid end def deserialize(params) @ResourceIds = params['ResourceIds'] @Offset = params['Offset'] @Limit = params['Limit'] unless params['Filters'].nil? @Filters = [] params['Filters'].each do |i| filter_tmp = Filter.new filter_tmp.deserialize(i) @Filters << filter_tmp end end @WorkSpaceId = params['WorkSpaceId'] end end # DescribeResources返回参数结构体 class DescribeResourcesResponse < TencentCloud::Common::AbstractModel # @param ResourceSet: 资源详细信息集合 # @type ResourceSet: Array # @param TotalCount: 总数量 # @type TotalCount: Integer # @param RequestId: 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :ResourceSet, :TotalCount, :RequestId def initialize(resourceset=nil, totalcount=nil, requestid=nil) @ResourceSet = resourceset @TotalCount = totalcount @RequestId = requestid end def deserialize(params) unless params['ResourceSet'].nil? @ResourceSet = [] params['ResourceSet'].each do |i| resourceitem_tmp = ResourceItem.new resourceitem_tmp.deserialize(i) @ResourceSet << resourceitem_tmp end end @TotalCount = params['TotalCount'] @RequestId = params['RequestId'] end end # DescribeSystemResources请求参数结构体 class DescribeSystemResourcesRequest < TencentCloud::Common::AbstractModel # @param ResourceIds: 需要查询的资源ID数组 # @type ResourceIds: Array # @param Offset: 偏移量,仅当设置 Limit 参数时有效 # @type Offset: Integer # @param Limit: 条数限制,默认返回 20 条 # @type Limit: Integer # @param Filters: 查询资源配置列表, 如果不填写,返回该 ResourceIds.N 下所有作业配置列表 # @type Filters: Array # @param ClusterId: 集群ID # @type ClusterId: String # @param FlinkVersion: 查询对应Flink版本的内置connector # @type FlinkVersion: String attr_accessor :ResourceIds, :Offset, :Limit, :Filters, :ClusterId, :FlinkVersion def initialize(resourceids=nil, offset=nil, limit=nil, filters=nil, clusterid=nil, flinkversion=nil) @ResourceIds = resourceids @Offset = offset @Limit = limit @Filters = filters @ClusterId = clusterid @FlinkVersion = flinkversion end def deserialize(params) @ResourceIds = params['ResourceIds'] @Offset = params['Offset'] @Limit = params['Limit'] unless params['Filters'].nil? @Filters = [] params['Filters'].each do |i| filter_tmp = Filter.new filter_tmp.deserialize(i) @Filters << filter_tmp end end @ClusterId = params['ClusterId'] @FlinkVersion = params['FlinkVersion'] end end # DescribeSystemResources返回参数结构体 class DescribeSystemResourcesResponse < TencentCloud::Common::AbstractModel # @param ResourceSet: 资源详细信息集合 # @type ResourceSet: Array # @param TotalCount: 总数量 # @type TotalCount: Integer # @param RequestId: 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :ResourceSet, :TotalCount, :RequestId def initialize(resourceset=nil, totalcount=nil, requestid=nil) @ResourceSet = resourceset @TotalCount = totalcount @RequestId = requestid end def deserialize(params) unless params['ResourceSet'].nil? @ResourceSet = [] params['ResourceSet'].each do |i| systemresourceitem_tmp = SystemResourceItem.new systemresourceitem_tmp.deserialize(i) @ResourceSet << systemresourceitem_tmp end end @TotalCount = params['TotalCount'] @RequestId = params['RequestId'] end end # DescribeTreeJobs请求参数结构体 class DescribeTreeJobsRequest < TencentCloud::Common::AbstractModel # @param WorkSpaceId: 工作空间 Serialid # @type WorkSpaceId: String attr_accessor :WorkSpaceId def initialize(workspaceid=nil) @WorkSpaceId = workspaceid end def deserialize(params) @WorkSpaceId = params['WorkSpaceId'] end end # DescribeTreeJobs返回参数结构体 class DescribeTreeJobsResponse < 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 # DescribeTreeResources请求参数结构体 class DescribeTreeResourcesRequest < TencentCloud::Common::AbstractModel # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :WorkSpaceId def initialize(workspaceid=nil) @WorkSpaceId = workspaceid end def deserialize(params) @WorkSpaceId = params['WorkSpaceId'] end end # DescribeTreeResources返回参数结构体 class DescribeTreeResourcesResponse < TencentCloud::Common::AbstractModel # @param ParentId: 父节点ID # 注意:此字段可能返回 null,表示取不到有效值。 # @type ParentId: String # @param Id: 文件夹ID # 注意:此字段可能返回 null,表示取不到有效值。 # @type Id: String # @param Name: 文件夹名 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Name: String # @param Items: 文件列表 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Items: Array # @param Children: 子目录列表 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Children: Array # @param TotalCount: 资源总数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TotalCount: Integer # @param RequestId: 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :ParentId, :Id, :Name, :Items, :Children, :TotalCount, :RequestId def initialize(parentid=nil, id=nil, name=nil, items=nil, children=nil, totalcount=nil, requestid=nil) @ParentId = parentid @Id = id @Name = name @Items = items @Children = children @TotalCount = totalcount @RequestId = requestid end def deserialize(params) @ParentId = params['ParentId'] @Id = params['Id'] @Name = params['Name'] unless params['Items'].nil? @Items = [] params['Items'].each do |i| treeresourceitem_tmp = TreeResourceItem.new treeresourceitem_tmp.deserialize(i) @Items << treeresourceitem_tmp end end unless params['Children'].nil? @Children = [] params['Children'].each do |i| describetreeresourcesrsp_tmp = DescribeTreeResourcesRsp.new describetreeresourcesrsp_tmp.deserialize(i) @Children << describetreeresourcesrsp_tmp end end @TotalCount = params['TotalCount'] @RequestId = params['RequestId'] end end # 树状结构资源列表对象 class DescribeTreeResourcesRsp < TencentCloud::Common::AbstractModel # @param ParentId: 父节点ID # @type ParentId: String # @param Id: 文件夹ID # @type Id: String # @param Name: 文件夹名称 # @type Name: String # @param Items: 文件夹下资源数字 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Items: Array # @param Children: 子节点 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Children: Array # @param TotalCount: 资源总数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TotalCount: Integer attr_accessor :ParentId, :Id, :Name, :Items, :Children, :TotalCount def initialize(parentid=nil, id=nil, name=nil, items=nil, children=nil, totalcount=nil) @ParentId = parentid @Id = id @Name = name @Items = items @Children = children @TotalCount = totalcount end def deserialize(params) @ParentId = params['ParentId'] @Id = params['Id'] @Name = params['Name'] unless params['Items'].nil? @Items = [] params['Items'].each do |i| treeresourceitem_tmp = TreeResourceItem.new treeresourceitem_tmp.deserialize(i) @Items << treeresourceitem_tmp end end unless params['Children'].nil? @Children = [] params['Children'].each do |i| describetreeresourcesrsp_tmp = DescribeTreeResourcesRsp.new describetreeresourcesrsp_tmp.deserialize(i) @Children << describetreeresourcesrsp_tmp end end @TotalCount = params['TotalCount'] end end # 查询作业列表时的过滤器 class Filter < TencentCloud::Common::AbstractModel # @param Name: 要过滤的字段 # @type Name: String # @param Values: 字段的过滤值 # @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 JobConfig < TencentCloud::Common::AbstractModel # @param JobId: 作业Id # @type JobId: String # @param EntrypointClass: 主类 # 注意:此字段可能返回 null,表示取不到有效值。 # @type EntrypointClass: String # @param ProgramArgs: 主类入参 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ProgramArgs: String # @param Remark: 备注 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Remark: String # @param CreateTime: 作业配置创建时间 # @type CreateTime: String # @param Version: 作业配置的版本号 # @type Version: Integer # @param DefaultParallelism: 作业默认并行度 # 注意:此字段可能返回 null,表示取不到有效值。 # @type DefaultParallelism: Integer # @param Properties: 系统参数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Properties: Array # @param ResourceRefDetails: 引用资源 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ResourceRefDetails: Array # @param CreatorUin: 创建者uin # 注意:此字段可能返回 null,表示取不到有效值。 # @type CreatorUin: String # @param UpdateTime: 作业配置上次启动时间 # 注意:此字段可能返回 null,表示取不到有效值。 # @type UpdateTime: String # @param COSBucket: 作业绑定的存储桶 # 注意:此字段可能返回 null,表示取不到有效值。 # @type COSBucket: String # @param LogCollect: 是否启用日志收集,0-未启用,1-已启用,2-历史集群未设置日志集,3-历史集群已开启 # 注意:此字段可能返回 null,表示取不到有效值。 # @type LogCollect: Integer # @param MaxParallelism: 作业的最大并行度 # 注意:此字段可能返回 null,表示取不到有效值。 # @type MaxParallelism: Integer # @param JobManagerSpec: JobManager规格 # 注意:此字段可能返回 null,表示取不到有效值。 # @type JobManagerSpec: Float # @param TaskManagerSpec: TaskManager规格 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TaskManagerSpec: Float # @param ClsLogsetId: CLS日志集ID # 注意:此字段可能返回 null,表示取不到有效值。 # @type ClsLogsetId: String # @param ClsTopicId: CLS日志主题ID # 注意:此字段可能返回 null,表示取不到有效值。 # @type ClsTopicId: String # @param PythonVersion: pyflink作业运行的python版本 # 注意:此字段可能返回 null,表示取不到有效值。 # @type PythonVersion: String # @param AutoRecover: Oceanus 平台恢复作业开关 1:开启 -1: 关闭 # 注意:此字段可能返回 null,表示取不到有效值。 # @type AutoRecover: Integer # @param LogLevel: 日志级别 # 注意:此字段可能返回 null,表示取不到有效值。 # @type LogLevel: String attr_accessor :JobId, :EntrypointClass, :ProgramArgs, :Remark, :CreateTime, :Version, :DefaultParallelism, :Properties, :ResourceRefDetails, :CreatorUin, :UpdateTime, :COSBucket, :LogCollect, :MaxParallelism, :JobManagerSpec, :TaskManagerSpec, :ClsLogsetId, :ClsTopicId, :PythonVersion, :AutoRecover, :LogLevel def initialize(jobid=nil, entrypointclass=nil, programargs=nil, remark=nil, createtime=nil, version=nil, defaultparallelism=nil, properties=nil, resourcerefdetails=nil, creatoruin=nil, updatetime=nil, cosbucket=nil, logcollect=nil, maxparallelism=nil, jobmanagerspec=nil, taskmanagerspec=nil, clslogsetid=nil, clstopicid=nil, pythonversion=nil, autorecover=nil, loglevel=nil) @JobId = jobid @EntrypointClass = entrypointclass @ProgramArgs = programargs @Remark = remark @CreateTime = createtime @Version = version @DefaultParallelism = defaultparallelism @Properties = properties @ResourceRefDetails = resourcerefdetails @CreatorUin = creatoruin @UpdateTime = updatetime @COSBucket = cosbucket @LogCollect = logcollect @MaxParallelism = maxparallelism @JobManagerSpec = jobmanagerspec @TaskManagerSpec = taskmanagerspec @ClsLogsetId = clslogsetid @ClsTopicId = clstopicid @PythonVersion = pythonversion @AutoRecover = autorecover @LogLevel = loglevel end def deserialize(params) @JobId = params['JobId'] @EntrypointClass = params['EntrypointClass'] @ProgramArgs = params['ProgramArgs'] @Remark = params['Remark'] @CreateTime = params['CreateTime'] @Version = params['Version'] @DefaultParallelism = params['DefaultParallelism'] unless params['Properties'].nil? @Properties = [] params['Properties'].each do |i| property_tmp = Property.new property_tmp.deserialize(i) @Properties << property_tmp end end unless params['ResourceRefDetails'].nil? @ResourceRefDetails = [] params['ResourceRefDetails'].each do |i| resourcerefdetail_tmp = ResourceRefDetail.new resourcerefdetail_tmp.deserialize(i) @ResourceRefDetails << resourcerefdetail_tmp end end @CreatorUin = params['CreatorUin'] @UpdateTime = params['UpdateTime'] @COSBucket = params['COSBucket'] @LogCollect = params['LogCollect'] @MaxParallelism = params['MaxParallelism'] @JobManagerSpec = params['JobManagerSpec'] @TaskManagerSpec = params['TaskManagerSpec'] @ClsLogsetId = params['ClsLogsetId'] @ClsTopicId = params['ClsTopicId'] @PythonVersion = params['PythonVersion'] @AutoRecover = params['AutoRecover'] @LogLevel = params['LogLevel'] end end # Job详细信息 class JobV1 < TencentCloud::Common::AbstractModel # @param JobId: 作业ID # 注意:此字段可能返回 null,表示取不到有效值。 # @type JobId: String # @param Region: 地域 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Region: String # @param Zone: 可用区 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Zone: String # @param AppId: 用户AppId # 注意:此字段可能返回 null,表示取不到有效值。 # @type AppId: Integer # @param OwnerUin: 用户UIN # 注意:此字段可能返回 null,表示取不到有效值。 # @type OwnerUin: String # @param CreatorUin: 创建者UIN # 注意:此字段可能返回 null,表示取不到有效值。 # @type CreatorUin: String # @param Name: 作业名字 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Name: String # @param JobType: 作业类型,1:sql作业,2:Jar作业 # 注意:此字段可能返回 null,表示取不到有效值。 # @type JobType: Integer # @param Status: 作业状态,1:未初始化,2:未发布,3:操作中,4:运行中,5:停止,6:暂停,-1:故障 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Status: Integer # @param CreateTime: 作业创建时间 # 注意:此字段可能返回 null,表示取不到有效值。 # @type CreateTime: String # @param StartTime: 作业启动时间 # 注意:此字段可能返回 null,表示取不到有效值。 # @type StartTime: String # @param StopTime: 作业停止时间 # 注意:此字段可能返回 null,表示取不到有效值。 # @type StopTime: String # @param UpdateTime: 作业更新时间 # 注意:此字段可能返回 null,表示取不到有效值。 # @type UpdateTime: String # @param TotalRunMillis: 作业累计运行时间 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TotalRunMillis: Integer # @param Remark: 备注信息 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Remark: String # @param LastOpResult: 操作错误提示信息 # 注意:此字段可能返回 null,表示取不到有效值。 # @type LastOpResult: String # @param ClusterName: 集群名字 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ClusterName: String # @param LatestJobConfigVersion: 最新配置版本号 # 注意:此字段可能返回 null,表示取不到有效值。 # @type LatestJobConfigVersion: Integer # @param PublishedJobConfigVersion: 已发布的配置版本 # 注意:此字段可能返回 null,表示取不到有效值。 # @type PublishedJobConfigVersion: Integer # @param RunningCuNum: 运行的CU数量 # 注意:此字段可能返回 null,表示取不到有效值。 # @type RunningCuNum: Integer # @param CuMem: 作业内存规格 # 注意:此字段可能返回 null,表示取不到有效值。 # @type CuMem: Integer # @param StatusDesc: 作业状态描述 # 注意:此字段可能返回 null,表示取不到有效值。 # @type StatusDesc: String # @param CurrentRunMillis: 运行状态时表示单次运行时间 # 注意:此字段可能返回 null,表示取不到有效值。 # @type CurrentRunMillis: Integer # @param ClusterId: 作业所在的集群ID # 注意:此字段可能返回 null,表示取不到有效值。 # @type ClusterId: String # @param WebUIUrl: 作业管理WEB UI 入口 # 注意:此字段可能返回 null,表示取不到有效值。 # @type WebUIUrl: String # @param SchedulerType: 作业所在集群类型 # 注意:此字段可能返回 null,表示取不到有效值。 # @type SchedulerType: Integer # @param ClusterStatus: 作业所在集群状态 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ClusterStatus: Integer # @param RunningCu: 细粒度下的运行的CU数量 # 注意:此字段可能返回 null,表示取不到有效值。 # @type RunningCu: Float # @param FlinkVersion: 作业运行的 Flink 版本 # 注意:此字段可能返回 null,表示取不到有效值。 # @type FlinkVersion: String # @param WorkSpaceId: 工作空间 SerialId # 注意:此字段可能返回 null,表示取不到有效值。 # @type WorkSpaceId: String # @param WorkSpaceName: 工作空间名称 # 注意:此字段可能返回 null,表示取不到有效值。 # @type WorkSpaceName: String attr_accessor :JobId, :Region, :Zone, :AppId, :OwnerUin, :CreatorUin, :Name, :JobType, :Status, :CreateTime, :StartTime, :StopTime, :UpdateTime, :TotalRunMillis, :Remark, :LastOpResult, :ClusterName, :LatestJobConfigVersion, :PublishedJobConfigVersion, :RunningCuNum, :CuMem, :StatusDesc, :CurrentRunMillis, :ClusterId, :WebUIUrl, :SchedulerType, :ClusterStatus, :RunningCu, :FlinkVersion, :WorkSpaceId, :WorkSpaceName def initialize(jobid=nil, region=nil, zone=nil, appid=nil, owneruin=nil, creatoruin=nil, name=nil, jobtype=nil, status=nil, createtime=nil, starttime=nil, stoptime=nil, updatetime=nil, totalrunmillis=nil, remark=nil, lastopresult=nil, clustername=nil, latestjobconfigversion=nil, publishedjobconfigversion=nil, runningcunum=nil, cumem=nil, statusdesc=nil, currentrunmillis=nil, clusterid=nil, webuiurl=nil, schedulertype=nil, clusterstatus=nil, runningcu=nil, flinkversion=nil, workspaceid=nil, workspacename=nil) @JobId = jobid @Region = region @Zone = zone @AppId = appid @OwnerUin = owneruin @CreatorUin = creatoruin @Name = name @JobType = jobtype @Status = status @CreateTime = createtime @StartTime = starttime @StopTime = stoptime @UpdateTime = updatetime @TotalRunMillis = totalrunmillis @Remark = remark @LastOpResult = lastopresult @ClusterName = clustername @LatestJobConfigVersion = latestjobconfigversion @PublishedJobConfigVersion = publishedjobconfigversion @RunningCuNum = runningcunum @CuMem = cumem @StatusDesc = statusdesc @CurrentRunMillis = currentrunmillis @ClusterId = clusterid @WebUIUrl = webuiurl @SchedulerType = schedulertype @ClusterStatus = clusterstatus @RunningCu = runningcu @FlinkVersion = flinkversion @WorkSpaceId = workspaceid @WorkSpaceName = workspacename end def deserialize(params) @JobId = params['JobId'] @Region = params['Region'] @Zone = params['Zone'] @AppId = params['AppId'] @OwnerUin = params['OwnerUin'] @CreatorUin = params['CreatorUin'] @Name = params['Name'] @JobType = params['JobType'] @Status = params['Status'] @CreateTime = params['CreateTime'] @StartTime = params['StartTime'] @StopTime = params['StopTime'] @UpdateTime = params['UpdateTime'] @TotalRunMillis = params['TotalRunMillis'] @Remark = params['Remark'] @LastOpResult = params['LastOpResult'] @ClusterName = params['ClusterName'] @LatestJobConfigVersion = params['LatestJobConfigVersion'] @PublishedJobConfigVersion = params['PublishedJobConfigVersion'] @RunningCuNum = params['RunningCuNum'] @CuMem = params['CuMem'] @StatusDesc = params['StatusDesc'] @CurrentRunMillis = params['CurrentRunMillis'] @ClusterId = params['ClusterId'] @WebUIUrl = params['WebUIUrl'] @SchedulerType = params['SchedulerType'] @ClusterStatus = params['ClusterStatus'] @RunningCu = params['RunningCu'] @FlinkVersion = params['FlinkVersion'] @WorkSpaceId = params['WorkSpaceId'] @WorkSpaceName = params['WorkSpaceName'] end end # ModifyJob请求参数结构体 class ModifyJobRequest < TencentCloud::Common::AbstractModel # @param JobId: 作业Id # @type JobId: String # @param Name: 作业名称,支持长度小于50的中文/英文/数字/”-”/”_”/”.”,不能重名 # @type Name: String # @param Remark: 描述 # @type Remark: String # @param TargetFolderId: 拖拽文件需传入此参数 # @type TargetFolderId: String # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :JobId, :Name, :Remark, :TargetFolderId, :WorkSpaceId def initialize(jobid=nil, name=nil, remark=nil, targetfolderid=nil, workspaceid=nil) @JobId = jobid @Name = name @Remark = remark @TargetFolderId = targetfolderid @WorkSpaceId = workspaceid end def deserialize(params) @JobId = params['JobId'] @Name = params['Name'] @Remark = params['Remark'] @TargetFolderId = params['TargetFolderId'] @WorkSpaceId = params['WorkSpaceId'] end end # ModifyJob返回参数结构体 class ModifyJobResponse < 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 Property < TencentCloud::Common::AbstractModel # @param Key: 系统配置的Key # @type Key: String # @param Value: 系统配置的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 # 依赖作业分状态计数信息 class RefJobStatusCountItem < TencentCloud::Common::AbstractModel # @param JobStatus: 作业状态 # 注意:此字段可能返回 null,表示取不到有效值。 # @type JobStatus: Integer # @param Count: 作业数量 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Count: Integer attr_accessor :JobStatus, :Count def initialize(jobstatus=nil, count=nil) @JobStatus = jobstatus @Count = count end def deserialize(params) @JobStatus = params['JobStatus'] @Count = params['Count'] end end # 描述资源配置的返回参数 class ResourceConfigItem < TencentCloud::Common::AbstractModel # @param ResourceId: 资源ID # @type ResourceId: String # @param ResourceType: 资源类型 # @type ResourceType: Integer # @param Region: 资源所属地域 # @type Region: String # @param AppId: 资源所属AppId # @type AppId: Integer # @param OwnerUin: 主账号Uin # @type OwnerUin: String # @param CreatorUin: 子账号Uin # @type CreatorUin: String # @param ResourceLoc: 资源位置描述 # @type ResourceLoc: :class:`Tencentcloud::Oceanus.v20190422.models.ResourceLoc` # @param CreateTime: 资源创建时间 # @type CreateTime: String # @param Version: 资源版本 # @type Version: Integer # @param Remark: 资源描述 # @type Remark: String # @param Status: 资源状态:0: 资源同步中,1:资源已就绪 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Status: Integer # @param RefJobCount: 关联作业个数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type RefJobCount: Integer # @param RefJobStatusCountSet: 分状态统计关联作业数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type RefJobStatusCountSet: Array attr_accessor :ResourceId, :ResourceType, :Region, :AppId, :OwnerUin, :CreatorUin, :ResourceLoc, :CreateTime, :Version, :Remark, :Status, :RefJobCount, :RefJobStatusCountSet def initialize(resourceid=nil, resourcetype=nil, region=nil, appid=nil, owneruin=nil, creatoruin=nil, resourceloc=nil, createtime=nil, version=nil, remark=nil, status=nil, refjobcount=nil, refjobstatuscountset=nil) @ResourceId = resourceid @ResourceType = resourcetype @Region = region @AppId = appid @OwnerUin = owneruin @CreatorUin = creatoruin @ResourceLoc = resourceloc @CreateTime = createtime @Version = version @Remark = remark @Status = status @RefJobCount = refjobcount @RefJobStatusCountSet = refjobstatuscountset end def deserialize(params) @ResourceId = params['ResourceId'] @ResourceType = params['ResourceType'] @Region = params['Region'] @AppId = params['AppId'] @OwnerUin = params['OwnerUin'] @CreatorUin = params['CreatorUin'] unless params['ResourceLoc'].nil? @ResourceLoc = ResourceLoc.new @ResourceLoc.deserialize(params['ResourceLoc']) end @CreateTime = params['CreateTime'] @Version = params['Version'] @Remark = params['Remark'] @Status = params['Status'] @RefJobCount = params['RefJobCount'] unless params['RefJobStatusCountSet'].nil? @RefJobStatusCountSet = [] params['RefJobStatusCountSet'].each do |i| refjobstatuscountitem_tmp = RefJobStatusCountItem.new refjobstatuscountitem_tmp.deserialize(i) @RefJobStatusCountSet << refjobstatuscountitem_tmp end end end end # 资源详细描述 class ResourceItem < TencentCloud::Common::AbstractModel # @param ResourceId: 资源ID # @type ResourceId: String # @param Name: 资源名称 # @type Name: String # @param ResourceType: 资源类型 # @type ResourceType: Integer # @param ResourceLoc: 资源位置 # @type ResourceLoc: :class:`Tencentcloud::Oceanus.v20190422.models.ResourceLoc` # @param Region: 资源地域 # @type Region: String # @param AppId: 应用ID # @type AppId: Integer # @param OwnerUin: 主账号Uin # @type OwnerUin: String # @param CreatorUin: 子账号Uin # @type CreatorUin: String # @param CreateTime: 资源创建时间 # @type CreateTime: String # @param UpdateTime: 资源最后更新时间 # @type UpdateTime: String # @param LatestResourceConfigVersion: 资源的资源版本ID # @type LatestResourceConfigVersion: Integer # @param Remark: 资源备注 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Remark: String # @param VersionCount: 版本个数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type VersionCount: Integer # @param RefJobCount: 关联作业数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type RefJobCount: Integer # @param IsJobRun: 作业运行状态 # 注意:此字段可能返回 null,表示取不到有效值。 # @type IsJobRun: Integer # @param FileName: 文件名 # 注意:此字段可能返回 null,表示取不到有效值。 # @type FileName: String # @param WorkSpaceId: 工作空间ID # 注意:此字段可能返回 null,表示取不到有效值。 # @type WorkSpaceId: Integer # @param RefJobStatusCountSet: 分状态统计关联作业数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type RefJobStatusCountSet: Array attr_accessor :ResourceId, :Name, :ResourceType, :ResourceLoc, :Region, :AppId, :OwnerUin, :CreatorUin, :CreateTime, :UpdateTime, :LatestResourceConfigVersion, :Remark, :VersionCount, :RefJobCount, :IsJobRun, :FileName, :WorkSpaceId, :RefJobStatusCountSet def initialize(resourceid=nil, name=nil, resourcetype=nil, resourceloc=nil, region=nil, appid=nil, owneruin=nil, creatoruin=nil, createtime=nil, updatetime=nil, latestresourceconfigversion=nil, remark=nil, versioncount=nil, refjobcount=nil, isjobrun=nil, filename=nil, workspaceid=nil, refjobstatuscountset=nil) @ResourceId = resourceid @Name = name @ResourceType = resourcetype @ResourceLoc = resourceloc @Region = region @AppId = appid @OwnerUin = owneruin @CreatorUin = creatoruin @CreateTime = createtime @UpdateTime = updatetime @LatestResourceConfigVersion = latestresourceconfigversion @Remark = remark @VersionCount = versioncount @RefJobCount = refjobcount @IsJobRun = isjobrun @FileName = filename @WorkSpaceId = workspaceid @RefJobStatusCountSet = refjobstatuscountset end def deserialize(params) @ResourceId = params['ResourceId'] @Name = params['Name'] @ResourceType = params['ResourceType'] unless params['ResourceLoc'].nil? @ResourceLoc = ResourceLoc.new @ResourceLoc.deserialize(params['ResourceLoc']) end @Region = params['Region'] @AppId = params['AppId'] @OwnerUin = params['OwnerUin'] @CreatorUin = params['CreatorUin'] @CreateTime = params['CreateTime'] @UpdateTime = params['UpdateTime'] @LatestResourceConfigVersion = params['LatestResourceConfigVersion'] @Remark = params['Remark'] @VersionCount = params['VersionCount'] @RefJobCount = params['RefJobCount'] @IsJobRun = params['IsJobRun'] @FileName = params['FileName'] @WorkSpaceId = params['WorkSpaceId'] unless params['RefJobStatusCountSet'].nil? @RefJobStatusCountSet = [] params['RefJobStatusCountSet'].each do |i| refjobstatuscountitem_tmp = RefJobStatusCountItem.new refjobstatuscountitem_tmp.deserialize(i) @RefJobStatusCountSet << refjobstatuscountitem_tmp end end end end # 资源位置描述 class ResourceLoc < TencentCloud::Common::AbstractModel # @param StorageType: 资源位置的存储类型,目前只支持1:COS # @type StorageType: Integer # @param Param: 描述资源位置的json # @type Param: :class:`Tencentcloud::Oceanus.v20190422.models.ResourceLocParam` attr_accessor :StorageType, :Param def initialize(storagetype=nil, param=nil) @StorageType = storagetype @Param = param end def deserialize(params) @StorageType = params['StorageType'] unless params['Param'].nil? @Param = ResourceLocParam.new @Param.deserialize(params['Param']) end end end # 资源参数描述 class ResourceLocParam < TencentCloud::Common::AbstractModel # @param Bucket: 资源bucket # @type Bucket: String # @param Path: 资源路径 # @type Path: String # @param Region: 资源所在地域,如果不填,则使用Resource的Region # 注意:此字段可能返回 null,表示取不到有效值。 # @type Region: String attr_accessor :Bucket, :Path, :Region def initialize(bucket=nil, path=nil, region=nil) @Bucket = bucket @Path = path @Region = region end def deserialize(params) @Bucket = params['Bucket'] @Path = params['Path'] @Region = params['Region'] end end # 资源引用参数 class ResourceRef < TencentCloud::Common::AbstractModel # @param ResourceId: 资源ID # @type ResourceId: String # @param Version: 资源版本ID,-1表示使用最新版本 # @type Version: Integer # @param Type: 引用资源类型,例如主资源设置为1,代表main class所在的jar包 # @type Type: Integer attr_accessor :ResourceId, :Version, :Type def initialize(resourceid=nil, version=nil, type=nil) @ResourceId = resourceid @Version = version @Type = type end def deserialize(params) @ResourceId = params['ResourceId'] @Version = params['Version'] @Type = params['Type'] end end # JobConfig引用资源信息 class ResourceRefDetail < TencentCloud::Common::AbstractModel # @param ResourceId: 资源id # @type ResourceId: String # @param Version: 资源版本,-1表示使用最新版本 # @type Version: Integer # @param Name: 资源名称 # @type Name: String # @param Type: 1: 主资源 # @type Type: Integer # @param SystemProvide: 1: 系统内置资源 # @type SystemProvide: Integer attr_accessor :ResourceId, :Version, :Name, :Type, :SystemProvide def initialize(resourceid=nil, version=nil, name=nil, type=nil, systemprovide=nil) @ResourceId = resourceid @Version = version @Name = name @Type = type @SystemProvide = systemprovide end def deserialize(params) @ResourceId = params['ResourceId'] @Version = params['Version'] @Name = params['Name'] @Type = params['Type'] @SystemProvide = params['SystemProvide'] end end # 资源被Job 引用信息 class ResourceRefJobInfo < TencentCloud::Common::AbstractModel # @param JobId: Job id # @type JobId: String # @param JobConfigVersion: Job配置版本 # @type JobConfigVersion: Integer # @param ResourceVersion: 资源版本 # @type ResourceVersion: Integer attr_accessor :JobId, :JobConfigVersion, :ResourceVersion def initialize(jobid=nil, jobconfigversion=nil, resourceversion=nil) @JobId = jobid @JobConfigVersion = jobconfigversion @ResourceVersion = resourceversion end def deserialize(params) @JobId = params['JobId'] @JobConfigVersion = params['JobConfigVersion'] @ResourceVersion = params['ResourceVersion'] end end # 作业启动详情 class RunJobDescription < TencentCloud::Common::AbstractModel # @param JobId: 作业Id # @type JobId: String # @param RunType: 运行类型,1:启动,2:恢复 # @type RunType: Integer # @param StartMode: 兼容旧版 SQL 类型作业启动参数:指定数据源消费起始时间点(例:T1557394288000) # @type StartMode: String # @param JobConfigVersion: 当前作业的某个版本 # @type JobConfigVersion: Integer # @param SavepointPath: Savepoint路径 # @type SavepointPath: String # @param SavepointId: Savepoint的Id # @type SavepointId: String # @param UseOldSystemConnector: 使用历史版本系统依赖 # 注意:此字段可能返回 null,表示取不到有效值。 # @type UseOldSystemConnector: Boolean attr_accessor :JobId, :RunType, :StartMode, :JobConfigVersion, :SavepointPath, :SavepointId, :UseOldSystemConnector def initialize(jobid=nil, runtype=nil, startmode=nil, jobconfigversion=nil, savepointpath=nil, savepointid=nil, useoldsystemconnector=nil) @JobId = jobid @RunType = runtype @StartMode = startmode @JobConfigVersion = jobconfigversion @SavepointPath = savepointpath @SavepointId = savepointid @UseOldSystemConnector = useoldsystemconnector end def deserialize(params) @JobId = params['JobId'] @RunType = params['RunType'] @StartMode = params['StartMode'] @JobConfigVersion = params['JobConfigVersion'] @SavepointPath = params['SavepointPath'] @SavepointId = params['SavepointId'] @UseOldSystemConnector = params['UseOldSystemConnector'] end end # RunJobs请求参数结构体 class RunJobsRequest < TencentCloud::Common::AbstractModel # @param RunJobDescriptions: 批量启动作业的描述信息 # @type RunJobDescriptions: Array # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :RunJobDescriptions, :WorkSpaceId def initialize(runjobdescriptions=nil, workspaceid=nil) @RunJobDescriptions = runjobdescriptions @WorkSpaceId = workspaceid end def deserialize(params) unless params['RunJobDescriptions'].nil? @RunJobDescriptions = [] params['RunJobDescriptions'].each do |i| runjobdescription_tmp = RunJobDescription.new runjobdescription_tmp.deserialize(i) @RunJobDescriptions << runjobdescription_tmp end end @WorkSpaceId = params['WorkSpaceId'] end end # RunJobs返回参数结构体 class RunJobsResponse < 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 # 描述Savepoint信息 class Savepoint < TencentCloud::Common::AbstractModel # @param Id: 主键 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Id: Integer # @param VersionId: 版本号 # 注意:此字段可能返回 null,表示取不到有效值。 # @type VersionId: Integer # @param Status: 状态 1: Active; 2: Expired; 3: InProgress; 4: Failed; 5: Timeout # 注意:此字段可能返回 null,表示取不到有效值。 # @type Status: Integer # @param CreateTime: 创建时间 # 注意:此字段可能返回 null,表示取不到有效值。 # @type CreateTime: Integer # @param UpdateTime: 更新时间 # 注意:此字段可能返回 null,表示取不到有效值。 # @type UpdateTime: Integer # @param Path: 路径 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Path: String # @param Size: 大小 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Size: Integer # @param RecordType: 快照类型 1: savepoint;2: checkpoint;3: cancelWithSavepoint # 注意:此字段可能返回 null,表示取不到有效值。 # @type RecordType: Integer # @param JobRuntimeId: 运行作业实例的顺序 ID # 注意:此字段可能返回 null,表示取不到有效值。 # @type JobRuntimeId: Integer # @param Description: 描述 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Description: String # @param Timeout: 固定超时时间 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Timeout: Integer # @param SerialId: 快照 serialId # 注意:此字段可能返回 null,表示取不到有效值。 # @type SerialId: String # @param TimeConsuming: 耗时 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TimeConsuming: Integer # @param PathStatus: 快照路径状态 1:可用;2:不可用; # 注意:此字段可能返回 null,表示取不到有效值。 # @type PathStatus: Integer attr_accessor :Id, :VersionId, :Status, :CreateTime, :UpdateTime, :Path, :Size, :RecordType, :JobRuntimeId, :Description, :Timeout, :SerialId, :TimeConsuming, :PathStatus def initialize(id=nil, versionid=nil, status=nil, createtime=nil, updatetime=nil, path=nil, size=nil, recordtype=nil, jobruntimeid=nil, description=nil, timeout=nil, serialid=nil, timeconsuming=nil, pathstatus=nil) @Id = id @VersionId = versionid @Status = status @CreateTime = createtime @UpdateTime = updatetime @Path = path @Size = size @RecordType = recordtype @JobRuntimeId = jobruntimeid @Description = description @Timeout = timeout @SerialId = serialid @TimeConsuming = timeconsuming @PathStatus = pathstatus end def deserialize(params) @Id = params['Id'] @VersionId = params['VersionId'] @Status = params['Status'] @CreateTime = params['CreateTime'] @UpdateTime = params['UpdateTime'] @Path = params['Path'] @Size = params['Size'] @RecordType = params['RecordType'] @JobRuntimeId = params['JobRuntimeId'] @Description = params['Description'] @Timeout = params['Timeout'] @SerialId = params['SerialId'] @TimeConsuming = params['TimeConsuming'] @PathStatus = params['PathStatus'] end end # 停止作业的描述信息 class StopJobDescription < TencentCloud::Common::AbstractModel # @param JobId: 作业Id # @type JobId: String # @param StopType: 停止类型,1 停止 2 暂停 # @type StopType: Integer attr_accessor :JobId, :StopType def initialize(jobid=nil, stoptype=nil) @JobId = jobid @StopType = stoptype end def deserialize(params) @JobId = params['JobId'] @StopType = params['StopType'] end end # StopJobs请求参数结构体 class StopJobsRequest < TencentCloud::Common::AbstractModel # @param StopJobDescriptions: 批量停止作业的描述信息 # @type StopJobDescriptions: Array # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :StopJobDescriptions, :WorkSpaceId def initialize(stopjobdescriptions=nil, workspaceid=nil) @StopJobDescriptions = stopjobdescriptions @WorkSpaceId = workspaceid end def deserialize(params) unless params['StopJobDescriptions'].nil? @StopJobDescriptions = [] params['StopJobDescriptions'].each do |i| stopjobdescription_tmp = StopJobDescription.new stopjobdescription_tmp.deserialize(i) @StopJobDescriptions << stopjobdescription_tmp end end @WorkSpaceId = params['WorkSpaceId'] end end # StopJobs返回参数结构体 class StopJobsResponse < 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 SystemResourceItem < TencentCloud::Common::AbstractModel # @param ResourceId: 资源ID # @type ResourceId: String # @param Name: 资源名称 # @type Name: String # @param ResourceType: 资源类型。1 表示 JAR 包,目前只支持该值。 # @type ResourceType: Integer # @param Remark: 资源备注 # @type Remark: String # @param Region: 资源所属地域 # @type Region: String # @param LatestResourceConfigVersion: 资源的最新版本 # @type LatestResourceConfigVersion: Integer attr_accessor :ResourceId, :Name, :ResourceType, :Remark, :Region, :LatestResourceConfigVersion def initialize(resourceid=nil, name=nil, resourcetype=nil, remark=nil, region=nil, latestresourceconfigversion=nil) @ResourceId = resourceid @Name = name @ResourceType = resourcetype @Remark = remark @Region = region @LatestResourceConfigVersion = latestresourceconfigversion end def deserialize(params) @ResourceId = params['ResourceId'] @Name = params['Name'] @ResourceType = params['ResourceType'] @Remark = params['Remark'] @Region = params['Region'] @LatestResourceConfigVersion = params['LatestResourceConfigVersion'] end end # 标签 class Tag < TencentCloud::Common::AbstractModel # @param TagKey: 标签键 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TagKey: String # @param TagValue: 标签值 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TagValue: String attr_accessor :TagKey, :TagValue def initialize(tagkey=nil, tagvalue=nil) @TagKey = tagkey @TagValue = tagvalue end def deserialize(params) @TagKey = params['TagKey'] @TagValue = params['TagValue'] end end # 树状结构资源对象 class TreeResourceItem < TencentCloud::Common::AbstractModel # @param ResourceId: 资源ID # @type ResourceId: String # @param Name: 资源名称 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Name: String # @param ResourceType: 资源类型 # @type ResourceType: Integer # @param Remark: 备注 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Remark: String # @param FileName: 文件名 # 注意:此字段可能返回 null,表示取不到有效值。 # @type FileName: String # @param FolderId: 目录ID # 注意:此字段可能返回 null,表示取不到有效值。 # @type FolderId: String attr_accessor :ResourceId, :Name, :ResourceType, :Remark, :FileName, :FolderId def initialize(resourceid=nil, name=nil, resourcetype=nil, remark=nil, filename=nil, folderid=nil) @ResourceId = resourceid @Name = name @ResourceType = resourcetype @Remark = remark @FileName = filename @FolderId = folderid end def deserialize(params) @ResourceId = params['ResourceId'] @Name = params['Name'] @ResourceType = params['ResourceType'] @Remark = params['Remark'] @FileName = params['FileName'] @FolderId = params['FolderId'] end end # TriggerJobSavepoint请求参数结构体 class TriggerJobSavepointRequest < TencentCloud::Common::AbstractModel # @param JobId: 作业 SerialId # @type JobId: String # @param Description: 描述 # @type Description: String # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String attr_accessor :JobId, :Description, :WorkSpaceId def initialize(jobid=nil, description=nil, workspaceid=nil) @JobId = jobid @Description = description @WorkSpaceId = workspaceid end def deserialize(params) @JobId = params['JobId'] @Description = params['Description'] @WorkSpaceId = params['WorkSpaceId'] end end # TriggerJobSavepoint返回参数结构体 class TriggerJobSavepointResponse < TencentCloud::Common::AbstractModel # @param SavepointTrigger: 是否成功 # @type SavepointTrigger: Boolean # @param ErrorMsg: 错误消息 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ErrorMsg: String # @param FinalSavepointPath: 快照路径 # 注意:此字段可能返回 null,表示取不到有效值。 # @type FinalSavepointPath: String # @param SavepointId: 快照 ID # 注意:此字段可能返回 null,表示取不到有效值。 # @type SavepointId: String # @param RequestId: 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :SavepointTrigger, :ErrorMsg, :FinalSavepointPath, :SavepointId, :RequestId def initialize(savepointtrigger=nil, errormsg=nil, finalsavepointpath=nil, savepointid=nil, requestid=nil) @SavepointTrigger = savepointtrigger @ErrorMsg = errormsg @FinalSavepointPath = finalsavepointpath @SavepointId = savepointid @RequestId = requestid end def deserialize(params) @SavepointTrigger = params['SavepointTrigger'] @ErrorMsg = params['ErrorMsg'] @FinalSavepointPath = params['FinalSavepointPath'] @SavepointId = params['SavepointId'] @RequestId = params['RequestId'] end end # 空间和集群绑定关系 class WorkSpaceClusterItem < TencentCloud::Common::AbstractModel # @param ClusterGroupId: 集群 ID # @type ClusterGroupId: Integer # @param ClusterGroupSerialId: 集群 SerialId # @type ClusterGroupSerialId: String # @param ClusterName: 集群名称 # @type ClusterName: String # @param WorkSpaceId: 工作空间 SerialId # @type WorkSpaceId: String # @param WorkSpaceName: 工作空间名称 # @type WorkSpaceName: String # @param Status: 绑定状态 2 绑定 1 解除绑定 # @type Status: Integer # @param ProjectId: 项目ID # @type ProjectId: Integer # @param ProjectIdStr: 项目ID string类型 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ProjectIdStr: String attr_accessor :ClusterGroupId, :ClusterGroupSerialId, :ClusterName, :WorkSpaceId, :WorkSpaceName, :Status, :ProjectId, :ProjectIdStr def initialize(clustergroupid=nil, clustergroupserialid=nil, clustername=nil, workspaceid=nil, workspacename=nil, status=nil, projectid=nil, projectidstr=nil) @ClusterGroupId = clustergroupid @ClusterGroupSerialId = clustergroupserialid @ClusterName = clustername @WorkSpaceId = workspaceid @WorkSpaceName = workspacename @Status = status @ProjectId = projectid @ProjectIdStr = projectidstr end def deserialize(params) @ClusterGroupId = params['ClusterGroupId'] @ClusterGroupSerialId = params['ClusterGroupSerialId'] @ClusterName = params['ClusterName'] @WorkSpaceId = params['WorkSpaceId'] @WorkSpaceName = params['WorkSpaceName'] @Status = params['Status'] @ProjectId = params['ProjectId'] @ProjectIdStr = params['ProjectIdStr'] end end end end end