Documentation ¶
Index ¶
- Constants
- type CCN
- type CheckSavepointRequest
- type CheckSavepointRequestParams
- type CheckSavepointResponse
- type CheckSavepointResponseParams
- type ClazzLevel
- type Client
- func (c *Client) CheckSavepoint(request *CheckSavepointRequest) (response *CheckSavepointResponse, err error)
- func (c *Client) CheckSavepointWithContext(ctx context.Context, request *CheckSavepointRequest) (response *CheckSavepointResponse, err error)
- func (c *Client) CopyJobs(request *CopyJobsRequest) (response *CopyJobsResponse, err error)
- func (c *Client) CopyJobsWithContext(ctx context.Context, request *CopyJobsRequest) (response *CopyJobsResponse, err error)
- func (c *Client) CreateFolder(request *CreateFolderRequest) (response *CreateFolderResponse, err error)
- func (c *Client) CreateFolderWithContext(ctx context.Context, request *CreateFolderRequest) (response *CreateFolderResponse, err error)
- func (c *Client) CreateJob(request *CreateJobRequest) (response *CreateJobResponse, err error)
- func (c *Client) CreateJobConfig(request *CreateJobConfigRequest) (response *CreateJobConfigResponse, err error)
- func (c *Client) CreateJobConfigWithContext(ctx context.Context, request *CreateJobConfigRequest) (response *CreateJobConfigResponse, err error)
- func (c *Client) CreateJobWithContext(ctx context.Context, request *CreateJobRequest) (response *CreateJobResponse, err error)
- func (c *Client) CreateResource(request *CreateResourceRequest) (response *CreateResourceResponse, err error)
- func (c *Client) CreateResourceConfig(request *CreateResourceConfigRequest) (response *CreateResourceConfigResponse, err error)
- func (c *Client) CreateResourceConfigWithContext(ctx context.Context, request *CreateResourceConfigRequest) (response *CreateResourceConfigResponse, err error)
- func (c *Client) CreateResourceWithContext(ctx context.Context, request *CreateResourceRequest) (response *CreateResourceResponse, err error)
- func (c *Client) CreateWorkSpace(request *CreateWorkSpaceRequest) (response *CreateWorkSpaceResponse, err error)
- func (c *Client) CreateWorkSpaceWithContext(ctx context.Context, request *CreateWorkSpaceRequest) (response *CreateWorkSpaceResponse, err error)
- func (c *Client) DeleteFolders(request *DeleteFoldersRequest) (response *DeleteFoldersResponse, err error)
- func (c *Client) DeleteFoldersWithContext(ctx context.Context, request *DeleteFoldersRequest) (response *DeleteFoldersResponse, err error)
- func (c *Client) DeleteJobConfigs(request *DeleteJobConfigsRequest) (response *DeleteJobConfigsResponse, err error)
- func (c *Client) DeleteJobConfigsWithContext(ctx context.Context, request *DeleteJobConfigsRequest) (response *DeleteJobConfigsResponse, err error)
- func (c *Client) DeleteJobs(request *DeleteJobsRequest) (response *DeleteJobsResponse, err error)
- func (c *Client) DeleteJobsWithContext(ctx context.Context, request *DeleteJobsRequest) (response *DeleteJobsResponse, err error)
- func (c *Client) DeleteResourceConfigs(request *DeleteResourceConfigsRequest) (response *DeleteResourceConfigsResponse, err error)
- func (c *Client) DeleteResourceConfigsWithContext(ctx context.Context, request *DeleteResourceConfigsRequest) (response *DeleteResourceConfigsResponse, err error)
- func (c *Client) DeleteResources(request *DeleteResourcesRequest) (response *DeleteResourcesResponse, err error)
- func (c *Client) DeleteResourcesWithContext(ctx context.Context, request *DeleteResourcesRequest) (response *DeleteResourcesResponse, err error)
- func (c *Client) DeleteTableConfig(request *DeleteTableConfigRequest) (response *DeleteTableConfigResponse, err error)
- func (c *Client) DeleteTableConfigWithContext(ctx context.Context, request *DeleteTableConfigRequest) (response *DeleteTableConfigResponse, err error)
- func (c *Client) DeleteWorkSpace(request *DeleteWorkSpaceRequest) (response *DeleteWorkSpaceResponse, err error)
- func (c *Client) DeleteWorkSpaceWithContext(ctx context.Context, request *DeleteWorkSpaceRequest) (response *DeleteWorkSpaceResponse, err error)
- func (c *Client) DescribeClusters(request *DescribeClustersRequest) (response *DescribeClustersResponse, err error)
- func (c *Client) DescribeClustersWithContext(ctx context.Context, request *DescribeClustersRequest) (response *DescribeClustersResponse, err error)
- func (c *Client) DescribeFolder(request *DescribeFolderRequest) (response *DescribeFolderResponse, err error)
- func (c *Client) DescribeFolderWithContext(ctx context.Context, request *DescribeFolderRequest) (response *DescribeFolderResponse, err error)
- func (c *Client) DescribeJobConfigs(request *DescribeJobConfigsRequest) (response *DescribeJobConfigsResponse, err error)
- func (c *Client) DescribeJobConfigsWithContext(ctx context.Context, request *DescribeJobConfigsRequest) (response *DescribeJobConfigsResponse, err error)
- func (c *Client) DescribeJobEvents(request *DescribeJobEventsRequest) (response *DescribeJobEventsResponse, err error)
- func (c *Client) DescribeJobEventsWithContext(ctx context.Context, request *DescribeJobEventsRequest) (response *DescribeJobEventsResponse, err error)
- func (c *Client) DescribeJobSavepoint(request *DescribeJobSavepointRequest) (response *DescribeJobSavepointResponse, err error)
- func (c *Client) DescribeJobSavepointWithContext(ctx context.Context, request *DescribeJobSavepointRequest) (response *DescribeJobSavepointResponse, err error)
- func (c *Client) DescribeJobSubmissionLog(request *DescribeJobSubmissionLogRequest) (response *DescribeJobSubmissionLogResponse, err error)
- func (c *Client) DescribeJobSubmissionLogWithContext(ctx context.Context, request *DescribeJobSubmissionLogRequest) (response *DescribeJobSubmissionLogResponse, err error)
- func (c *Client) DescribeJobs(request *DescribeJobsRequest) (response *DescribeJobsResponse, err error)
- func (c *Client) DescribeJobsWithContext(ctx context.Context, request *DescribeJobsRequest) (response *DescribeJobsResponse, err error)
- func (c *Client) DescribeResourceConfigs(request *DescribeResourceConfigsRequest) (response *DescribeResourceConfigsResponse, err error)
- func (c *Client) DescribeResourceConfigsWithContext(ctx context.Context, request *DescribeResourceConfigsRequest) (response *DescribeResourceConfigsResponse, err error)
- func (c *Client) DescribeResourceRelatedJobs(request *DescribeResourceRelatedJobsRequest) (response *DescribeResourceRelatedJobsResponse, err error)
- func (c *Client) DescribeResourceRelatedJobsWithContext(ctx context.Context, request *DescribeResourceRelatedJobsRequest) (response *DescribeResourceRelatedJobsResponse, err error)
- func (c *Client) DescribeResources(request *DescribeResourcesRequest) (response *DescribeResourcesResponse, err error)
- func (c *Client) DescribeResourcesWithContext(ctx context.Context, request *DescribeResourcesRequest) (response *DescribeResourcesResponse, err error)
- func (c *Client) DescribeSystemResources(request *DescribeSystemResourcesRequest) (response *DescribeSystemResourcesResponse, err error)
- func (c *Client) DescribeSystemResourcesWithContext(ctx context.Context, request *DescribeSystemResourcesRequest) (response *DescribeSystemResourcesResponse, err error)
- func (c *Client) DescribeTreeJobs(request *DescribeTreeJobsRequest) (response *DescribeTreeJobsResponse, err error)
- func (c *Client) DescribeTreeJobsWithContext(ctx context.Context, request *DescribeTreeJobsRequest) (response *DescribeTreeJobsResponse, err error)
- func (c *Client) DescribeTreeResources(request *DescribeTreeResourcesRequest) (response *DescribeTreeResourcesResponse, err error)
- func (c *Client) DescribeTreeResourcesWithContext(ctx context.Context, request *DescribeTreeResourcesRequest) (response *DescribeTreeResourcesResponse, err error)
- func (c *Client) DescribeWorkSpaces(request *DescribeWorkSpacesRequest) (response *DescribeWorkSpacesResponse, err error)
- func (c *Client) DescribeWorkSpacesWithContext(ctx context.Context, request *DescribeWorkSpacesRequest) (response *DescribeWorkSpacesResponse, err error)
- func (c *Client) FetchSqlGatewayStatementResult(request *FetchSqlGatewayStatementResultRequest) (response *FetchSqlGatewayStatementResultResponse, err error)
- func (c *Client) FetchSqlGatewayStatementResultWithContext(ctx context.Context, request *FetchSqlGatewayStatementResultRequest) (response *FetchSqlGatewayStatementResultResponse, err error)
- func (c *Client) GetMetaTable(request *GetMetaTableRequest) (response *GetMetaTableResponse, err error)
- func (c *Client) GetMetaTableWithContext(ctx context.Context, request *GetMetaTableRequest) (response *GetMetaTableResponse, err error)
- func (c *Client) ModifyFolder(request *ModifyFolderRequest) (response *ModifyFolderResponse, err error)
- func (c *Client) ModifyFolderWithContext(ctx context.Context, request *ModifyFolderRequest) (response *ModifyFolderResponse, err error)
- func (c *Client) ModifyJob(request *ModifyJobRequest) (response *ModifyJobResponse, err error)
- func (c *Client) ModifyJobWithContext(ctx context.Context, request *ModifyJobRequest) (response *ModifyJobResponse, err error)
- func (c *Client) ModifyWorkSpace(request *ModifyWorkSpaceRequest) (response *ModifyWorkSpaceResponse, err error)
- func (c *Client) ModifyWorkSpaceWithContext(ctx context.Context, request *ModifyWorkSpaceRequest) (response *ModifyWorkSpaceResponse, err error)
- func (c *Client) RunJobs(request *RunJobsRequest) (response *RunJobsResponse, err error)
- func (c *Client) RunJobsWithContext(ctx context.Context, request *RunJobsRequest) (response *RunJobsResponse, err error)
- func (c *Client) RunSqlGatewayStatement(request *RunSqlGatewayStatementRequest) (response *RunSqlGatewayStatementResponse, err error)
- func (c *Client) RunSqlGatewayStatementWithContext(ctx context.Context, request *RunSqlGatewayStatementRequest) (response *RunSqlGatewayStatementResponse, err error)
- func (c *Client) StopJobs(request *StopJobsRequest) (response *StopJobsResponse, err error)
- func (c *Client) StopJobsWithContext(ctx context.Context, request *StopJobsRequest) (response *StopJobsResponse, err error)
- func (c *Client) TriggerJobSavepoint(request *TriggerJobSavepointRequest) (response *TriggerJobSavepointResponse, err error)
- func (c *Client) TriggerJobSavepointWithContext(ctx context.Context, request *TriggerJobSavepointRequest) (response *TriggerJobSavepointResponse, err error)
- type Cluster
- type ClusterGroupSetItem
- type ClusterSession
- type ClusterVersion
- type CopyJobItem
- type CopyJobResult
- type CopyJobsRequest
- type CopyJobsRequestParams
- type CopyJobsResponse
- type CopyJobsResponseParams
- type CreateFolderRequest
- type CreateFolderRequestParams
- type CreateFolderResponse
- type CreateFolderResponseParams
- type CreateJobConfigRequest
- type CreateJobConfigRequestParams
- type CreateJobConfigResponse
- type CreateJobConfigResponseParams
- type CreateJobRequest
- type CreateJobRequestParams
- type CreateJobResponse
- type CreateJobResponseParams
- type CreateResourceConfigRequest
- type CreateResourceConfigRequestParams
- type CreateResourceConfigResponse
- type CreateResourceConfigResponseParams
- type CreateResourceRequest
- type CreateResourceRequestParams
- type CreateResourceResponse
- type CreateResourceResponseParams
- type CreateWorkSpaceRequest
- type CreateWorkSpaceRequestParams
- type CreateWorkSpaceResponse
- type CreateWorkSpaceResponseParams
- type DeleteFoldersRequest
- type DeleteFoldersRequestParams
- type DeleteFoldersResponse
- type DeleteFoldersResponseParams
- type DeleteJobConfigsRequest
- type DeleteJobConfigsRequestParams
- type DeleteJobConfigsResponse
- type DeleteJobConfigsResponseParams
- type DeleteJobsRequest
- type DeleteJobsRequestParams
- type DeleteJobsResponse
- type DeleteJobsResponseParams
- type DeleteResourceConfigsRequest
- type DeleteResourceConfigsRequestParams
- type DeleteResourceConfigsResponse
- type DeleteResourceConfigsResponseParams
- type DeleteResourcesRequest
- type DeleteResourcesRequestParams
- type DeleteResourcesResponse
- type DeleteResourcesResponseParams
- type DeleteTableConfigRequest
- type DeleteTableConfigRequestParams
- type DeleteTableConfigResponse
- type DeleteTableConfigResponseParams
- type DeleteWorkSpaceRequest
- type DeleteWorkSpaceRequestParams
- type DeleteWorkSpaceResponse
- type DeleteWorkSpaceResponseParams
- type DescribeClustersRequest
- type DescribeClustersRequestParams
- type DescribeClustersResponse
- type DescribeClustersResponseParams
- type DescribeFolderRequest
- type DescribeFolderRequestParams
- type DescribeFolderResponse
- type DescribeFolderResponseParams
- type DescribeJobConfigsRequest
- type DescribeJobConfigsRequestParams
- type DescribeJobConfigsResponse
- type DescribeJobConfigsResponseParams
- type DescribeJobEventsRequest
- type DescribeJobEventsRequestParams
- type DescribeJobEventsResponse
- type DescribeJobEventsResponseParams
- type DescribeJobSavepointRequest
- type DescribeJobSavepointRequestParams
- type DescribeJobSavepointResponse
- type DescribeJobSavepointResponseParams
- type DescribeJobSubmissionLogRequest
- type DescribeJobSubmissionLogRequestParams
- type DescribeJobSubmissionLogResponse
- type DescribeJobSubmissionLogResponseParams
- type DescribeJobsRequest
- type DescribeJobsRequestParams
- type DescribeJobsResponse
- type DescribeJobsResponseParams
- type DescribeResourceConfigsRequest
- type DescribeResourceConfigsRequestParams
- type DescribeResourceConfigsResponse
- type DescribeResourceConfigsResponseParams
- type DescribeResourceRelatedJobsRequest
- type DescribeResourceRelatedJobsRequestParams
- type DescribeResourceRelatedJobsResponse
- type DescribeResourceRelatedJobsResponseParams
- type DescribeResourcesRequest
- type DescribeResourcesRequestParams
- type DescribeResourcesResponse
- type DescribeResourcesResponseParams
- type DescribeSystemResourcesRequest
- type DescribeSystemResourcesRequestParams
- type DescribeSystemResourcesResponse
- type DescribeSystemResourcesResponseParams
- type DescribeTreeJobsRequest
- type DescribeTreeJobsRequestParams
- type DescribeTreeJobsResponse
- type DescribeTreeJobsResponseParams
- type DescribeTreeJobsRsp
- type DescribeTreeResourcesRequest
- type DescribeTreeResourcesRequestParams
- type DescribeTreeResourcesResponse
- type DescribeTreeResourcesResponseParams
- type DescribeTreeResourcesRsp
- type DescribeWorkSpacesRequest
- type DescribeWorkSpacesRequestParams
- type DescribeWorkSpacesResponse
- type DescribeWorkSpacesResponseParams
- type ExpertModeConfiguration
- type FetchSqlGatewayStatementResultRequest
- type FetchSqlGatewayStatementResultRequestParams
- type FetchSqlGatewayStatementResultResponse
- type FetchSqlGatewayStatementResultResponseParams
- type Filter
- type GatewayRefItem
- type GetMetaTableRequest
- type GetMetaTableRequestParams
- type GetMetaTableResponse
- type GetMetaTableResponseParams
- type JobConfig
- type JobEvent
- type JobEventInfo
- type JobGraph
- type JobGraphEdge
- type JobGraphNode
- type JobInstanceForSubmissionLog
- type JobV1
- type LogContent
- type LogicalType
- type ModifyFolderRequest
- type ModifyFolderRequestParams
- type ModifyFolderResponse
- type ModifyFolderResponseParams
- type ModifyJobRequest
- type ModifyJobRequestParams
- type ModifyJobResponse
- type ModifyJobResponseParams
- type ModifyWorkSpaceRequest
- type ModifyWorkSpaceRequestParams
- type ModifyWorkSpaceResponse
- type ModifyWorkSpaceResponseParams
- type NodeConfig
- type Order
- type Property
- type RefJobStatusCountItem
- type ResourceConfigItem
- type ResourceItem
- type ResourceLoc
- type ResourceLocParam
- type ResourceRef
- type ResourceRefDetail
- type ResourceRefJobInfo
- type ResultColumn
- type ResultData
- type RoleAuth
- type RunJobDescription
- type RunJobsRequest
- type RunJobsRequestParams
- type RunJobsResponse
- type RunJobsResponseParams
- type RunSqlGatewayStatementRequest
- type RunSqlGatewayStatementRequestParams
- type RunSqlGatewayStatementResponse
- type RunSqlGatewayStatementResponseParams
- type Savepoint
- type SlotSharingGroup
- type SlotSharingGroupSpec
- type SqlGatewayItem
- type StatementResult
- type StopJobDescription
- type StopJobsRequest
- type StopJobsRequestParams
- type StopJobsResponse
- type StopJobsResponseParams
- type SubEks
- type SubFolderInfo
- type SystemResourceItem
- type Tag
- type TraceModeConfiguration
- type TreeJobSets
- type TreeResourceItem
- type TriggerJobSavepointRequest
- type TriggerJobSavepointRequestParams
- type TriggerJobSavepointResponse
- type TriggerJobSavepointResponseParams
- type WorkSpaceClusterItem
- type WorkSpaceSetItem
Constants ¶
const ( // CAM签名/鉴权错误。 AUTHFAILURE = "AuthFailure" // 未授权操作。 AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" // 操作失败。 FAILEDOPERATION = "FailedOperation" // 数据库连接失败,请检查参数是否填写正确。 FAILEDOPERATION_DATASOURCECONNECTIONFAILED = "FailedOperation.DataSourceConnectionFailed" // 作业的草稿不允许删除。 FAILEDOPERATION_DRAFTCONFIGCANNOTDELETE = "FailedOperation.DraftConfigCanNotDelete" // 重复的作业名。 FAILEDOPERATION_DUPLICATEDJOBNAME = "FailedOperation.DuplicatedJobName" // 获取SqlGateway结果失败,异常 FAILEDOPERATION_FAILEDOPERATIONCODE_FETCHSQLGATEWAYSTATEMENT = "FailedOperation.FailedOperationCode_FetchSqlGatewayStatement" // 运行SqlGateway失败,异常 FAILEDOPERATION_FAILEDOPERATIONCODE_RUNSQLGATEWAY = "FailedOperation.FailedOperationCode_RunSqlGateway" // 查询资源关联标签失败。 FAILEDOPERATION_GETRESOURCETAGSBYRESOURCEIDS = "FailedOperation.GetResourceTagsByResourceIds" // 语法检查失败。 FAILEDOPERATION_GRAMMARCHECKFAILURE = "FailedOperation.GrammarCheckFailure" // 作业配置在使用中。 FAILEDOPERATION_JOBCONFIGONPUBLISH = "FailedOperation.JobConfigOnPublish" // SQL解析失败。 FAILEDOPERATION_PARSESQL = "FailedOperation.ParseSql" // 用户未实名验证。 FAILEDOPERATION_USERNOTAUTHENTICATED = "FailedOperation.UserNotAuthenticated" // 内部错误。 INTERNALERROR = "InternalError" // CLS接口错误。 INTERNALERROR_CLS = "InternalError.CLS" // COS 服务访问错误。 INTERNALERROR_COSCLIENT = "InternalError.COSClient" // CAM 网关错误。 INTERNALERROR_CAMCGWERROR = "InternalError.CamCgwError" // 数据库异常。 INTERNALERROR_DB = "InternalError.DB" // 失败的目标资源。 INTERNALERROR_FAILEDTOBESCRIBERESOURCES = "InternalError.FailedToBescribeResources" // 无法更新作业错误。 INTERNALERROR_FAILEDTOUPDATEJOB = "InternalError.FailedToUpdateJob" // 作业实例没找到。 INTERNALERROR_JOBINSTANCENOTFOUND = "InternalError.JobInstanceNotFound" // 内部错误。 INTERNALERROR_LOGICERROR = "InternalError.LogicError" // 资源只有一个版本,无法删除。 INTERNALERROR_RESOURCECONFIGCANNOTDELETE = "InternalError.ResourceConfigCanNotDelete" // 资源不存在。 INTERNALERROR_RESOURCENOTEXIST = "InternalError.ResourceNotExist" // 未找到sqlcode错误。 INTERNALERROR_SQLCODENOTFOUND = "InternalError.SqlCodeNotFound" // 内部错误。 INTERNALERROR_STSNEWCLIENT = "InternalError.StsNewClient" // 系统错误。 INTERNALERROR_SYSTEMERROR = "InternalError.SystemError" // 参数错误。 INVALIDPARAMETER = "InvalidParameter" // AppId资源不匹配。 INVALIDPARAMETER_APPIDRESOURCENOTMATCH = "InvalidParameter.AppIdResourceNotMatch" // 空间命名重复。 INVALIDPARAMETER_DUPLICATEDSPACENAME = "InvalidParameter.DuplicatedSpaceName" // 非法的 MaxParallelism 参数。 INVALIDPARAMETER_ILLEGALMAXPARALLELISM = "InvalidParameter.IllegalMaxParallelism" // 非法的搜索字符串。 INVALIDPARAMETER_ILLEGALSEARCHKEYWORD = "InvalidParameter.IllegalSearchKeyword" // appid错误。 INVALIDPARAMETER_INVALIDAPPID = "InvalidParameter.InvalidAppId" // 无效集群id。 INVALIDPARAMETER_INVALIDCLUSTERID = "InvalidParameter.InvalidClusterId" // 空间命名不规范。 INVALIDPARAMETER_INVALIDITEMSPACENAME = "InvalidParameter.InvalidItemSpaceName" // 名字不符合规范。 INVALIDPARAMETER_INVALIDNAME = "InvalidParameter.InvalidName" // 无效Region。 INVALIDPARAMETER_INVALIDREGION = "InvalidParameter.InvalidRegion" // ResourceIds非法。 INVALIDPARAMETER_INVALIDRESOURCEIDS = "InvalidParameter.InvalidResourceIds" // 创建作业配置错误。 INVALIDPARAMETER_JOBCONFIGLOGCOLLECTPARAMERROR = "InvalidParameter.JobConfigLogCollectParamError" // MaxParallelism 过大。 INVALIDPARAMETER_MAXPARALLELISMTOOLARGE = "InvalidParameter.MaxParallelismTooLarge" // MaxParallelism 不允许小于算子默认并行度。 INVALIDPARAMETER_MAXPARALLELISMTOOSMALL = "InvalidParameter.MaxParallelismTooSmall" // Uin资源不匹配。 INVALIDPARAMETER_UINRESOURCENOTMATCH = "InvalidParameter.UinResourceNotMatch" // Flink参数非法。 INVALIDPARAMETER_UNSUPPORTEDFLINKCONF = "InvalidParameter.UnsupportedFlinkConf" // 参数取值错误。 INVALIDPARAMETERVALUE = "InvalidParameterValue" // 集群Id指定错误,为空或者不存在。 INVALIDPARAMETERVALUE_CLUSTERID = "InvalidParameterValue.ClusterId" // 群集Id报错。 INVALIDPARAMETERVALUE_CLUSTERIDS = "InvalidParameterValue.ClusterIds" // CU内存规格不匹配。 INVALIDPARAMETERVALUE_CUMEM = "InvalidParameterValue.CuMem" // 无效限制错误。 INVALIDPARAMETERVALUE_INVALIDLIMIT = "InvalidParameterValue.InvalidLimit" // 无效启动模式。 INVALIDPARAMETERVALUE_INVALIDSTARTMODE = "InvalidParameterValue.InvalidStartMode" // 无效时间错误。 INVALIDPARAMETERVALUE_INVALIDTIME = "InvalidParameterValue.InvalidTime" // 作业id的参数无效。 INVALIDPARAMETERVALUE_JOBIDVALUEERROR = "InvalidParameterValue.JobIdValueError" // Illegal JobName。 INVALIDPARAMETERVALUE_JOBNAME = "InvalidParameterValue.JobName" // 作业名称已存在。 INVALIDPARAMETERVALUE_JOBNAMEEXISTED = "InvalidParameterValue.JobNameExisted" // 集群模式与作业类型不匹配。 INVALIDPARAMETERVALUE_JOBTYPECOMBINEWITHCLUSTERTYPE = "InvalidParameterValue.JobTypeCombineWithClusterType" // SQL作业不能指定EntrypointClass,JAR作业则必须指定。 INVALIDPARAMETERVALUE_JOBTYPECOMBINEWITHENTRYPOINTCLASS = "InvalidParameterValue.JobTypeCombineWithEntrypointClass" // OrderType值错误。 INVALIDPARAMETERVALUE_ORDERTYPE = "InvalidParameterValue.OrderType" // 未找到资源ID。 INVALIDPARAMETERVALUE_RESOURCEIDSNOTFOUND = "InvalidParameterValue.ResourceIdsNotFound" // 批量运行作业个数超过上限。 INVALIDPARAMETERVALUE_RUNJOBDESCRIPTIONSCOUNT = "InvalidParameterValue.RunJobDescriptionsCount" // RunType错误。 INVALIDPARAMETERVALUE_RUNTYPE = "InvalidParameterValue.RunType" // 时间戳范围有误。 INVALIDPARAMETERVALUE_TIMESTAMP = "InvalidParameterValue.Timestamp" // 非法的类型字段。 INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type" // 不支持的复合类型。 INVALIDPARAMETERVALUE_UNSUPPORTEDCOMPOSITE = "InvalidParameterValue.UnSupportedComposite" // 未知停止类型错误。 INVALIDPARAMETERVALUE_UNKNOWNSTOPTYPE = "InvalidParameterValue.UnknownStopType" // 超过配额限制。 LIMITEXCEEDED = "LimitExceeded" // 项目空间数量超出限制。 LIMITEXCEEDED_ITEMSPACELIMITEXCEEDED = "LimitExceeded.ItemSpaceLimitExceeded" // Job个数超过限额。 LIMITEXCEEDED_JOB = "LimitExceeded.Job" // 作业配置超出限制。 LIMITEXCEEDED_JOBCONFIG = "LimitExceeded.JobConfig" // 工作空间超阈值。 LIMITEXCEEDED_WORKSPACELIMITEXCEEDED = "LimitExceeded.WorkSpaceLimitExceeded" // 资源被占用。 RESOURCEINUSE = "ResourceInUse" // 集群有其他操作。 RESOURCEINUSE_INSTANCEINPROCESS = "ResourceInUse.InstanceInProcess" // 资源名称已存在。 RESOURCEINUSE_RESOURCENAMEALREADYEXISTS = "ResourceInUse.ResourceNameAlreadyExists" // CU资源不足。 RESOURCEINSUFFICIENT_CU = "ResourceInsufficient.CU" // 资源不存在。 RESOURCENOTFOUND = "ResourceNotFound" // COS Bucket 未找到或无权限访问。 RESOURCENOTFOUND_COSBUCKET = "ResourceNotFound.COSBucket" // 集群不存在。 RESOURCENOTFOUND_CLUSTERID = "ResourceNotFound.ClusterId" // 作业不存在。 RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" // 作业配置版本不存在。 RESOURCENOTFOUND_JOBCONFIG = "ResourceNotFound.JobConfig" // 找不到作业。 RESOURCENOTFOUND_JOBID = "ResourceNotFound.JobId" // 找不到日志。 RESOURCENOTFOUND_LOGTOPIC = "ResourceNotFound.LogTopic" // 程序包不存在。 RESOURCENOTFOUND_RESOURCE = "ResourceNotFound.Resource" // 程序包版本不存在。 RESOURCENOTFOUND_RESOURCECONFIG = "ResourceNotFound.ResourceConfig" // 资源不存在。 RESOURCENOTFOUND_RESOURCENOTEXIST = "ResourceNotFound.ResourceNotExist" // 数据库或表不存在。 RESOURCENOTFOUND_TABLENOTEXIST = "ResourceNotFound.TableNotExist" // 资源不可用。 RESOURCEUNAVAILABLE = "ResourceUnavailable" // 被某个作业配置使用。 RESOURCEUNAVAILABLE_BEUSEBYSOMEJOBCONFIG = "ResourceUnavailable.BeUseBySomeJobConfig" // 检查资源位置是否存在错误。 RESOURCEUNAVAILABLE_CHECKRESOURCELOCEXISTS = "ResourceUnavailable.CheckResourceLocExists" // 集群处于非运行状态。 RESOURCEUNAVAILABLE_CLUSTER = "ResourceUnavailable.Cluster" // 群集组状态错误。 RESOURCEUNAVAILABLE_CLUSTERGROUPSTATUS = "ResourceUnavailable.ClusterGroupStatus" // 失败的目标资源。 RESOURCEUNAVAILABLE_FAILEDTOBESCRIBERESOURCES = "ResourceUnavailable.FailedToBescribeResources" // 获取发布的作业配置错误。 RESOURCEUNAVAILABLE_GETJOBPUBLISHEDJOBCONFIG = "ResourceUnavailable.GetJobPublishedJobConfig" // 作业资源配置未就绪。 RESOURCEUNAVAILABLE_JOBRESOURCECONFIGNOTREADY = "ResourceUnavailable.JobResourceConfigNotReady" // 找不到JobId的正在运行的作业实例。 RESOURCEUNAVAILABLE_NORUNNINGJOBINSTANCESFOUNDFORJOBID = "ResourceUnavailable.NoRunningJobInstancesFoundForJobId" // 不允许删除错误。 RESOURCEUNAVAILABLE_NOTALLOWEDTOBEDELETED = "ResourceUnavailable.NotAllowedToBeDeleted" // 不允许停止或暂停错误。 RESOURCEUNAVAILABLE_NOTALLOWEDTOBESTOPORPAUSE = "ResourceUnavailable.NotAllowedToBeStopOrPause" // 共享群集只允许CuMem=4。 RESOURCEUNAVAILABLE_REQCUMEM = "ResourceUnavailable.ReqCuMem" // cos上的程序包不存在。 RESOURCEUNAVAILABLE_RESOURCELOCNOTEXISTS = "ResourceUnavailable.ResourceLocNotExists" // 未授权操作。 UNAUTHORIZEDOPERATION = "UnauthorizedOperation" // 操作不支持。 UNSUPPORTEDOPERATION = "UnsupportedOperation" // 资源未释放,不能做删除作业。 UNSUPPORTEDOPERATION_CANNOTDELETE = "UnsupportedOperation.CanNotDelete" // Cls Sql未启用。 UNSUPPORTEDOPERATION_CLSSQLNOTENABLED = "UnsupportedOperation.ClsSqlNotEnabled" // Checkpoint 时间间隔,错误。 UNSUPPORTEDOPERATION_INVALIDCHECKPOINTINTERVALERROR = "UnsupportedOperation.InvalidCheckpointIntervalError" // 权限拦截,没有进入权限。 UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess" // 不支持的启动模式。 UNSUPPORTEDOPERATION_UNSUPPORTEDSTARTMODE = "UnsupportedOperation.UnsupportedStartMode" )
const APIVersion = "2019-04-22"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CheckSavepointRequest ¶ added in v1.0.404
type CheckSavepointRequest struct { *tchttp.BaseRequest // 作业 id JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 快照资源 id SerialId *string `json:"SerialId,omitnil,omitempty" name:"SerialId"` // 快照类型 1: savepoint;2: checkpoint;3: cancelWithSavepoint RecordType *int64 `json:"RecordType,omitnil,omitempty" name:"RecordType"` // 快照路径,目前只支持 cos 路径 SavepointPath *string `json:"SavepointPath,omitnil,omitempty" name:"SavepointPath"` // 工作空间 id WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewCheckSavepointRequest ¶ added in v1.0.404
func NewCheckSavepointRequest() (request *CheckSavepointRequest)
func (*CheckSavepointRequest) FromJsonString ¶ added in v1.0.404
func (r *CheckSavepointRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CheckSavepointRequest) ToJsonString ¶ added in v1.0.404
func (r *CheckSavepointRequest) ToJsonString() string
type CheckSavepointRequestParams ¶ added in v1.0.426
type CheckSavepointRequestParams struct { // 作业 id JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 快照资源 id SerialId *string `json:"SerialId,omitnil,omitempty" name:"SerialId"` // 快照类型 1: savepoint;2: checkpoint;3: cancelWithSavepoint RecordType *int64 `json:"RecordType,omitnil,omitempty" name:"RecordType"` // 快照路径,目前只支持 cos 路径 SavepointPath *string `json:"SavepointPath,omitnil,omitempty" name:"SavepointPath"` // 工作空间 id WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type CheckSavepointResponse ¶ added in v1.0.404
type CheckSavepointResponse struct { *tchttp.BaseResponse Response *CheckSavepointResponseParams `json:"Response"` }
func NewCheckSavepointResponse ¶ added in v1.0.404
func NewCheckSavepointResponse() (response *CheckSavepointResponse)
func (*CheckSavepointResponse) FromJsonString ¶ added in v1.0.404
func (r *CheckSavepointResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CheckSavepointResponse) ToJsonString ¶ added in v1.0.404
func (r *CheckSavepointResponse) ToJsonString() string
type CheckSavepointResponseParams ¶ added in v1.0.426
type CheckSavepointResponseParams struct { // 资源 id SerialId *string `json:"SerialId,omitnil,omitempty" name:"SerialId"` // 1=可用,2=不可用 SavepointStatus *int64 `json:"SavepointStatus,omitnil,omitempty" name:"SavepointStatus"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type ClazzLevel ¶ added in v1.0.712
type Client ¶
func NewClient ¶
func NewClient(credential common.CredentialIface, region string, clientProfile *profile.ClientProfile) (client *Client, err error)
func NewClientWithSecretId ¶
Deprecated
func (*Client) CheckSavepoint ¶ added in v1.0.404
func (c *Client) CheckSavepoint(request *CheckSavepointRequest) (response *CheckSavepointResponse, err error)
CheckSavepoint 检查快照是否可用
可能返回的错误码:
RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) CheckSavepointWithContext ¶ added in v1.0.404
func (c *Client) CheckSavepointWithContext(ctx context.Context, request *CheckSavepointRequest) (response *CheckSavepointResponse, err error)
CheckSavepoint 检查快照是否可用
可能返回的错误码:
RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) CopyJobs ¶ added in v1.0.449
func (c *Client) CopyJobs(request *CopyJobsRequest) (response *CopyJobsResponse, err error)
CopyJobs 单条和批量复制作业
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" INTERNALERROR = "InternalError" INTERNALERROR_CLS = "InternalError.CLS" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_STSNEWCLIENT = "InternalError.StsNewClient" INTERNALERROR_SYSTEMERROR = "InternalError.SystemError" INVALIDPARAMETERVALUE = "InvalidParameterValue" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" UNSUPPORTEDOPERATION = "UnsupportedOperation" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) CopyJobsWithContext ¶ added in v1.0.449
func (c *Client) CopyJobsWithContext(ctx context.Context, request *CopyJobsRequest) (response *CopyJobsResponse, err error)
CopyJobs 单条和批量复制作业
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" INTERNALERROR = "InternalError" INTERNALERROR_CLS = "InternalError.CLS" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_STSNEWCLIENT = "InternalError.StsNewClient" INTERNALERROR_SYSTEMERROR = "InternalError.SystemError" INVALIDPARAMETERVALUE = "InvalidParameterValue" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" UNSUPPORTEDOPERATION = "UnsupportedOperation" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) CreateFolder ¶ added in v1.0.449
func (c *Client) CreateFolder(request *CreateFolderRequest) (response *CreateFolderResponse, err error)
CreateFolder 作业列表页面新建文件夹请求
可能返回的错误码:
FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INVALIDPARAMETERVALUE = "InvalidParameterValue" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) CreateFolderWithContext ¶ added in v1.0.449
func (c *Client) CreateFolderWithContext(ctx context.Context, request *CreateFolderRequest) (response *CreateFolderResponse, err error)
CreateFolder 作业列表页面新建文件夹请求
可能返回的错误码:
FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INVALIDPARAMETERVALUE = "InvalidParameterValue" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) CreateJob ¶
func (c *Client) CreateJob(request *CreateJobRequest) (response *CreateJobResponse, err error)
CreateJob 新建作业接口,一个 AppId 最多允许创建1000个作业
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" FAILEDOPERATION_DUPLICATEDJOBNAME = "FailedOperation.DuplicatedJobName" FAILEDOPERATION_USERNOTAUTHENTICATED = "FailedOperation.UserNotAuthenticated" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INVALIDPARAMETER_INVALIDNAME = "InvalidParameter.InvalidName" INVALIDPARAMETERVALUE_CLUSTERID = "InvalidParameterValue.ClusterId" INVALIDPARAMETERVALUE_CUMEM = "InvalidParameterValue.CuMem" INVALIDPARAMETERVALUE_JOBNAME = "InvalidParameterValue.JobName" INVALIDPARAMETERVALUE_JOBNAMEEXISTED = "InvalidParameterValue.JobNameExisted" INVALIDPARAMETERVALUE_JOBTYPECOMBINEWITHCLUSTERTYPE = "InvalidParameterValue.JobTypeCombineWithClusterType" INVALIDPARAMETERVALUE_UNSUPPORTEDCOMPOSITE = "InvalidParameterValue.UnSupportedComposite" LIMITEXCEEDED = "LimitExceeded" LIMITEXCEEDED_JOB = "LimitExceeded.Job" RESOURCENOTFOUND_CLUSTERID = "ResourceNotFound.ClusterId" RESOURCEUNAVAILABLE_CLUSTER = "ResourceUnavailable.Cluster" RESOURCEUNAVAILABLE_CLUSTERGROUPSTATUS = "ResourceUnavailable.ClusterGroupStatus" RESOURCEUNAVAILABLE_REQCUMEM = "ResourceUnavailable.ReqCuMem" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) CreateJobConfig ¶
func (c *Client) CreateJobConfig(request *CreateJobConfigRequest) (response *CreateJobConfigResponse, err error)
CreateJobConfig 创建作业配置,一个作业最多有100个配置版本
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" FAILEDOPERATION_GRAMMARCHECKFAILURE = "FailedOperation.GrammarCheckFailure" FAILEDOPERATION_PARSESQL = "FailedOperation.ParseSql" INTERNALERROR_COSCLIENT = "InternalError.COSClient" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INTERNALERROR_SQLCODENOTFOUND = "InternalError.SqlCodeNotFound" INTERNALERROR_STSNEWCLIENT = "InternalError.StsNewClient" INVALIDPARAMETER_ILLEGALMAXPARALLELISM = "InvalidParameter.IllegalMaxParallelism" INVALIDPARAMETER_INVALIDREGION = "InvalidParameter.InvalidRegion" INVALIDPARAMETER_JOBCONFIGLOGCOLLECTPARAMERROR = "InvalidParameter.JobConfigLogCollectParamError" INVALIDPARAMETER_MAXPARALLELISMTOOLARGE = "InvalidParameter.MaxParallelismTooLarge" INVALIDPARAMETER_MAXPARALLELISMTOOSMALL = "InvalidParameter.MaxParallelismTooSmall" INVALIDPARAMETER_UNSUPPORTEDFLINKCONF = "InvalidParameter.UnsupportedFlinkConf" INVALIDPARAMETERVALUE = "InvalidParameterValue" INVALIDPARAMETERVALUE_JOBTYPECOMBINEWITHENTRYPOINTCLASS = "InvalidParameterValue.JobTypeCombineWithEntrypointClass" LIMITEXCEEDED = "LimitExceeded" LIMITEXCEEDED_JOBCONFIG = "LimitExceeded.JobConfig" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_COSBUCKET = "ResourceNotFound.COSBucket" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" RESOURCENOTFOUND_JOBID = "ResourceNotFound.JobId" UNSUPPORTEDOPERATION_INVALIDCHECKPOINTINTERVALERROR = "UnsupportedOperation.InvalidCheckpointIntervalError" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) CreateJobConfigWithContext ¶ added in v1.0.324
func (c *Client) CreateJobConfigWithContext(ctx context.Context, request *CreateJobConfigRequest) (response *CreateJobConfigResponse, err error)
CreateJobConfig 创建作业配置,一个作业最多有100个配置版本
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" FAILEDOPERATION_GRAMMARCHECKFAILURE = "FailedOperation.GrammarCheckFailure" FAILEDOPERATION_PARSESQL = "FailedOperation.ParseSql" INTERNALERROR_COSCLIENT = "InternalError.COSClient" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INTERNALERROR_SQLCODENOTFOUND = "InternalError.SqlCodeNotFound" INTERNALERROR_STSNEWCLIENT = "InternalError.StsNewClient" INVALIDPARAMETER_ILLEGALMAXPARALLELISM = "InvalidParameter.IllegalMaxParallelism" INVALIDPARAMETER_INVALIDREGION = "InvalidParameter.InvalidRegion" INVALIDPARAMETER_JOBCONFIGLOGCOLLECTPARAMERROR = "InvalidParameter.JobConfigLogCollectParamError" INVALIDPARAMETER_MAXPARALLELISMTOOLARGE = "InvalidParameter.MaxParallelismTooLarge" INVALIDPARAMETER_MAXPARALLELISMTOOSMALL = "InvalidParameter.MaxParallelismTooSmall" INVALIDPARAMETER_UNSUPPORTEDFLINKCONF = "InvalidParameter.UnsupportedFlinkConf" INVALIDPARAMETERVALUE = "InvalidParameterValue" INVALIDPARAMETERVALUE_JOBTYPECOMBINEWITHENTRYPOINTCLASS = "InvalidParameterValue.JobTypeCombineWithEntrypointClass" LIMITEXCEEDED = "LimitExceeded" LIMITEXCEEDED_JOBCONFIG = "LimitExceeded.JobConfig" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_COSBUCKET = "ResourceNotFound.COSBucket" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" RESOURCENOTFOUND_JOBID = "ResourceNotFound.JobId" UNSUPPORTEDOPERATION_INVALIDCHECKPOINTINTERVALERROR = "UnsupportedOperation.InvalidCheckpointIntervalError" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) CreateJobWithContext ¶ added in v1.0.324
func (c *Client) CreateJobWithContext(ctx context.Context, request *CreateJobRequest) (response *CreateJobResponse, err error)
CreateJob 新建作业接口,一个 AppId 最多允许创建1000个作业
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" FAILEDOPERATION_DUPLICATEDJOBNAME = "FailedOperation.DuplicatedJobName" FAILEDOPERATION_USERNOTAUTHENTICATED = "FailedOperation.UserNotAuthenticated" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INVALIDPARAMETER_INVALIDNAME = "InvalidParameter.InvalidName" INVALIDPARAMETERVALUE_CLUSTERID = "InvalidParameterValue.ClusterId" INVALIDPARAMETERVALUE_CUMEM = "InvalidParameterValue.CuMem" INVALIDPARAMETERVALUE_JOBNAME = "InvalidParameterValue.JobName" INVALIDPARAMETERVALUE_JOBNAMEEXISTED = "InvalidParameterValue.JobNameExisted" INVALIDPARAMETERVALUE_JOBTYPECOMBINEWITHCLUSTERTYPE = "InvalidParameterValue.JobTypeCombineWithClusterType" INVALIDPARAMETERVALUE_UNSUPPORTEDCOMPOSITE = "InvalidParameterValue.UnSupportedComposite" LIMITEXCEEDED = "LimitExceeded" LIMITEXCEEDED_JOB = "LimitExceeded.Job" RESOURCENOTFOUND_CLUSTERID = "ResourceNotFound.ClusterId" RESOURCEUNAVAILABLE_CLUSTER = "ResourceUnavailable.Cluster" RESOURCEUNAVAILABLE_CLUSTERGROUPSTATUS = "ResourceUnavailable.ClusterGroupStatus" RESOURCEUNAVAILABLE_REQCUMEM = "ResourceUnavailable.ReqCuMem" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) CreateResource ¶
func (c *Client) CreateResource(request *CreateResourceRequest) (response *CreateResourceResponse, err error)
CreateResource 创建资源接口
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_COSCLIENT = "InternalError.COSClient" INTERNALERROR_DB = "InternalError.DB" INVALIDPARAMETER_INVALIDAPPID = "InvalidParameter.InvalidAppId" LIMITEXCEEDED = "LimitExceeded" RESOURCEINUSE_RESOURCENAMEALREADYEXISTS = "ResourceInUse.ResourceNameAlreadyExists" RESOURCENOTFOUND = "ResourceNotFound" RESOURCEUNAVAILABLE_CHECKRESOURCELOCEXISTS = "ResourceUnavailable.CheckResourceLocExists" RESOURCEUNAVAILABLE_RESOURCELOCNOTEXISTS = "ResourceUnavailable.ResourceLocNotExists" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) CreateResourceConfig ¶
func (c *Client) CreateResourceConfig(request *CreateResourceConfigRequest) (response *CreateResourceConfigResponse, err error)
CreateResourceConfig 创建资源配置接口
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_RESOURCENOTEXIST = "InternalError.ResourceNotExist" LIMITEXCEEDED = "LimitExceeded" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_RESOURCENOTEXIST = "ResourceNotFound.ResourceNotExist" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) CreateResourceConfigWithContext ¶ added in v1.0.324
func (c *Client) CreateResourceConfigWithContext(ctx context.Context, request *CreateResourceConfigRequest) (response *CreateResourceConfigResponse, err error)
CreateResourceConfig 创建资源配置接口
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_RESOURCENOTEXIST = "InternalError.ResourceNotExist" LIMITEXCEEDED = "LimitExceeded" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_RESOURCENOTEXIST = "ResourceNotFound.ResourceNotExist" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) CreateResourceWithContext ¶ added in v1.0.324
func (c *Client) CreateResourceWithContext(ctx context.Context, request *CreateResourceRequest) (response *CreateResourceResponse, err error)
CreateResource 创建资源接口
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_COSCLIENT = "InternalError.COSClient" INTERNALERROR_DB = "InternalError.DB" INVALIDPARAMETER_INVALIDAPPID = "InvalidParameter.InvalidAppId" LIMITEXCEEDED = "LimitExceeded" RESOURCEINUSE_RESOURCENAMEALREADYEXISTS = "ResourceInUse.ResourceNameAlreadyExists" RESOURCENOTFOUND = "ResourceNotFound" RESOURCEUNAVAILABLE_CHECKRESOURCELOCEXISTS = "ResourceUnavailable.CheckResourceLocExists" RESOURCEUNAVAILABLE_RESOURCELOCNOTEXISTS = "ResourceUnavailable.ResourceLocNotExists" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) CreateWorkSpace ¶ added in v1.0.769
func (c *Client) CreateWorkSpace(request *CreateWorkSpaceRequest) (response *CreateWorkSpaceResponse, err error)
CreateWorkSpace 创建工作空间
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_INVALIDITEMSPACENAME = "InvalidParameter.InvalidItemSpaceName" LIMITEXCEEDED_ITEMSPACELIMITEXCEEDED = "LimitExceeded.ItemSpaceLimitExceeded" LIMITEXCEEDED_WORKSPACELIMITEXCEEDED = "LimitExceeded.WorkSpaceLimitExceeded" UNSUPPORTEDOPERATION = "UnsupportedOperation"
func (*Client) CreateWorkSpaceWithContext ¶ added in v1.0.769
func (c *Client) CreateWorkSpaceWithContext(ctx context.Context, request *CreateWorkSpaceRequest) (response *CreateWorkSpaceResponse, err error)
CreateWorkSpace 创建工作空间
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_INVALIDITEMSPACENAME = "InvalidParameter.InvalidItemSpaceName" LIMITEXCEEDED_ITEMSPACELIMITEXCEEDED = "LimitExceeded.ItemSpaceLimitExceeded" LIMITEXCEEDED_WORKSPACELIMITEXCEEDED = "LimitExceeded.WorkSpaceLimitExceeded" UNSUPPORTEDOPERATION = "UnsupportedOperation"
func (*Client) DeleteFolders ¶ added in v1.0.769
func (c *Client) DeleteFolders(request *DeleteFoldersRequest) (response *DeleteFoldersResponse, err error)
DeleteFolders 作业列表删除文件夹
可能返回的错误码:
FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INVALIDPARAMETERVALUE = "InvalidParameterValue" RESOURCENOTFOUND = "ResourceNotFound" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DeleteFoldersWithContext ¶ added in v1.0.769
func (c *Client) DeleteFoldersWithContext(ctx context.Context, request *DeleteFoldersRequest) (response *DeleteFoldersResponse, err error)
DeleteFolders 作业列表删除文件夹
可能返回的错误码:
FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INVALIDPARAMETERVALUE = "InvalidParameterValue" RESOURCENOTFOUND = "ResourceNotFound" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DeleteJobConfigs ¶ added in v1.0.769
func (c *Client) DeleteJobConfigs(request *DeleteJobConfigsRequest) (response *DeleteJobConfigsResponse, err error)
DeleteJobConfigs 删除作业配置
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION_DRAFTCONFIGCANNOTDELETE = "FailedOperation.DraftConfigCanNotDelete" FAILEDOPERATION_JOBCONFIGONPUBLISH = "FailedOperation.JobConfigOnPublish" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DeleteJobConfigsWithContext ¶ added in v1.0.769
func (c *Client) DeleteJobConfigsWithContext(ctx context.Context, request *DeleteJobConfigsRequest) (response *DeleteJobConfigsResponse, err error)
DeleteJobConfigs 删除作业配置
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION_DRAFTCONFIGCANNOTDELETE = "FailedOperation.DraftConfigCanNotDelete" FAILEDOPERATION_JOBCONFIGONPUBLISH = "FailedOperation.JobConfigOnPublish" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DeleteJobs ¶ added in v1.0.441
func (c *Client) DeleteJobs(request *DeleteJobsRequest) (response *DeleteJobsResponse, err error)
DeleteJobs 批量删除作业接口,批量操作数量上限20
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INVALIDPARAMETERVALUE_JOBIDVALUEERROR = "InvalidParameterValue.JobIdValueError" RESOURCEINUSE = "ResourceInUse" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" RESOURCENOTFOUND_JOBID = "ResourceNotFound.JobId" RESOURCEUNAVAILABLE_NOTALLOWEDTOBEDELETED = "ResourceUnavailable.NotAllowedToBeDeleted" UNSUPPORTEDOPERATION = "UnsupportedOperation" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DeleteJobsWithContext ¶ added in v1.0.441
func (c *Client) DeleteJobsWithContext(ctx context.Context, request *DeleteJobsRequest) (response *DeleteJobsResponse, err error)
DeleteJobs 批量删除作业接口,批量操作数量上限20
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INVALIDPARAMETERVALUE_JOBIDVALUEERROR = "InvalidParameterValue.JobIdValueError" RESOURCEINUSE = "ResourceInUse" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" RESOURCENOTFOUND_JOBID = "ResourceNotFound.JobId" RESOURCEUNAVAILABLE_NOTALLOWEDTOBEDELETED = "ResourceUnavailable.NotAllowedToBeDeleted" UNSUPPORTEDOPERATION = "UnsupportedOperation" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DeleteResourceConfigs ¶
func (c *Client) DeleteResourceConfigs(request *DeleteResourceConfigsRequest) (response *DeleteResourceConfigsResponse, err error)
DeleteResourceConfigs 删除资源版本
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_RESOURCECONFIGCANNOTDELETE = "InternalError.ResourceConfigCanNotDelete" INVALIDPARAMETER_INVALIDRESOURCEIDS = "InvalidParameter.InvalidResourceIds" INVALIDPARAMETERVALUE_RESOURCEIDSNOTFOUND = "InvalidParameterValue.ResourceIdsNotFound" RESOURCEINUSE = "ResourceInUse" RESOURCENOTFOUND = "ResourceNotFound" RESOURCEUNAVAILABLE = "ResourceUnavailable" RESOURCEUNAVAILABLE_BEUSEBYSOMEJOBCONFIG = "ResourceUnavailable.BeUseBySomeJobConfig" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DeleteResourceConfigsWithContext ¶ added in v1.0.324
func (c *Client) DeleteResourceConfigsWithContext(ctx context.Context, request *DeleteResourceConfigsRequest) (response *DeleteResourceConfigsResponse, err error)
DeleteResourceConfigs 删除资源版本
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_RESOURCECONFIGCANNOTDELETE = "InternalError.ResourceConfigCanNotDelete" INVALIDPARAMETER_INVALIDRESOURCEIDS = "InvalidParameter.InvalidResourceIds" INVALIDPARAMETERVALUE_RESOURCEIDSNOTFOUND = "InvalidParameterValue.ResourceIdsNotFound" RESOURCEINUSE = "ResourceInUse" RESOURCENOTFOUND = "ResourceNotFound" RESOURCEUNAVAILABLE = "ResourceUnavailable" RESOURCEUNAVAILABLE_BEUSEBYSOMEJOBCONFIG = "ResourceUnavailable.BeUseBySomeJobConfig" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DeleteResources ¶
func (c *Client) DeleteResources(request *DeleteResourcesRequest) (response *DeleteResourcesResponse, err error)
DeleteResources 删除资源接口
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INVALIDPARAMETER_INVALIDRESOURCEIDS = "InvalidParameter.InvalidResourceIds" RESOURCEINUSE = "ResourceInUse" RESOURCENOTFOUND = "ResourceNotFound" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DeleteResourcesWithContext ¶ added in v1.0.324
func (c *Client) DeleteResourcesWithContext(ctx context.Context, request *DeleteResourcesRequest) (response *DeleteResourcesResponse, err error)
DeleteResources 删除资源接口
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INVALIDPARAMETER_INVALIDRESOURCEIDS = "InvalidParameter.InvalidResourceIds" RESOURCEINUSE = "ResourceInUse" RESOURCENOTFOUND = "ResourceNotFound" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DeleteTableConfig ¶
func (c *Client) DeleteTableConfig(request *DeleteTableConfigRequest) (response *DeleteTableConfigResponse, err error)
DeleteTableConfig 删除作业表配置
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB"
func (*Client) DeleteTableConfigWithContext ¶ added in v1.0.324
func (c *Client) DeleteTableConfigWithContext(ctx context.Context, request *DeleteTableConfigRequest) (response *DeleteTableConfigResponse, err error)
DeleteTableConfig 删除作业表配置
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB"
func (*Client) DeleteWorkSpace ¶ added in v1.0.771
func (c *Client) DeleteWorkSpace(request *DeleteWorkSpaceRequest) (response *DeleteWorkSpaceResponse, err error)
DeleteWorkSpace 删除工作空间
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" UNSUPPORTEDOPERATION_CANNOTDELETE = "UnsupportedOperation.CanNotDelete"
func (*Client) DeleteWorkSpaceWithContext ¶ added in v1.0.771
func (c *Client) DeleteWorkSpaceWithContext(ctx context.Context, request *DeleteWorkSpaceRequest) (response *DeleteWorkSpaceResponse, err error)
DeleteWorkSpace 删除工作空间
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" UNSUPPORTEDOPERATION_CANNOTDELETE = "UnsupportedOperation.CanNotDelete"
func (*Client) DescribeClusters ¶ added in v1.0.441
func (c *Client) DescribeClusters(request *DescribeClustersRequest) (response *DescribeClustersResponse, err error)
DescribeClusters 查询集群
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" FAILEDOPERATION_GETRESOURCETAGSBYRESOURCEIDS = "FailedOperation.GetResourceTagsByResourceIds" INTERNALERROR = "InternalError" INVALIDPARAMETERVALUE_CLUSTERIDS = "InvalidParameterValue.ClusterIds" INVALIDPARAMETERVALUE_ORDERTYPE = "InvalidParameterValue.OrderType" RESOURCENOTFOUND = "ResourceNotFound" UNAUTHORIZEDOPERATION = "UnauthorizedOperation" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeClustersWithContext ¶ added in v1.0.441
func (c *Client) DescribeClustersWithContext(ctx context.Context, request *DescribeClustersRequest) (response *DescribeClustersResponse, err error)
DescribeClusters 查询集群
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" FAILEDOPERATION_GETRESOURCETAGSBYRESOURCEIDS = "FailedOperation.GetResourceTagsByResourceIds" INTERNALERROR = "InternalError" INVALIDPARAMETERVALUE_CLUSTERIDS = "InvalidParameterValue.ClusterIds" INVALIDPARAMETERVALUE_ORDERTYPE = "InvalidParameterValue.OrderType" RESOURCENOTFOUND = "ResourceNotFound" UNAUTHORIZEDOPERATION = "UnauthorizedOperation" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeFolder ¶ added in v1.0.810
func (c *Client) DescribeFolder(request *DescribeFolderRequest) (response *DescribeFolderResponse, err error)
DescribeFolder 查询指定文件夹及其相应的子文件夹信息
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" FAILEDOPERATION_GETRESOURCETAGSBYRESOURCEIDS = "FailedOperation.GetResourceTagsByResourceIds" INTERNALERROR = "InternalError" INVALIDPARAMETERVALUE_CLUSTERIDS = "InvalidParameterValue.ClusterIds" INVALIDPARAMETERVALUE_ORDERTYPE = "InvalidParameterValue.OrderType" RESOURCENOTFOUND = "ResourceNotFound" UNAUTHORIZEDOPERATION = "UnauthorizedOperation" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeFolderWithContext ¶ added in v1.0.810
func (c *Client) DescribeFolderWithContext(ctx context.Context, request *DescribeFolderRequest) (response *DescribeFolderResponse, err error)
DescribeFolder 查询指定文件夹及其相应的子文件夹信息
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" FAILEDOPERATION_GETRESOURCETAGSBYRESOURCEIDS = "FailedOperation.GetResourceTagsByResourceIds" INTERNALERROR = "InternalError" INVALIDPARAMETERVALUE_CLUSTERIDS = "InvalidParameterValue.ClusterIds" INVALIDPARAMETERVALUE_ORDERTYPE = "InvalidParameterValue.OrderType" RESOURCENOTFOUND = "ResourceNotFound" UNAUTHORIZEDOPERATION = "UnauthorizedOperation" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeJobConfigs ¶
func (c *Client) DescribeJobConfigs(request *DescribeJobConfigsRequest) (response *DescribeJobConfigsResponse, err error)
DescribeJobConfigs 查询作业配置列表,一次最多查询100个
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INVALIDPARAMETER_ILLEGALMAXPARALLELISM = "InvalidParameter.IllegalMaxParallelism" INVALIDPARAMETER_MAXPARALLELISMTOOLARGE = "InvalidParameter.MaxParallelismTooLarge" INVALIDPARAMETER_MAXPARALLELISMTOOSMALL = "InvalidParameter.MaxParallelismTooSmall" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeJobConfigsWithContext ¶ added in v1.0.324
func (c *Client) DescribeJobConfigsWithContext(ctx context.Context, request *DescribeJobConfigsRequest) (response *DescribeJobConfigsResponse, err error)
DescribeJobConfigs 查询作业配置列表,一次最多查询100个
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INVALIDPARAMETER_ILLEGALMAXPARALLELISM = "InvalidParameter.IllegalMaxParallelism" INVALIDPARAMETER_MAXPARALLELISMTOOLARGE = "InvalidParameter.MaxParallelismTooLarge" INVALIDPARAMETER_MAXPARALLELISMTOOSMALL = "InvalidParameter.MaxParallelismTooSmall" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeJobEvents ¶ added in v1.0.822
func (c *Client) DescribeJobEvents(request *DescribeJobEventsRequest) (response *DescribeJobEventsResponse, err error)
DescribeJobEvents 获取指定作业的事件,包括作业启动停止、运行失败、快照失败、作业异常等各种事件类型
可能返回的错误码:
AUTHFAILURE = "AuthFailure" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_INVALIDAPPID = "InvalidParameter.InvalidAppId" INVALIDPARAMETERVALUE_JOBIDVALUEERROR = "InvalidParameterValue.JobIdValueError" INVALIDPARAMETERVALUE_TIMESTAMP = "InvalidParameterValue.Timestamp" INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeJobEventsWithContext ¶ added in v1.0.822
func (c *Client) DescribeJobEventsWithContext(ctx context.Context, request *DescribeJobEventsRequest) (response *DescribeJobEventsResponse, err error)
DescribeJobEvents 获取指定作业的事件,包括作业启动停止、运行失败、快照失败、作业异常等各种事件类型
可能返回的错误码:
AUTHFAILURE = "AuthFailure" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_INVALIDAPPID = "InvalidParameter.InvalidAppId" INVALIDPARAMETERVALUE_JOBIDVALUEERROR = "InvalidParameterValue.JobIdValueError" INVALIDPARAMETERVALUE_TIMESTAMP = "InvalidParameterValue.Timestamp" INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeJobSavepoint ¶ added in v1.0.404
func (c *Client) DescribeJobSavepoint(request *DescribeJobSavepointRequest) (response *DescribeJobSavepointResponse, err error)
DescribeJobSavepoint 查找Savepoint列表
可能返回的错误码:
AUTHFAILURE = "AuthFailure" INTERNALERROR = "InternalError" RESOURCENOTFOUND_JOBID = "ResourceNotFound.JobId" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeJobSavepointWithContext ¶ added in v1.0.404
func (c *Client) DescribeJobSavepointWithContext(ctx context.Context, request *DescribeJobSavepointRequest) (response *DescribeJobSavepointResponse, err error)
DescribeJobSavepoint 查找Savepoint列表
可能返回的错误码:
AUTHFAILURE = "AuthFailure" INTERNALERROR = "InternalError" RESOURCENOTFOUND_JOBID = "ResourceNotFound.JobId" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeJobSubmissionLog ¶ added in v1.0.702
func (c *Client) DescribeJobSubmissionLog(request *DescribeJobSubmissionLogRequest) (response *DescribeJobSubmissionLogResponse, err error)
DescribeJobSubmissionLog 查询作业实例启动日志
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INVALIDPARAMETER_ILLEGALSEARCHKEYWORD = "InvalidParameter.IllegalSearchKeyword" INVALIDPARAMETERVALUE_INVALIDLIMIT = "InvalidParameterValue.InvalidLimit" INVALIDPARAMETERVALUE_INVALIDTIME = "InvalidParameterValue.InvalidTime" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" RESOURCENOTFOUND_LOGTOPIC = "ResourceNotFound.LogTopic" UNSUPPORTEDOPERATION_CLSSQLNOTENABLED = "UnsupportedOperation.ClsSqlNotEnabled"
func (*Client) DescribeJobSubmissionLogWithContext ¶ added in v1.0.702
func (c *Client) DescribeJobSubmissionLogWithContext(ctx context.Context, request *DescribeJobSubmissionLogRequest) (response *DescribeJobSubmissionLogResponse, err error)
DescribeJobSubmissionLog 查询作业实例启动日志
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INVALIDPARAMETER_ILLEGALSEARCHKEYWORD = "InvalidParameter.IllegalSearchKeyword" INVALIDPARAMETERVALUE_INVALIDLIMIT = "InvalidParameterValue.InvalidLimit" INVALIDPARAMETERVALUE_INVALIDTIME = "InvalidParameterValue.InvalidTime" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" RESOURCENOTFOUND_LOGTOPIC = "ResourceNotFound.LogTopic" UNSUPPORTEDOPERATION_CLSSQLNOTENABLED = "UnsupportedOperation.ClsSqlNotEnabled"
func (*Client) DescribeJobs ¶
func (c *Client) DescribeJobs(request *DescribeJobsRequest) (response *DescribeJobsResponse, err error)
DescribeJobs 查询作业
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_CAMCGWERROR = "InternalError.CamCgwError" INTERNALERROR_DB = "InternalError.DB" RESOURCENOTFOUND_JOBID = "ResourceNotFound.JobId" RESOURCEUNAVAILABLE_GETJOBPUBLISHEDJOBCONFIG = "ResourceUnavailable.GetJobPublishedJobConfig" UNSUPPORTEDOPERATION = "UnsupportedOperation" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeJobsWithContext ¶ added in v1.0.324
func (c *Client) DescribeJobsWithContext(ctx context.Context, request *DescribeJobsRequest) (response *DescribeJobsResponse, err error)
DescribeJobs 查询作业
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_CAMCGWERROR = "InternalError.CamCgwError" INTERNALERROR_DB = "InternalError.DB" RESOURCENOTFOUND_JOBID = "ResourceNotFound.JobId" RESOURCEUNAVAILABLE_GETJOBPUBLISHEDJOBCONFIG = "ResourceUnavailable.GetJobPublishedJobConfig" UNSUPPORTEDOPERATION = "UnsupportedOperation" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeResourceConfigs ¶
func (c *Client) DescribeResourceConfigs(request *DescribeResourceConfigsRequest) (response *DescribeResourceConfigsResponse, err error)
DescribeResourceConfigs 描述资源配置接口
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INVALIDPARAMETER_APPIDRESOURCENOTMATCH = "InvalidParameter.AppIdResourceNotMatch" INVALIDPARAMETER_UINRESOURCENOTMATCH = "InvalidParameter.UinResourceNotMatch" INVALIDPARAMETERVALUE = "InvalidParameterValue" INVALIDPARAMETERVALUE_JOBIDVALUEERROR = "InvalidParameterValue.JobIdValueError" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" RESOURCENOTFOUND_RESOURCECONFIG = "ResourceNotFound.ResourceConfig" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeResourceConfigsWithContext ¶ added in v1.0.324
func (c *Client) DescribeResourceConfigsWithContext(ctx context.Context, request *DescribeResourceConfigsRequest) (response *DescribeResourceConfigsResponse, err error)
DescribeResourceConfigs 描述资源配置接口
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INVALIDPARAMETER_APPIDRESOURCENOTMATCH = "InvalidParameter.AppIdResourceNotMatch" INVALIDPARAMETER_UINRESOURCENOTMATCH = "InvalidParameter.UinResourceNotMatch" INVALIDPARAMETERVALUE = "InvalidParameterValue" INVALIDPARAMETERVALUE_JOBIDVALUEERROR = "InvalidParameterValue.JobIdValueError" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" RESOURCENOTFOUND_RESOURCECONFIG = "ResourceNotFound.ResourceConfig" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeResourceRelatedJobs ¶
func (c *Client) DescribeResourceRelatedJobs(request *DescribeResourceRelatedJobsRequest) (response *DescribeResourceRelatedJobsResponse, err error)
DescribeResourceRelatedJobs 获取资源关联作业信息
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INVALIDPARAMETERVALUE = "InvalidParameterValue" RESOURCENOTFOUND = "ResourceNotFound" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeResourceRelatedJobsWithContext ¶ added in v1.0.324
func (c *Client) DescribeResourceRelatedJobsWithContext(ctx context.Context, request *DescribeResourceRelatedJobsRequest) (response *DescribeResourceRelatedJobsResponse, err error)
DescribeResourceRelatedJobs 获取资源关联作业信息
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INVALIDPARAMETERVALUE = "InvalidParameterValue" RESOURCENOTFOUND = "ResourceNotFound" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeResources ¶
func (c *Client) DescribeResources(request *DescribeResourcesRequest) (response *DescribeResourcesResponse, err error)
DescribeResources 描述资源接口
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INVALIDPARAMETERVALUE = "InvalidParameterValue" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_RESOURCECONFIG = "ResourceNotFound.ResourceConfig" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeResourcesWithContext ¶ added in v1.0.324
func (c *Client) DescribeResourcesWithContext(ctx context.Context, request *DescribeResourcesRequest) (response *DescribeResourcesResponse, err error)
DescribeResources 描述资源接口
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INVALIDPARAMETERVALUE = "InvalidParameterValue" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_RESOURCECONFIG = "ResourceNotFound.ResourceConfig" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeSystemResources ¶
func (c *Client) DescribeSystemResources(request *DescribeSystemResourcesRequest) (response *DescribeSystemResourcesResponse, err error)
DescribeSystemResources 描述系统资源接口
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_FAILEDTOBESCRIBERESOURCES = "InternalError.FailedToBescribeResources" INVALIDPARAMETERVALUE = "InvalidParameterValue" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_CLUSTERID = "ResourceNotFound.ClusterId" RESOURCEUNAVAILABLE_FAILEDTOBESCRIBERESOURCES = "ResourceUnavailable.FailedToBescribeResources"
func (*Client) DescribeSystemResourcesWithContext ¶ added in v1.0.324
func (c *Client) DescribeSystemResourcesWithContext(ctx context.Context, request *DescribeSystemResourcesRequest) (response *DescribeSystemResourcesResponse, err error)
DescribeSystemResources 描述系统资源接口
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" INTERNALERROR = "InternalError" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_FAILEDTOBESCRIBERESOURCES = "InternalError.FailedToBescribeResources" INVALIDPARAMETERVALUE = "InvalidParameterValue" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_CLUSTERID = "ResourceNotFound.ClusterId" RESOURCEUNAVAILABLE_FAILEDTOBESCRIBERESOURCES = "ResourceUnavailable.FailedToBescribeResources"
func (*Client) DescribeTreeJobs ¶ added in v1.0.441
func (c *Client) DescribeTreeJobs(request *DescribeTreeJobsRequest) (response *DescribeTreeJobsResponse, err error)
DescribeTreeJobs 生成树状作业显示结构
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeTreeJobsWithContext ¶ added in v1.0.441
func (c *Client) DescribeTreeJobsWithContext(ctx context.Context, request *DescribeTreeJobsRequest) (response *DescribeTreeJobsResponse, err error)
DescribeTreeJobs 生成树状作业显示结构
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeTreeResources ¶ added in v1.0.482
func (c *Client) DescribeTreeResources(request *DescribeTreeResourcesRequest) (response *DescribeTreeResourcesResponse, err error)
DescribeTreeResources 查询树状结构资源列表
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" FAILEDOPERATION_DATASOURCECONNECTIONFAILED = "FailedOperation.DataSourceConnectionFailed" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeTreeResourcesWithContext ¶ added in v1.0.482
func (c *Client) DescribeTreeResourcesWithContext(ctx context.Context, request *DescribeTreeResourcesRequest) (response *DescribeTreeResourcesResponse, err error)
DescribeTreeResources 查询树状结构资源列表
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" FAILEDOPERATION_DATASOURCECONNECTIONFAILED = "FailedOperation.DataSourceConnectionFailed" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) DescribeWorkSpaces ¶ added in v1.0.683
func (c *Client) DescribeWorkSpaces(request *DescribeWorkSpacesRequest) (response *DescribeWorkSpacesResponse, err error)
DescribeWorkSpaces 授权工作空间列表
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter"
func (*Client) DescribeWorkSpacesWithContext ¶ added in v1.0.683
func (c *Client) DescribeWorkSpacesWithContext(ctx context.Context, request *DescribeWorkSpacesRequest) (response *DescribeWorkSpacesResponse, err error)
DescribeWorkSpaces 授权工作空间列表
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter"
func (*Client) FetchSqlGatewayStatementResult ¶ added in v1.0.767
func (c *Client) FetchSqlGatewayStatementResult(request *FetchSqlGatewayStatementResultRequest) (response *FetchSqlGatewayStatementResultResponse, err error)
FetchSqlGatewayStatementResult 查询Sql Gateway的Statement执行结果
可能返回的错误码:
FAILEDOPERATION_FAILEDOPERATIONCODE_FETCHSQLGATEWAYSTATEMENT = "FailedOperation.FailedOperationCode_FetchSqlGatewayStatement"
func (*Client) FetchSqlGatewayStatementResultWithContext ¶ added in v1.0.767
func (c *Client) FetchSqlGatewayStatementResultWithContext(ctx context.Context, request *FetchSqlGatewayStatementResultRequest) (response *FetchSqlGatewayStatementResultResponse, err error)
FetchSqlGatewayStatementResult 查询Sql Gateway的Statement执行结果
可能返回的错误码:
FAILEDOPERATION_FAILEDOPERATIONCODE_FETCHSQLGATEWAYSTATEMENT = "FailedOperation.FailedOperationCode_FetchSqlGatewayStatement"
func (*Client) GetMetaTable ¶ added in v1.0.829
func (c *Client) GetMetaTable(request *GetMetaTableRequest) (response *GetMetaTableResponse, err error)
GetMetaTable 查询元数据表
可能返回的错误码:
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" RESOURCENOTFOUND_TABLENOTEXIST = "ResourceNotFound.TableNotExist"
func (*Client) GetMetaTableWithContext ¶ added in v1.0.829
func (c *Client) GetMetaTableWithContext(ctx context.Context, request *GetMetaTableRequest) (response *GetMetaTableResponse, err error)
GetMetaTable 查询元数据表
可能返回的错误码:
AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" RESOURCENOTFOUND_TABLENOTEXIST = "ResourceNotFound.TableNotExist"
func (*Client) ModifyFolder ¶ added in v1.0.769
func (c *Client) ModifyFolder(request *ModifyFolderRequest) (response *ModifyFolderResponse, err error)
ModifyFolder 自定义树状结构页面拖拽文件夹
可能返回的错误码:
FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INVALIDPARAMETERVALUE = "InvalidParameterValue" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) ModifyFolderWithContext ¶ added in v1.0.769
func (c *Client) ModifyFolderWithContext(ctx context.Context, request *ModifyFolderRequest) (response *ModifyFolderResponse, err error)
ModifyFolder 自定义树状结构页面拖拽文件夹
可能返回的错误码:
FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INVALIDPARAMETERVALUE = "InvalidParameterValue" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) ModifyJob ¶ added in v1.0.420
func (c *Client) ModifyJob(request *ModifyJobRequest) (response *ModifyJobResponse, err error)
ModifyJob 更新作业属性,仅允许以下3种操作,不支持组合操作:
(1) 更新作业名称
(2) 更新作业备注
(3) 更新作业最大并行度
变更前提:WorkerCuNum<=MaxParallelism
如果MaxParallelism变小,不重启作业,待下一次重启生效
如果MaxParallelism变大,则要求入参RestartAllowed必须为True
假设作业运行状态,则先停止作业,再启动作业,中间状态丢失
假设作业暂停状态,则将作业更改为停止状态,中间状态丢失
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" FAILEDOPERATION_DUPLICATEDJOBNAME = "FailedOperation.DuplicatedJobName" INTERNALERROR_JOBINSTANCENOTFOUND = "InternalError.JobInstanceNotFound" INTERNALERROR_SYSTEMERROR = "InternalError.SystemError" INVALIDPARAMETERVALUE_JOBNAME = "InvalidParameterValue.JobName" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) ModifyJobWithContext ¶ added in v1.0.420
func (c *Client) ModifyJobWithContext(ctx context.Context, request *ModifyJobRequest) (response *ModifyJobResponse, err error)
ModifyJob 更新作业属性,仅允许以下3种操作,不支持组合操作:
(1) 更新作业名称
(2) 更新作业备注
(3) 更新作业最大并行度
变更前提:WorkerCuNum<=MaxParallelism
如果MaxParallelism变小,不重启作业,待下一次重启生效
如果MaxParallelism变大,则要求入参RestartAllowed必须为True
假设作业运行状态,则先停止作业,再启动作业,中间状态丢失
假设作业暂停状态,则将作业更改为停止状态,中间状态丢失
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" FAILEDOPERATION_DUPLICATEDJOBNAME = "FailedOperation.DuplicatedJobName" INTERNALERROR_JOBINSTANCENOTFOUND = "InternalError.JobInstanceNotFound" INTERNALERROR_SYSTEMERROR = "InternalError.SystemError" INVALIDPARAMETERVALUE_JOBNAME = "InvalidParameterValue.JobName" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) ModifyWorkSpace ¶ added in v1.0.769
func (c *Client) ModifyWorkSpace(request *ModifyWorkSpaceRequest) (response *ModifyWorkSpaceResponse, err error)
ModifyWorkSpace 修改工作空间
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_DUPLICATEDSPACENAME = "InvalidParameter.DuplicatedSpaceName" INVALIDPARAMETER_INVALIDITEMSPACENAME = "InvalidParameter.InvalidItemSpaceName" UNSUPPORTEDOPERATION = "UnsupportedOperation"
func (*Client) ModifyWorkSpaceWithContext ¶ added in v1.0.769
func (c *Client) ModifyWorkSpaceWithContext(ctx context.Context, request *ModifyWorkSpaceRequest) (response *ModifyWorkSpaceResponse, err error)
ModifyWorkSpace 修改工作空间
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INVALIDPARAMETER = "InvalidParameter" INVALIDPARAMETER_DUPLICATEDSPACENAME = "InvalidParameter.DuplicatedSpaceName" INVALIDPARAMETER_INVALIDITEMSPACENAME = "InvalidParameter.InvalidItemSpaceName" UNSUPPORTEDOPERATION = "UnsupportedOperation"
func (*Client) RunJobs ¶
func (c *Client) RunJobs(request *RunJobsRequest) (response *RunJobsResponse, err error)
RunJobs 批量启动或者恢复作业,批量操作数量上限20
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR_COSCLIENT = "InternalError.COSClient" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_FAILEDTOUPDATEJOB = "InternalError.FailedToUpdateJob" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INTERNALERROR_STSNEWCLIENT = "InternalError.StsNewClient" INVALIDPARAMETER_INVALIDCLUSTERID = "InvalidParameter.InvalidClusterId" INVALIDPARAMETER_INVALIDREGION = "InvalidParameter.InvalidRegion" INVALIDPARAMETERVALUE_INVALIDSTARTMODE = "InvalidParameterValue.InvalidStartMode" INVALIDPARAMETERVALUE_JOBIDVALUEERROR = "InvalidParameterValue.JobIdValueError" INVALIDPARAMETERVALUE_RUNJOBDESCRIPTIONSCOUNT = "InvalidParameterValue.RunJobDescriptionsCount" INVALIDPARAMETERVALUE_RUNTYPE = "InvalidParameterValue.RunType" RESOURCEINUSE_INSTANCEINPROCESS = "ResourceInUse.InstanceInProcess" RESOURCEINSUFFICIENT_CU = "ResourceInsufficient.CU" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_COSBUCKET = "ResourceNotFound.COSBucket" RESOURCENOTFOUND_CLUSTERID = "ResourceNotFound.ClusterId" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" RESOURCENOTFOUND_JOBCONFIG = "ResourceNotFound.JobConfig" RESOURCENOTFOUND_RESOURCE = "ResourceNotFound.Resource" RESOURCEUNAVAILABLE = "ResourceUnavailable" RESOURCEUNAVAILABLE_JOBRESOURCECONFIGNOTREADY = "ResourceUnavailable.JobResourceConfigNotReady" RESOURCEUNAVAILABLE_NORUNNINGJOBINSTANCESFOUNDFORJOBID = "ResourceUnavailable.NoRunningJobInstancesFoundForJobId" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess" UNSUPPORTEDOPERATION_UNSUPPORTEDSTARTMODE = "UnsupportedOperation.UnsupportedStartMode"
func (*Client) RunJobsWithContext ¶ added in v1.0.324
func (c *Client) RunJobsWithContext(ctx context.Context, request *RunJobsRequest) (response *RunJobsResponse, err error)
RunJobs 批量启动或者恢复作业,批量操作数量上限20
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR_COSCLIENT = "InternalError.COSClient" INTERNALERROR_DB = "InternalError.DB" INTERNALERROR_FAILEDTOUPDATEJOB = "InternalError.FailedToUpdateJob" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INTERNALERROR_STSNEWCLIENT = "InternalError.StsNewClient" INVALIDPARAMETER_INVALIDCLUSTERID = "InvalidParameter.InvalidClusterId" INVALIDPARAMETER_INVALIDREGION = "InvalidParameter.InvalidRegion" INVALIDPARAMETERVALUE_INVALIDSTARTMODE = "InvalidParameterValue.InvalidStartMode" INVALIDPARAMETERVALUE_JOBIDVALUEERROR = "InvalidParameterValue.JobIdValueError" INVALIDPARAMETERVALUE_RUNJOBDESCRIPTIONSCOUNT = "InvalidParameterValue.RunJobDescriptionsCount" INVALIDPARAMETERVALUE_RUNTYPE = "InvalidParameterValue.RunType" RESOURCEINUSE_INSTANCEINPROCESS = "ResourceInUse.InstanceInProcess" RESOURCEINSUFFICIENT_CU = "ResourceInsufficient.CU" RESOURCENOTFOUND = "ResourceNotFound" RESOURCENOTFOUND_COSBUCKET = "ResourceNotFound.COSBucket" RESOURCENOTFOUND_CLUSTERID = "ResourceNotFound.ClusterId" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" RESOURCENOTFOUND_JOBCONFIG = "ResourceNotFound.JobConfig" RESOURCENOTFOUND_RESOURCE = "ResourceNotFound.Resource" RESOURCEUNAVAILABLE = "ResourceUnavailable" RESOURCEUNAVAILABLE_JOBRESOURCECONFIGNOTREADY = "ResourceUnavailable.JobResourceConfigNotReady" RESOURCEUNAVAILABLE_NORUNNINGJOBINSTANCESFOUNDFORJOBID = "ResourceUnavailable.NoRunningJobInstancesFoundForJobId" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess" UNSUPPORTEDOPERATION_UNSUPPORTEDSTARTMODE = "UnsupportedOperation.UnsupportedStartMode"
func (*Client) RunSqlGatewayStatement ¶ added in v1.0.767
func (c *Client) RunSqlGatewayStatement(request *RunSqlGatewayStatementRequest) (response *RunSqlGatewayStatementResponse, err error)
RunSqlGatewayStatement 通过Sql gateway执行satement
可能返回的错误码:
FAILEDOPERATION_FAILEDOPERATIONCODE_RUNSQLGATEWAY = "FailedOperation.FailedOperationCode_RunSqlGateway"
func (*Client) RunSqlGatewayStatementWithContext ¶ added in v1.0.767
func (c *Client) RunSqlGatewayStatementWithContext(ctx context.Context, request *RunSqlGatewayStatementRequest) (response *RunSqlGatewayStatementResponse, err error)
RunSqlGatewayStatement 通过Sql gateway执行satement
可能返回的错误码:
FAILEDOPERATION_FAILEDOPERATIONCODE_RUNSQLGATEWAY = "FailedOperation.FailedOperationCode_RunSqlGateway"
func (*Client) StopJobs ¶
func (c *Client) StopJobs(request *StopJobsRequest) (response *StopJobsResponse, err error)
StopJobs 批量停止作业,批量操作数量上限为20
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INTERNALERROR_RESOURCENOTEXIST = "InternalError.ResourceNotExist" INVALIDPARAMETERVALUE_UNKNOWNSTOPTYPE = "InvalidParameterValue.UnknownStopType" RESOURCEINUSE = "ResourceInUse" RESOURCENOTFOUND_COSBUCKET = "ResourceNotFound.COSBucket" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" RESOURCENOTFOUND_RESOURCENOTEXIST = "ResourceNotFound.ResourceNotExist" RESOURCEUNAVAILABLE_NORUNNINGJOBINSTANCESFOUNDFORJOBID = "ResourceUnavailable.NoRunningJobInstancesFoundForJobId" RESOURCEUNAVAILABLE_NOTALLOWEDTOBESTOPORPAUSE = "ResourceUnavailable.NotAllowedToBeStopOrPause" UNSUPPORTEDOPERATION = "UnsupportedOperation" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) StopJobsWithContext ¶ added in v1.0.324
func (c *Client) StopJobsWithContext(ctx context.Context, request *StopJobsRequest) (response *StopJobsResponse, err error)
StopJobs 批量停止作业,批量操作数量上限为20
可能返回的错误码:
AUTHFAILURE = "AuthFailure" AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" INTERNALERROR_LOGICERROR = "InternalError.LogicError" INTERNALERROR_RESOURCENOTEXIST = "InternalError.ResourceNotExist" INVALIDPARAMETERVALUE_UNKNOWNSTOPTYPE = "InvalidParameterValue.UnknownStopType" RESOURCEINUSE = "ResourceInUse" RESOURCENOTFOUND_COSBUCKET = "ResourceNotFound.COSBucket" RESOURCENOTFOUND_JOB = "ResourceNotFound.Job" RESOURCENOTFOUND_RESOURCENOTEXIST = "ResourceNotFound.ResourceNotExist" RESOURCEUNAVAILABLE_NORUNNINGJOBINSTANCESFOUNDFORJOBID = "ResourceUnavailable.NoRunningJobInstancesFoundForJobId" RESOURCEUNAVAILABLE_NOTALLOWEDTOBESTOPORPAUSE = "ResourceUnavailable.NotAllowedToBeStopOrPause" UNSUPPORTEDOPERATION = "UnsupportedOperation" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) TriggerJobSavepoint ¶ added in v1.0.415
func (c *Client) TriggerJobSavepoint(request *TriggerJobSavepointRequest) (response *TriggerJobSavepointResponse, err error)
TriggerJobSavepoint 触发Savepoint
可能返回的错误码:
AUTHFAILURE = "AuthFailure" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
func (*Client) TriggerJobSavepointWithContext ¶ added in v1.0.415
func (c *Client) TriggerJobSavepointWithContext(ctx context.Context, request *TriggerJobSavepointRequest) (response *TriggerJobSavepointResponse, err error)
TriggerJobSavepoint 触发Savepoint
可能返回的错误码:
AUTHFAILURE = "AuthFailure" FAILEDOPERATION = "FailedOperation" INTERNALERROR = "InternalError" UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"
type Cluster ¶ added in v1.0.441
type Cluster struct { // 集群 ID ClusterId *string `json:"ClusterId,omitnil,omitempty" name:"ClusterId"` // 集群名称 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 地域 Region *string `json:"Region,omitnil,omitempty" name:"Region"` // 用户 AppID AppId *uint64 `json:"AppId,omitnil,omitempty" name:"AppId"` // 主账号 UIN OwnerUin *string `json:"OwnerUin,omitnil,omitempty" name:"OwnerUin"` // 创建者 UIN CreatorUin *string `json:"CreatorUin,omitnil,omitempty" name:"CreatorUin"` // 集群状态, 1 未初始化,,3 初始化中,2 运行中 Status *int64 `json:"Status,omitnil,omitempty" name:"Status"` // 描述 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 集群创建时间 CreateTime *string `json:"CreateTime,omitnil,omitempty" name:"CreateTime"` // 最后一次操作集群的时间 UpdateTime *string `json:"UpdateTime,omitnil,omitempty" name:"UpdateTime"` // CU 数量 CuNum *uint64 `json:"CuNum,omitnil,omitempty" name:"CuNum"` // CU 内存规格 CuMem *uint64 `json:"CuMem,omitnil,omitempty" name:"CuMem"` // 可用区 Zone *string `json:"Zone,omitnil,omitempty" name:"Zone"` // 状态描述 StatusDesc *string `json:"StatusDesc,omitnil,omitempty" name:"StatusDesc"` // 网络 CCNs []*CCN `json:"CCNs,omitnil,omitempty" name:"CCNs"` // 网络 NetEnvironmentType *uint64 `json:"NetEnvironmentType,omitnil,omitempty" name:"NetEnvironmentType"` // 空闲 CU FreeCuNum *int64 `json:"FreeCuNum,omitnil,omitempty" name:"FreeCuNum"` // 集群绑定的标签 // 注意:此字段可能返回 null,表示取不到有效值。 Tags []*Tag `json:"Tags,omitnil,omitempty" name:"Tags"` // 集群隔离时间; 没隔离时间,则为 - // 注意:此字段可能返回 null,表示取不到有效值。 IsolatedTime *string `json:"IsolatedTime,omitnil,omitempty" name:"IsolatedTime"` // 集群过期时间; 没过期概念,则为 - // 注意:此字段可能返回 null,表示取不到有效值。 ExpireTime *string `json:"ExpireTime,omitnil,omitempty" name:"ExpireTime"` // 距离过期还有多少秒; 没过期概念,则为 - // 注意:此字段可能返回 null,表示取不到有效值。 SecondsUntilExpiry *string `json:"SecondsUntilExpiry,omitnil,omitempty" name:"SecondsUntilExpiry"` // 自动续费标记,0 表示默认状态 (用户未设置,即初始状态,用户开通了预付费不停服特权会进行自动续费), 1 表示自动续费,2表示明确不自动续费(用户设置) // 注意:此字段可能返回 null,表示取不到有效值。 AutoRenewFlag *int64 `json:"AutoRenewFlag,omitnil,omitempty" name:"AutoRenewFlag"` // 集群的默认 COS 存储桶 // 注意:此字段可能返回 null,表示取不到有效值。 DefaultCOSBucket *string `json:"DefaultCOSBucket,omitnil,omitempty" name:"DefaultCOSBucket"` // 集群的CLS 日志集 LogSet // 注意:此字段可能返回 null,表示取不到有效值。 CLSLogSet *string `json:"CLSLogSet,omitnil,omitempty" name:"CLSLogSet"` // 集群的CLS 日志主题 TopicId // 注意:此字段可能返回 null,表示取不到有效值。 CLSTopicId *string `json:"CLSTopicId,omitnil,omitempty" name:"CLSTopicId"` // 集群的CLS 日志集 名字 // 注意:此字段可能返回 null,表示取不到有效值。 CLSLogName *string `json:"CLSLogName,omitnil,omitempty" name:"CLSLogName"` // 集群的CLS 日志主题 名字 // 注意:此字段可能返回 null,表示取不到有效值。 CLSTopicName *string `json:"CLSTopicName,omitnil,omitempty" name:"CLSTopicName"` // 集群的版本信息 // 注意:此字段可能返回 null,表示取不到有效值。 Version *ClusterVersion `json:"Version,omitnil,omitempty" name:"Version"` // 细粒度资源下的空闲CU // 注意:此字段可能返回 null,表示取不到有效值。 FreeCu *float64 `json:"FreeCu,omitnil,omitempty" name:"FreeCu"` // 集群的默认日志采集配置 // 注意:此字段可能返回 null,表示取不到有效值。 DefaultLogCollectConf *string `json:"DefaultLogCollectConf,omitnil,omitempty" name:"DefaultLogCollectConf"` // 取值:0-没有设置,1-已设置,2-不允许设置 // 注意:此字段可能返回 null,表示取不到有效值。 CustomizedDNSEnabled *int64 `json:"CustomizedDNSEnabled,omitnil,omitempty" name:"CustomizedDNSEnabled"` // 空间信息 // 注意:此字段可能返回 null,表示取不到有效值。 Correlations []*WorkSpaceClusterItem `json:"Correlations,omitnil,omitempty" name:"Correlations"` // 运行CU // 注意:此字段可能返回 null,表示取不到有效值。 RunningCu *float64 `json:"RunningCu,omitnil,omitempty" name:"RunningCu"` // 0 后付费,1 预付费 // 注意:此字段可能返回 null,表示取不到有效值。 PayMode *int64 `json:"PayMode,omitnil,omitempty" name:"PayMode"` // 前端区分 集群是否需要2CU逻辑 因为历史集群 变配不需要, default 1 新集群都需要 // 注意:此字段可能返回 null,表示取不到有效值。 IsNeedManageNode *int64 `json:"IsNeedManageNode,omitnil,omitempty" name:"IsNeedManageNode"` // session集群信息 // 注意:此字段可能返回 null,表示取不到有效值。 ClusterSessions []*ClusterSession `json:"ClusterSessions,omitnil,omitempty" name:"ClusterSessions"` // V3版本 = 2 // 注意:此字段可能返回 null,表示取不到有效值。 ArchGeneration *uint64 `json:"ArchGeneration,omitnil,omitempty" name:"ArchGeneration"` // 0:TKE, 1:EKS // 注意:此字段可能返回 null,表示取不到有效值。 ClusterType *uint64 `json:"ClusterType,omitnil,omitempty" name:"ClusterType"` // 订单信息 // 注意:此字段可能返回 null,表示取不到有效值。 Orders []*Order `json:"Orders,omitnil,omitempty" name:"Orders"` // Gateway信息 // 注意:此字段可能返回 null,表示取不到有效值。 SqlGateways []*SqlGatewayItem `json:"SqlGateways,omitnil,omitempty" name:"SqlGateways"` // 0 公网访问 // 1 内网访问 // 注意:此字段可能返回 null,表示取不到有效值。 WebUIType *int64 `json:"WebUIType,omitnil,omitempty" name:"WebUIType"` // 2 独享集群 // 注意:此字段可能返回 null,表示取不到有效值。 Type *int64 `json:"Type,omitnil,omitempty" name:"Type"` // 子eks集群 // 注意:此字段可能返回 null,表示取不到有效值。 SubEks *SubEks `json:"SubEks,omitnil,omitempty" name:"SubEks"` // 上级集群 // 注意:此字段可能返回 null,表示取不到有效值。 AgentSerialId *string `json:"AgentSerialId,omitnil,omitempty" name:"AgentSerialId"` // 资源类型 // 注意:此字段可能返回 null,表示取不到有效值。 ResourceType *int64 `json:"ResourceType,omitnil,omitempty" name:"ResourceType"` }
type ClusterGroupSetItem ¶ added in v1.0.683
type ClusterGroupSetItem struct { // clusterGroup 的 SerialId ClusterId *string `json:"ClusterId,omitnil,omitempty" name:"ClusterId"` // 集群名称 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 地域 Region *string `json:"Region,omitnil,omitempty" name:"Region"` // 区 Zone *string `json:"Zone,omitnil,omitempty" name:"Zone"` // 账号 APPID AppId *int64 `json:"AppId,omitnil,omitempty" name:"AppId"` // 主账号 UIN OwnerUin *string `json:"OwnerUin,omitnil,omitempty" name:"OwnerUin"` // 创建账号 UIN CreatorUin *string `json:"CreatorUin,omitnil,omitempty" name:"CreatorUin"` // CU 数量 CuNum *int64 `json:"CuNum,omitnil,omitempty" name:"CuNum"` // CU 内存规格 CuMem *int64 `json:"CuMem,omitnil,omitempty" name:"CuMem"` // 集群状态, 1 未初始化,,3 初始化中,2 运行中 Status *int64 `json:"Status,omitnil,omitempty" name:"Status"` // 状态描述 StatusDesc *string `json:"StatusDesc,omitnil,omitempty" name:"StatusDesc"` // 集群创建时间 CreateTime *string `json:"CreateTime,omitnil,omitempty" name:"CreateTime"` // 最后一次操作集群的时间 UpdateTime *string `json:"UpdateTime,omitnil,omitempty" name:"UpdateTime"` // 描述 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 网络 NetEnvironmentType *int64 `json:"NetEnvironmentType,omitnil,omitempty" name:"NetEnvironmentType"` // 空闲 CU FreeCuNum *int64 `json:"FreeCuNum,omitnil,omitempty" name:"FreeCuNum"` // 细粒度资源下的空闲CU FreeCu *float64 `json:"FreeCu,omitnil,omitempty" name:"FreeCu"` // 运行中CU RunningCu *float64 `json:"RunningCu,omitnil,omitempty" name:"RunningCu"` // 付费模式 PayMode *int64 `json:"PayMode,omitnil,omitempty" name:"PayMode"` // 弹性 // 注意:此字段可能返回 null,表示取不到有效值。 SubEks *SubEks `json:"SubEks,omitnil,omitempty" name:"SubEks"` }
type ClusterSession ¶ added in v1.0.655
type ClusterSession struct { // 集群SerialId ClusterGroupSerialId *string `json:"ClusterGroupSerialId,omitnil,omitempty" name:"ClusterGroupSerialId"` // 创建者appId AppId *int64 `json:"AppId,omitnil,omitempty" name:"AppId"` // 创建者主账号 OwnerUin *string `json:"OwnerUin,omitnil,omitempty" name:"OwnerUin"` // 创建者账号 CreatorUin *string `json:"CreatorUin,omitnil,omitempty" name:"CreatorUin"` // 区域 Region *string `json:"Region,omitnil,omitempty" name:"Region"` // zone Zone *string `json:"Zone,omitnil,omitempty" name:"Zone"` // Session集群状态 Status *int64 `json:"Status,omitnil,omitempty" name:"Status"` // Session集群消耗的cu数量 CuNum *float64 `json:"CuNum,omitnil,omitempty" name:"CuNum"` // Session集群的Flink版本 FlinkVersion *string `json:"FlinkVersion,omitnil,omitempty" name:"FlinkVersion"` // session集群FlinkUi地址 WebUIUrl *string `json:"WebUIUrl,omitnil,omitempty" name:"WebUIUrl"` // session集群高级参数 // 注意:此字段可能返回 null,表示取不到有效值。 Properties []*Property `json:"Properties,omitnil,omitempty" name:"Properties"` // JobManager的规格 JobManagerCuSpec *float64 `json:"JobManagerCuSpec,omitnil,omitempty" name:"JobManagerCuSpec"` // TaskManager的规格 TaskManagerCuSpec *float64 `json:"TaskManagerCuSpec,omitnil,omitempty" name:"TaskManagerCuSpec"` // TaskManager启动的数量 TaskManagerNum *int64 `json:"TaskManagerNum,omitnil,omitempty" name:"TaskManagerNum"` // 创建时间 CreateTime *string `json:"CreateTime,omitnil,omitempty" name:"CreateTime"` // 更新时间 UpdateTime *string `json:"UpdateTime,omitnil,omitempty" name:"UpdateTime"` }
type ClusterVersion ¶ added in v1.0.441
type CopyJobItem ¶ added in v1.0.450
type CopyJobItem struct { // 需要复制的作业serial id SourceId *string `json:"SourceId,omitnil,omitempty" name:"SourceId"` // 目标集群的cluster serial id TargetClusterId *string `json:"TargetClusterId,omitnil,omitempty" name:"TargetClusterId"` // 需要复制的作业名称 SourceName *string `json:"SourceName,omitnil,omitempty" name:"SourceName"` // 新作业的名称 TargetName *string `json:"TargetName,omitnil,omitempty" name:"TargetName"` // 新作业的目录id TargetFolderId *string `json:"TargetFolderId,omitnil,omitempty" name:"TargetFolderId"` // 源作业类型 JobType *int64 `json:"JobType,omitnil,omitempty" name:"JobType"` }
type CopyJobResult ¶ added in v1.0.450
type CopyJobResult struct { // 原作业id // 注意:此字段可能返回 null,表示取不到有效值。 JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 原作业名称 // 注意:此字段可能返回 null,表示取不到有效值。 JobName *string `json:"JobName,omitnil,omitempty" name:"JobName"` // 新作业名称 // 注意:此字段可能返回 null,表示取不到有效值。 TargetJobName *string `json:"TargetJobName,omitnil,omitempty" name:"TargetJobName"` // 新作业id // 注意:此字段可能返回 null,表示取不到有效值。 TargetJobId *string `json:"TargetJobId,omitnil,omitempty" name:"TargetJobId"` // 失败时候的信息 // 注意:此字段可能返回 null,表示取不到有效值。 Message *string `json:"Message,omitnil,omitempty" name:"Message"` // 0 成功 -1 失败 // 注意:此字段可能返回 null,表示取不到有效值。 Result *int64 `json:"Result,omitnil,omitempty" name:"Result"` // 目标集群名称 // 注意:此字段可能返回 null,表示取不到有效值。 ClusterName *string `json:"ClusterName,omitnil,omitempty" name:"ClusterName"` // 目标集群id // 注意:此字段可能返回 null,表示取不到有效值。 ClusterId *string `json:"ClusterId,omitnil,omitempty" name:"ClusterId"` // 作业类型 // 注意:此字段可能返回 null,表示取不到有效值。 JobType *int64 `json:"JobType,omitnil,omitempty" name:"JobType"` }
type CopyJobsRequest ¶ added in v1.0.449
type CopyJobsRequest struct { *tchttp.BaseRequest // 复制明细列表 JobItems []*CopyJobItem `json:"JobItems,omitnil,omitempty" name:"JobItems"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 目标工作空间 SerialId TargetWorkspaceId *string `json:"TargetWorkspaceId,omitnil,omitempty" name:"TargetWorkspaceId"` }
func NewCopyJobsRequest ¶ added in v1.0.449
func NewCopyJobsRequest() (request *CopyJobsRequest)
func (*CopyJobsRequest) FromJsonString ¶ added in v1.0.449
func (r *CopyJobsRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CopyJobsRequest) ToJsonString ¶ added in v1.0.449
func (r *CopyJobsRequest) ToJsonString() string
type CopyJobsRequestParams ¶ added in v1.0.449
type CopyJobsRequestParams struct { // 复制明细列表 JobItems []*CopyJobItem `json:"JobItems,omitnil,omitempty" name:"JobItems"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 目标工作空间 SerialId TargetWorkspaceId *string `json:"TargetWorkspaceId,omitnil,omitempty" name:"TargetWorkspaceId"` }
Predefined struct for user
type CopyJobsResponse ¶ added in v1.0.449
type CopyJobsResponse struct { *tchttp.BaseResponse Response *CopyJobsResponseParams `json:"Response"` }
func NewCopyJobsResponse ¶ added in v1.0.449
func NewCopyJobsResponse() (response *CopyJobsResponse)
func (*CopyJobsResponse) FromJsonString ¶ added in v1.0.449
func (r *CopyJobsResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CopyJobsResponse) ToJsonString ¶ added in v1.0.449
func (r *CopyJobsResponse) ToJsonString() string
type CopyJobsResponseParams ¶ added in v1.0.449
type CopyJobsResponseParams struct { // 成功条数 // 注意:此字段可能返回 null,表示取不到有效值。 SuccessCount *int64 `json:"SuccessCount,omitnil,omitempty" name:"SuccessCount"` // 失败条数 // 注意:此字段可能返回 null,表示取不到有效值。 FailCount *int64 `json:"FailCount,omitnil,omitempty" name:"FailCount"` // 结果列表 // 注意:此字段可能返回 null,表示取不到有效值。 CopyJobsResults []*CopyJobResult `json:"CopyJobsResults,omitnil,omitempty" name:"CopyJobsResults"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type CreateFolderRequest ¶ added in v1.0.449
type CreateFolderRequest struct { *tchttp.BaseRequest // 新建文件夹名 FolderName *string `json:"FolderName,omitnil,omitempty" name:"FolderName"` // 新建文件夹的父目录ID(根目录为"root") ParentId *string `json:"ParentId,omitnil,omitempty" name:"ParentId"` // 文件夹类型,0是任务文件夹,1是依赖文件夹 FolderType *int64 `json:"FolderType,omitnil,omitempty" name:"FolderType"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewCreateFolderRequest ¶ added in v1.0.449
func NewCreateFolderRequest() (request *CreateFolderRequest)
func (*CreateFolderRequest) FromJsonString ¶ added in v1.0.449
func (r *CreateFolderRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateFolderRequest) ToJsonString ¶ added in v1.0.449
func (r *CreateFolderRequest) ToJsonString() string
type CreateFolderRequestParams ¶ added in v1.0.449
type CreateFolderRequestParams struct { // 新建文件夹名 FolderName *string `json:"FolderName,omitnil,omitempty" name:"FolderName"` // 新建文件夹的父目录ID(根目录为"root") ParentId *string `json:"ParentId,omitnil,omitempty" name:"ParentId"` // 文件夹类型,0是任务文件夹,1是依赖文件夹 FolderType *int64 `json:"FolderType,omitnil,omitempty" name:"FolderType"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type CreateFolderResponse ¶ added in v1.0.449
type CreateFolderResponse struct { *tchttp.BaseResponse Response *CreateFolderResponseParams `json:"Response"` }
func NewCreateFolderResponse ¶ added in v1.0.449
func NewCreateFolderResponse() (response *CreateFolderResponse)
func (*CreateFolderResponse) FromJsonString ¶ added in v1.0.449
func (r *CreateFolderResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateFolderResponse) ToJsonString ¶ added in v1.0.449
func (r *CreateFolderResponse) ToJsonString() string
type CreateFolderResponseParams ¶ added in v1.0.449
type CreateFolderResponseParams struct { // 新建文件夹的唯一ID FolderId *string `json:"FolderId,omitnil,omitempty" name:"FolderId"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type CreateJobConfigRequest ¶
type CreateJobConfigRequest struct { *tchttp.BaseRequest // 作业Id JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 主类 EntrypointClass *string `json:"EntrypointClass,omitnil,omitempty" name:"EntrypointClass"` // 主类入参 ProgramArgs *string `json:"ProgramArgs,omitnil,omitempty" name:"ProgramArgs"` // 备注 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 资源引用数组 ResourceRefs []*ResourceRef `json:"ResourceRefs,omitnil,omitempty" name:"ResourceRefs"` // 作业默认并行度 DefaultParallelism *uint64 `json:"DefaultParallelism,omitnil,omitempty" name:"DefaultParallelism"` // 系统参数 Properties []*Property `json:"Properties,omitnil,omitempty" name:"Properties"` // 1: 作业配置达到上限之后,自动删除可删除的最早版本 AutoDelete *int64 `json:"AutoDelete,omitnil,omitempty" name:"AutoDelete"` // 作业使用的 COS 存储桶名 COSBucket *string `json:"COSBucket,omitnil,omitempty" name:"COSBucket"` // 是否采集作业日志 LogCollect *bool `json:"LogCollect,omitnil,omitempty" name:"LogCollect"` // JobManager规格 JobManagerSpec *float64 `json:"JobManagerSpec,omitnil,omitempty" name:"JobManagerSpec"` // TaskManager规格 TaskManagerSpec *float64 `json:"TaskManagerSpec,omitnil,omitempty" name:"TaskManagerSpec"` // CLS日志集ID ClsLogsetId *string `json:"ClsLogsetId,omitnil,omitempty" name:"ClsLogsetId"` // CLS日志主题ID ClsTopicId *string `json:"ClsTopicId,omitnil,omitempty" name:"ClsTopicId"` // 日志采集类型 2:CLS;3:COS LogCollectType *int64 `json:"LogCollectType,omitnil,omitempty" name:"LogCollectType"` // pyflink作业运行时使用的python版本 PythonVersion *string `json:"PythonVersion,omitnil,omitempty" name:"PythonVersion"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 日志级别 LogLevel *string `json:"LogLevel,omitnil,omitempty" name:"LogLevel"` // Oceanus 平台恢复作业开关 1:开启 -1: 关闭 AutoRecover *int64 `json:"AutoRecover,omitnil,omitempty" name:"AutoRecover"` // 类日志级别 ClazzLevels []*ClazzLevel `json:"ClazzLevels,omitnil,omitempty" name:"ClazzLevels"` // 是否打开专家模式 ExpertModeOn *bool `json:"ExpertModeOn,omitnil,omitempty" name:"ExpertModeOn"` // 专家模式的配置 ExpertModeConfiguration *ExpertModeConfiguration `json:"ExpertModeConfiguration,omitnil,omitempty" name:"ExpertModeConfiguration"` // trace链路 TraceModeOn *bool `json:"TraceModeOn,omitnil,omitempty" name:"TraceModeOn"` // trace链路配置 TraceModeConfiguration *TraceModeConfiguration `json:"TraceModeConfiguration,omitnil,omitempty" name:"TraceModeConfiguration"` // checkpoint保留个数 CheckpointRetainedNum *int64 `json:"CheckpointRetainedNum,omitnil,omitempty" name:"CheckpointRetainedNum"` // 算子拓扑图 JobGraph *JobGraph `json:"JobGraph,omitnil,omitempty" name:"JobGraph"` // es索引名称 EsServerlessIndex *string `json:"EsServerlessIndex,omitnil,omitempty" name:"EsServerlessIndex"` // es索引空间 EsServerlessSpace *string `json:"EsServerlessSpace,omitnil,omitempty" name:"EsServerlessSpace"` }
func NewCreateJobConfigRequest ¶
func NewCreateJobConfigRequest() (request *CreateJobConfigRequest)
func (*CreateJobConfigRequest) FromJsonString ¶
func (r *CreateJobConfigRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateJobConfigRequest) ToJsonString ¶
func (r *CreateJobConfigRequest) ToJsonString() string
type CreateJobConfigRequestParams ¶ added in v1.0.426
type CreateJobConfigRequestParams struct { // 作业Id JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 主类 EntrypointClass *string `json:"EntrypointClass,omitnil,omitempty" name:"EntrypointClass"` // 主类入参 ProgramArgs *string `json:"ProgramArgs,omitnil,omitempty" name:"ProgramArgs"` // 备注 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 资源引用数组 ResourceRefs []*ResourceRef `json:"ResourceRefs,omitnil,omitempty" name:"ResourceRefs"` // 作业默认并行度 DefaultParallelism *uint64 `json:"DefaultParallelism,omitnil,omitempty" name:"DefaultParallelism"` // 系统参数 Properties []*Property `json:"Properties,omitnil,omitempty" name:"Properties"` // 1: 作业配置达到上限之后,自动删除可删除的最早版本 AutoDelete *int64 `json:"AutoDelete,omitnil,omitempty" name:"AutoDelete"` // 作业使用的 COS 存储桶名 COSBucket *string `json:"COSBucket,omitnil,omitempty" name:"COSBucket"` // 是否采集作业日志 LogCollect *bool `json:"LogCollect,omitnil,omitempty" name:"LogCollect"` // JobManager规格 JobManagerSpec *float64 `json:"JobManagerSpec,omitnil,omitempty" name:"JobManagerSpec"` // TaskManager规格 TaskManagerSpec *float64 `json:"TaskManagerSpec,omitnil,omitempty" name:"TaskManagerSpec"` // CLS日志集ID ClsLogsetId *string `json:"ClsLogsetId,omitnil,omitempty" name:"ClsLogsetId"` // CLS日志主题ID ClsTopicId *string `json:"ClsTopicId,omitnil,omitempty" name:"ClsTopicId"` // 日志采集类型 2:CLS;3:COS LogCollectType *int64 `json:"LogCollectType,omitnil,omitempty" name:"LogCollectType"` // pyflink作业运行时使用的python版本 PythonVersion *string `json:"PythonVersion,omitnil,omitempty" name:"PythonVersion"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 日志级别 LogLevel *string `json:"LogLevel,omitnil,omitempty" name:"LogLevel"` // Oceanus 平台恢复作业开关 1:开启 -1: 关闭 AutoRecover *int64 `json:"AutoRecover,omitnil,omitempty" name:"AutoRecover"` // 类日志级别 ClazzLevels []*ClazzLevel `json:"ClazzLevels,omitnil,omitempty" name:"ClazzLevels"` // 是否打开专家模式 ExpertModeOn *bool `json:"ExpertModeOn,omitnil,omitempty" name:"ExpertModeOn"` // 专家模式的配置 ExpertModeConfiguration *ExpertModeConfiguration `json:"ExpertModeConfiguration,omitnil,omitempty" name:"ExpertModeConfiguration"` // trace链路 TraceModeOn *bool `json:"TraceModeOn,omitnil,omitempty" name:"TraceModeOn"` // trace链路配置 TraceModeConfiguration *TraceModeConfiguration `json:"TraceModeConfiguration,omitnil,omitempty" name:"TraceModeConfiguration"` // checkpoint保留个数 CheckpointRetainedNum *int64 `json:"CheckpointRetainedNum,omitnil,omitempty" name:"CheckpointRetainedNum"` // 算子拓扑图 JobGraph *JobGraph `json:"JobGraph,omitnil,omitempty" name:"JobGraph"` // es索引名称 EsServerlessIndex *string `json:"EsServerlessIndex,omitnil,omitempty" name:"EsServerlessIndex"` // es索引空间 EsServerlessSpace *string `json:"EsServerlessSpace,omitnil,omitempty" name:"EsServerlessSpace"` }
Predefined struct for user
type CreateJobConfigResponse ¶
type CreateJobConfigResponse struct { *tchttp.BaseResponse Response *CreateJobConfigResponseParams `json:"Response"` }
func NewCreateJobConfigResponse ¶
func NewCreateJobConfigResponse() (response *CreateJobConfigResponse)
func (*CreateJobConfigResponse) FromJsonString ¶
func (r *CreateJobConfigResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateJobConfigResponse) ToJsonString ¶
func (r *CreateJobConfigResponse) ToJsonString() string
type CreateJobConfigResponseParams ¶ added in v1.0.426
type CreateJobConfigResponseParams struct { // 作业配置版本号 Version *uint64 `json:"Version,omitnil,omitempty" name:"Version"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type CreateJobRequest ¶
type CreateJobRequest struct { *tchttp.BaseRequest // 作业名称,允许输入长度小于50个字符的中文、英文、数字、-(横线)、_(下划线)、.(点),且符号必须半角字符。注意作业名不能和现有作业同名 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 作业的类型,1 表示 SQL 作业,2 表示 JAR 作业 JobType *int64 `json:"JobType,omitnil,omitempty" name:"JobType"` // 集群的类型,1 表示共享集群,2 表示独享集群 ClusterType *int64 `json:"ClusterType,omitnil,omitempty" name:"ClusterType"` // 当 ClusterType=2 时,必选,用来指定该作业提交的独享集群 ID ClusterId *string `json:"ClusterId,omitnil,omitempty" name:"ClusterId"` // 设置每 CU 的内存规格,单位为 GB,支持 2、4、8、16(需申请开通白名单后使用)。默认为 4,即 1 CU 对应 4 GB 的运行内存 CuMem *uint64 `json:"CuMem,omitnil,omitempty" name:"CuMem"` // 作业的备注信息,可以随意设置 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 作业名所属文件夹ID,根目录为"root" FolderId *string `json:"FolderId,omitnil,omitempty" name:"FolderId"` // 作业运行的Flink版本 FlinkVersion *string `json:"FlinkVersion,omitnil,omitempty" name:"FlinkVersion"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 作业标签 Tags []*Tag `json:"Tags,omitnil,omitempty" name:"Tags"` // 作业描述 Description *string `json:"Description,omitnil,omitempty" name:"Description"` }
func NewCreateJobRequest ¶
func NewCreateJobRequest() (request *CreateJobRequest)
func (*CreateJobRequest) FromJsonString ¶
func (r *CreateJobRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateJobRequest) ToJsonString ¶
func (r *CreateJobRequest) ToJsonString() string
type CreateJobRequestParams ¶ added in v1.0.426
type CreateJobRequestParams struct { // 作业名称,允许输入长度小于50个字符的中文、英文、数字、-(横线)、_(下划线)、.(点),且符号必须半角字符。注意作业名不能和现有作业同名 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 作业的类型,1 表示 SQL 作业,2 表示 JAR 作业 JobType *int64 `json:"JobType,omitnil,omitempty" name:"JobType"` // 集群的类型,1 表示共享集群,2 表示独享集群 ClusterType *int64 `json:"ClusterType,omitnil,omitempty" name:"ClusterType"` // 当 ClusterType=2 时,必选,用来指定该作业提交的独享集群 ID ClusterId *string `json:"ClusterId,omitnil,omitempty" name:"ClusterId"` // 设置每 CU 的内存规格,单位为 GB,支持 2、4、8、16(需申请开通白名单后使用)。默认为 4,即 1 CU 对应 4 GB 的运行内存 CuMem *uint64 `json:"CuMem,omitnil,omitempty" name:"CuMem"` // 作业的备注信息,可以随意设置 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 作业名所属文件夹ID,根目录为"root" FolderId *string `json:"FolderId,omitnil,omitempty" name:"FolderId"` // 作业运行的Flink版本 FlinkVersion *string `json:"FlinkVersion,omitnil,omitempty" name:"FlinkVersion"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 作业标签 Tags []*Tag `json:"Tags,omitnil,omitempty" name:"Tags"` // 作业描述 Description *string `json:"Description,omitnil,omitempty" name:"Description"` }
Predefined struct for user
type CreateJobResponse ¶
type CreateJobResponse struct { *tchttp.BaseResponse Response *CreateJobResponseParams `json:"Response"` }
func NewCreateJobResponse ¶
func NewCreateJobResponse() (response *CreateJobResponse)
func (*CreateJobResponse) FromJsonString ¶
func (r *CreateJobResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateJobResponse) ToJsonString ¶
func (r *CreateJobResponse) ToJsonString() string
type CreateJobResponseParams ¶ added in v1.0.426
type CreateJobResponseParams struct { // 作业Id JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type CreateResourceConfigRequest ¶
type CreateResourceConfigRequest struct { *tchttp.BaseRequest // 资源ID ResourceId *string `json:"ResourceId,omitnil,omitempty" name:"ResourceId"` // 位置信息 ResourceLoc *ResourceLoc `json:"ResourceLoc,omitnil,omitempty" name:"ResourceLoc"` // 资源描述信息 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 1: 资源版本达到上限,自动删除最早可删除的版本 AutoDelete *int64 `json:"AutoDelete,omitnil,omitempty" name:"AutoDelete"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewCreateResourceConfigRequest ¶
func NewCreateResourceConfigRequest() (request *CreateResourceConfigRequest)
func (*CreateResourceConfigRequest) FromJsonString ¶
func (r *CreateResourceConfigRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateResourceConfigRequest) ToJsonString ¶
func (r *CreateResourceConfigRequest) ToJsonString() string
type CreateResourceConfigRequestParams ¶ added in v1.0.426
type CreateResourceConfigRequestParams struct { // 资源ID ResourceId *string `json:"ResourceId,omitnil,omitempty" name:"ResourceId"` // 位置信息 ResourceLoc *ResourceLoc `json:"ResourceLoc,omitnil,omitempty" name:"ResourceLoc"` // 资源描述信息 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 1: 资源版本达到上限,自动删除最早可删除的版本 AutoDelete *int64 `json:"AutoDelete,omitnil,omitempty" name:"AutoDelete"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type CreateResourceConfigResponse ¶
type CreateResourceConfigResponse struct { *tchttp.BaseResponse Response *CreateResourceConfigResponseParams `json:"Response"` }
func NewCreateResourceConfigResponse ¶
func NewCreateResourceConfigResponse() (response *CreateResourceConfigResponse)
func (*CreateResourceConfigResponse) FromJsonString ¶
func (r *CreateResourceConfigResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateResourceConfigResponse) ToJsonString ¶
func (r *CreateResourceConfigResponse) ToJsonString() string
type CreateResourceConfigResponseParams ¶ added in v1.0.426
type CreateResourceConfigResponseParams struct { // 资源版本ID Version *int64 `json:"Version,omitnil,omitempty" name:"Version"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type CreateResourceRequest ¶
type CreateResourceRequest struct { *tchttp.BaseRequest // 资源位置 ResourceLoc *ResourceLoc `json:"ResourceLoc,omitnil,omitempty" name:"ResourceLoc"` // 资源类型。目前只支持 JAR,取值为 1 ResourceType *int64 `json:"ResourceType,omitnil,omitempty" name:"ResourceType"` // 资源描述 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 资源名称 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 资源版本描述 ResourceConfigRemark *string `json:"ResourceConfigRemark,omitnil,omitempty" name:"ResourceConfigRemark"` // 目录ID FolderId *string `json:"FolderId,omitnil,omitempty" name:"FolderId"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewCreateResourceRequest ¶
func NewCreateResourceRequest() (request *CreateResourceRequest)
func (*CreateResourceRequest) FromJsonString ¶
func (r *CreateResourceRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateResourceRequest) ToJsonString ¶
func (r *CreateResourceRequest) ToJsonString() string
type CreateResourceRequestParams ¶ added in v1.0.426
type CreateResourceRequestParams struct { // 资源位置 ResourceLoc *ResourceLoc `json:"ResourceLoc,omitnil,omitempty" name:"ResourceLoc"` // 资源类型。目前只支持 JAR,取值为 1 ResourceType *int64 `json:"ResourceType,omitnil,omitempty" name:"ResourceType"` // 资源描述 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 资源名称 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 资源版本描述 ResourceConfigRemark *string `json:"ResourceConfigRemark,omitnil,omitempty" name:"ResourceConfigRemark"` // 目录ID FolderId *string `json:"FolderId,omitnil,omitempty" name:"FolderId"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type CreateResourceResponse ¶
type CreateResourceResponse struct { *tchttp.BaseResponse Response *CreateResourceResponseParams `json:"Response"` }
func NewCreateResourceResponse ¶
func NewCreateResourceResponse() (response *CreateResourceResponse)
func (*CreateResourceResponse) FromJsonString ¶
func (r *CreateResourceResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateResourceResponse) ToJsonString ¶
func (r *CreateResourceResponse) ToJsonString() string
type CreateResourceResponseParams ¶ added in v1.0.426
type CreateResourceResponseParams struct { // 资源ID ResourceId *string `json:"ResourceId,omitnil,omitempty" name:"ResourceId"` // 资源版本 Version *int64 `json:"Version,omitnil,omitempty" name:"Version"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type CreateWorkSpaceRequest ¶ added in v1.0.769
type CreateWorkSpaceRequest struct { *tchttp.BaseRequest // 工作空间名称 WorkSpaceName *string `json:"WorkSpaceName,omitnil,omitempty" name:"WorkSpaceName"` // 项目空间备注 Description *string `json:"Description,omitnil,omitempty" name:"Description"` }
func NewCreateWorkSpaceRequest ¶ added in v1.0.769
func NewCreateWorkSpaceRequest() (request *CreateWorkSpaceRequest)
func (*CreateWorkSpaceRequest) FromJsonString ¶ added in v1.0.769
func (r *CreateWorkSpaceRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateWorkSpaceRequest) ToJsonString ¶ added in v1.0.769
func (r *CreateWorkSpaceRequest) ToJsonString() string
type CreateWorkSpaceRequestParams ¶ added in v1.0.769
type CreateWorkSpaceRequestParams struct { // 工作空间名称 WorkSpaceName *string `json:"WorkSpaceName,omitnil,omitempty" name:"WorkSpaceName"` // 项目空间备注 Description *string `json:"Description,omitnil,omitempty" name:"Description"` }
Predefined struct for user
type CreateWorkSpaceResponse ¶ added in v1.0.769
type CreateWorkSpaceResponse struct { *tchttp.BaseResponse Response *CreateWorkSpaceResponseParams `json:"Response"` }
func NewCreateWorkSpaceResponse ¶ added in v1.0.769
func NewCreateWorkSpaceResponse() (response *CreateWorkSpaceResponse)
func (*CreateWorkSpaceResponse) FromJsonString ¶ added in v1.0.769
func (r *CreateWorkSpaceResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*CreateWorkSpaceResponse) ToJsonString ¶ added in v1.0.769
func (r *CreateWorkSpaceResponse) ToJsonString() string
type CreateWorkSpaceResponseParams ¶ added in v1.0.769
type CreateWorkSpaceResponseParams struct { // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DeleteFoldersRequest ¶ added in v1.0.769
type DeleteFoldersRequest struct { *tchttp.BaseRequest // 需删除的文件夹唯一ID FolderIds []*string `json:"FolderIds,omitnil,omitempty" name:"FolderIds"` // 文件夹类型,0是任务文件夹,1是依赖文件夹 FolderType *int64 `json:"FolderType,omitnil,omitempty" name:"FolderType"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewDeleteFoldersRequest ¶ added in v1.0.769
func NewDeleteFoldersRequest() (request *DeleteFoldersRequest)
func (*DeleteFoldersRequest) FromJsonString ¶ added in v1.0.769
func (r *DeleteFoldersRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DeleteFoldersRequest) ToJsonString ¶ added in v1.0.769
func (r *DeleteFoldersRequest) ToJsonString() string
type DeleteFoldersRequestParams ¶ added in v1.0.769
type DeleteFoldersRequestParams struct { // 需删除的文件夹唯一ID FolderIds []*string `json:"FolderIds,omitnil,omitempty" name:"FolderIds"` // 文件夹类型,0是任务文件夹,1是依赖文件夹 FolderType *int64 `json:"FolderType,omitnil,omitempty" name:"FolderType"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type DeleteFoldersResponse ¶ added in v1.0.769
type DeleteFoldersResponse struct { *tchttp.BaseResponse Response *DeleteFoldersResponseParams `json:"Response"` }
func NewDeleteFoldersResponse ¶ added in v1.0.769
func NewDeleteFoldersResponse() (response *DeleteFoldersResponse)
func (*DeleteFoldersResponse) FromJsonString ¶ added in v1.0.769
func (r *DeleteFoldersResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DeleteFoldersResponse) ToJsonString ¶ added in v1.0.769
func (r *DeleteFoldersResponse) ToJsonString() string
type DeleteFoldersResponseParams ¶ added in v1.0.769
type DeleteFoldersResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DeleteJobConfigsRequest ¶ added in v1.0.769
type DeleteJobConfigsRequest struct { *tchttp.BaseRequest // 作业ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 作业配置版本数组 JobConfigVersions []*int64 `json:"JobConfigVersions,omitnil,omitempty" name:"JobConfigVersions"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewDeleteJobConfigsRequest ¶ added in v1.0.769
func NewDeleteJobConfigsRequest() (request *DeleteJobConfigsRequest)
func (*DeleteJobConfigsRequest) FromJsonString ¶ added in v1.0.769
func (r *DeleteJobConfigsRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DeleteJobConfigsRequest) ToJsonString ¶ added in v1.0.769
func (r *DeleteJobConfigsRequest) ToJsonString() string
type DeleteJobConfigsRequestParams ¶ added in v1.0.769
type DeleteJobConfigsRequestParams struct { // 作业ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 作业配置版本数组 JobConfigVersions []*int64 `json:"JobConfigVersions,omitnil,omitempty" name:"JobConfigVersions"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type DeleteJobConfigsResponse ¶ added in v1.0.769
type DeleteJobConfigsResponse struct { *tchttp.BaseResponse Response *DeleteJobConfigsResponseParams `json:"Response"` }
func NewDeleteJobConfigsResponse ¶ added in v1.0.769
func NewDeleteJobConfigsResponse() (response *DeleteJobConfigsResponse)
func (*DeleteJobConfigsResponse) FromJsonString ¶ added in v1.0.769
func (r *DeleteJobConfigsResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DeleteJobConfigsResponse) ToJsonString ¶ added in v1.0.769
func (r *DeleteJobConfigsResponse) ToJsonString() string
type DeleteJobConfigsResponseParams ¶ added in v1.0.769
type DeleteJobConfigsResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DeleteJobsRequest ¶ added in v1.0.441
type DeleteJobsRequest struct { *tchttp.BaseRequest // 作业Id列表 JobIds []*string `json:"JobIds,omitnil,omitempty" name:"JobIds"` // 工作空间Id WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewDeleteJobsRequest ¶ added in v1.0.441
func NewDeleteJobsRequest() (request *DeleteJobsRequest)
func (*DeleteJobsRequest) FromJsonString ¶ added in v1.0.441
func (r *DeleteJobsRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DeleteJobsRequest) ToJsonString ¶ added in v1.0.441
func (r *DeleteJobsRequest) ToJsonString() string
type DeleteJobsRequestParams ¶ added in v1.0.441
type DeleteJobsRequestParams struct { // 作业Id列表 JobIds []*string `json:"JobIds,omitnil,omitempty" name:"JobIds"` // 工作空间Id WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type DeleteJobsResponse ¶ added in v1.0.441
type DeleteJobsResponse struct { *tchttp.BaseResponse Response *DeleteJobsResponseParams `json:"Response"` }
func NewDeleteJobsResponse ¶ added in v1.0.441
func NewDeleteJobsResponse() (response *DeleteJobsResponse)
func (*DeleteJobsResponse) FromJsonString ¶ added in v1.0.441
func (r *DeleteJobsResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DeleteJobsResponse) ToJsonString ¶ added in v1.0.441
func (r *DeleteJobsResponse) ToJsonString() string
type DeleteJobsResponseParams ¶ added in v1.0.441
type DeleteJobsResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DeleteResourceConfigsRequest ¶
type DeleteResourceConfigsRequest struct { *tchttp.BaseRequest // 资源ID ResourceId *string `json:"ResourceId,omitnil,omitempty" name:"ResourceId"` // 资源版本数组 ResourceConfigVersions []*int64 `json:"ResourceConfigVersions,omitnil,omitempty" name:"ResourceConfigVersions"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewDeleteResourceConfigsRequest ¶
func NewDeleteResourceConfigsRequest() (request *DeleteResourceConfigsRequest)
func (*DeleteResourceConfigsRequest) FromJsonString ¶
func (r *DeleteResourceConfigsRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DeleteResourceConfigsRequest) ToJsonString ¶
func (r *DeleteResourceConfigsRequest) ToJsonString() string
type DeleteResourceConfigsRequestParams ¶ added in v1.0.426
type DeleteResourceConfigsRequestParams struct { // 资源ID ResourceId *string `json:"ResourceId,omitnil,omitempty" name:"ResourceId"` // 资源版本数组 ResourceConfigVersions []*int64 `json:"ResourceConfigVersions,omitnil,omitempty" name:"ResourceConfigVersions"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type DeleteResourceConfigsResponse ¶
type DeleteResourceConfigsResponse struct { *tchttp.BaseResponse Response *DeleteResourceConfigsResponseParams `json:"Response"` }
func NewDeleteResourceConfigsResponse ¶
func NewDeleteResourceConfigsResponse() (response *DeleteResourceConfigsResponse)
func (*DeleteResourceConfigsResponse) FromJsonString ¶
func (r *DeleteResourceConfigsResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DeleteResourceConfigsResponse) ToJsonString ¶
func (r *DeleteResourceConfigsResponse) ToJsonString() string
type DeleteResourceConfigsResponseParams ¶ added in v1.0.426
type DeleteResourceConfigsResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DeleteResourcesRequest ¶
type DeleteResourcesRequest struct { *tchttp.BaseRequest // 待删除资源ID列表 ResourceIds []*string `json:"ResourceIds,omitnil,omitempty" name:"ResourceIds"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewDeleteResourcesRequest ¶
func NewDeleteResourcesRequest() (request *DeleteResourcesRequest)
func (*DeleteResourcesRequest) FromJsonString ¶
func (r *DeleteResourcesRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DeleteResourcesRequest) ToJsonString ¶
func (r *DeleteResourcesRequest) ToJsonString() string
type DeleteResourcesRequestParams ¶ added in v1.0.426
type DeleteResourcesRequestParams struct { // 待删除资源ID列表 ResourceIds []*string `json:"ResourceIds,omitnil,omitempty" name:"ResourceIds"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type DeleteResourcesResponse ¶
type DeleteResourcesResponse struct { *tchttp.BaseResponse Response *DeleteResourcesResponseParams `json:"Response"` }
func NewDeleteResourcesResponse ¶
func NewDeleteResourcesResponse() (response *DeleteResourcesResponse)
func (*DeleteResourcesResponse) FromJsonString ¶
func (r *DeleteResourcesResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DeleteResourcesResponse) ToJsonString ¶
func (r *DeleteResourcesResponse) ToJsonString() string
type DeleteResourcesResponseParams ¶ added in v1.0.426
type DeleteResourcesResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DeleteTableConfigRequest ¶
type DeleteTableConfigRequest struct { *tchttp.BaseRequest // 作业ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 调试作业ID DebugId *int64 `json:"DebugId,omitnil,omitempty" name:"DebugId"` // 表名 TableName *string `json:"TableName,omitnil,omitempty" name:"TableName"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewDeleteTableConfigRequest ¶
func NewDeleteTableConfigRequest() (request *DeleteTableConfigRequest)
func (*DeleteTableConfigRequest) FromJsonString ¶
func (r *DeleteTableConfigRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DeleteTableConfigRequest) ToJsonString ¶
func (r *DeleteTableConfigRequest) ToJsonString() string
type DeleteTableConfigRequestParams ¶ added in v1.0.426
type DeleteTableConfigRequestParams struct { // 作业ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 调试作业ID DebugId *int64 `json:"DebugId,omitnil,omitempty" name:"DebugId"` // 表名 TableName *string `json:"TableName,omitnil,omitempty" name:"TableName"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type DeleteTableConfigResponse ¶
type DeleteTableConfigResponse struct { *tchttp.BaseResponse Response *DeleteTableConfigResponseParams `json:"Response"` }
func NewDeleteTableConfigResponse ¶
func NewDeleteTableConfigResponse() (response *DeleteTableConfigResponse)
func (*DeleteTableConfigResponse) FromJsonString ¶
func (r *DeleteTableConfigResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DeleteTableConfigResponse) ToJsonString ¶
func (r *DeleteTableConfigResponse) ToJsonString() string
type DeleteTableConfigResponseParams ¶ added in v1.0.426
type DeleteTableConfigResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DeleteWorkSpaceRequest ¶ added in v1.0.771
type DeleteWorkSpaceRequest struct { *tchttp.BaseRequest // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewDeleteWorkSpaceRequest ¶ added in v1.0.771
func NewDeleteWorkSpaceRequest() (request *DeleteWorkSpaceRequest)
func (*DeleteWorkSpaceRequest) FromJsonString ¶ added in v1.0.771
func (r *DeleteWorkSpaceRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DeleteWorkSpaceRequest) ToJsonString ¶ added in v1.0.771
func (r *DeleteWorkSpaceRequest) ToJsonString() string
type DeleteWorkSpaceRequestParams ¶ added in v1.0.771
type DeleteWorkSpaceRequestParams struct { // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type DeleteWorkSpaceResponse ¶ added in v1.0.771
type DeleteWorkSpaceResponse struct { *tchttp.BaseResponse Response *DeleteWorkSpaceResponseParams `json:"Response"` }
func NewDeleteWorkSpaceResponse ¶ added in v1.0.771
func NewDeleteWorkSpaceResponse() (response *DeleteWorkSpaceResponse)
func (*DeleteWorkSpaceResponse) FromJsonString ¶ added in v1.0.771
func (r *DeleteWorkSpaceResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DeleteWorkSpaceResponse) ToJsonString ¶ added in v1.0.771
func (r *DeleteWorkSpaceResponse) ToJsonString() string
type DeleteWorkSpaceResponseParams ¶ added in v1.0.771
type DeleteWorkSpaceResponseParams struct { // 是否删除 Delete *bool `json:"Delete,omitnil,omitempty" name:"Delete"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeClustersRequest ¶ added in v1.0.441
type DescribeClustersRequest struct { *tchttp.BaseRequest // 按照一个或者多个集群 ID 查询,每次请求的集群上限为 100 ClusterIds []*string `json:"ClusterIds,omitnil,omitempty" name:"ClusterIds"` // 偏移量,默认 0 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 请求的集群数量,默认 20,最大值 100 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 集群信息结果排序规则,1 按时间降序,2 按照时间升序,3 按照状态排序 OrderType *int64 `json:"OrderType,omitnil,omitempty" name:"OrderType"` // 过滤规则 Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewDescribeClustersRequest ¶ added in v1.0.441
func NewDescribeClustersRequest() (request *DescribeClustersRequest)
func (*DescribeClustersRequest) FromJsonString ¶ added in v1.0.441
func (r *DescribeClustersRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeClustersRequest) ToJsonString ¶ added in v1.0.441
func (r *DescribeClustersRequest) ToJsonString() string
type DescribeClustersRequestParams ¶ added in v1.0.441
type DescribeClustersRequestParams struct { // 按照一个或者多个集群 ID 查询,每次请求的集群上限为 100 ClusterIds []*string `json:"ClusterIds,omitnil,omitempty" name:"ClusterIds"` // 偏移量,默认 0 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 请求的集群数量,默认 20,最大值 100 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 集群信息结果排序规则,1 按时间降序,2 按照时间升序,3 按照状态排序 OrderType *int64 `json:"OrderType,omitnil,omitempty" name:"OrderType"` // 过滤规则 Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type DescribeClustersResponse ¶ added in v1.0.441
type DescribeClustersResponse struct { *tchttp.BaseResponse Response *DescribeClustersResponseParams `json:"Response"` }
func NewDescribeClustersResponse ¶ added in v1.0.441
func NewDescribeClustersResponse() (response *DescribeClustersResponse)
func (*DescribeClustersResponse) FromJsonString ¶ added in v1.0.441
func (r *DescribeClustersResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeClustersResponse) ToJsonString ¶ added in v1.0.441
func (r *DescribeClustersResponse) ToJsonString() string
type DescribeClustersResponseParams ¶ added in v1.0.441
type DescribeClustersResponseParams struct { // 集群总数 TotalCount *int64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"` // 集群列表 ClusterSet []*Cluster `json:"ClusterSet,omitnil,omitempty" name:"ClusterSet"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeFolderRequest ¶ added in v1.0.810
type DescribeFolderRequest struct { *tchttp.BaseRequest // folder id FolderId *string `json:"FolderId,omitnil,omitempty" name:"FolderId"` // workspace id WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 1:资源文件夹 // 其他:作业文件夹 FolderType *int64 `json:"FolderType,omitnil,omitempty" name:"FolderType"` }
func NewDescribeFolderRequest ¶ added in v1.0.810
func NewDescribeFolderRequest() (request *DescribeFolderRequest)
func (*DescribeFolderRequest) FromJsonString ¶ added in v1.0.810
func (r *DescribeFolderRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeFolderRequest) ToJsonString ¶ added in v1.0.810
func (r *DescribeFolderRequest) ToJsonString() string
type DescribeFolderRequestParams ¶ added in v1.0.810
type DescribeFolderRequestParams struct { // folder id FolderId *string `json:"FolderId,omitnil,omitempty" name:"FolderId"` // workspace id WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 1:资源文件夹 // 其他:作业文件夹 FolderType *int64 `json:"FolderType,omitnil,omitempty" name:"FolderType"` }
Predefined struct for user
type DescribeFolderResponse ¶ added in v1.0.810
type DescribeFolderResponse struct { *tchttp.BaseResponse Response *DescribeFolderResponseParams `json:"Response"` }
func NewDescribeFolderResponse ¶ added in v1.0.810
func NewDescribeFolderResponse() (response *DescribeFolderResponse)
func (*DescribeFolderResponse) FromJsonString ¶ added in v1.0.810
func (r *DescribeFolderResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeFolderResponse) ToJsonString ¶ added in v1.0.810
func (r *DescribeFolderResponse) ToJsonString() string
type DescribeFolderResponseParams ¶ added in v1.0.810
type DescribeFolderResponseParams struct { // folder id FolderId *string `json:"FolderId,omitnil,omitempty" name:"FolderId"` // folder name FolderName *string `json:"FolderName,omitnil,omitempty" name:"FolderName"` // 父文件夹id ParentId *string `json:"ParentId,omitnil,omitempty" name:"ParentId"` // 文件夹类型 FolderType *int64 `json:"FolderType,omitnil,omitempty" name:"FolderType"` // workspace id WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 子文件夹信息 // 注意:此字段可能返回 null,表示取不到有效值。 SubFolderInfo []*SubFolderInfo `json:"SubFolderInfo,omitnil,omitempty" name:"SubFolderInfo"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeJobConfigsRequest ¶
type DescribeJobConfigsRequest struct { *tchttp.BaseRequest // 作业Id JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 作业配置版本 JobConfigVersions []*uint64 `json:"JobConfigVersions,omitnil,omitempty" name:"JobConfigVersions"` // 偏移量,默认0 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 分页大小,默认20,最大100 Limit *uint64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 过滤条件 Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"` // true 表示只展示草稿 OnlyDraft *bool `json:"OnlyDraft,omitnil,omitempty" name:"OnlyDraft"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewDescribeJobConfigsRequest ¶
func NewDescribeJobConfigsRequest() (request *DescribeJobConfigsRequest)
func (*DescribeJobConfigsRequest) FromJsonString ¶
func (r *DescribeJobConfigsRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeJobConfigsRequest) ToJsonString ¶
func (r *DescribeJobConfigsRequest) ToJsonString() string
type DescribeJobConfigsRequestParams ¶ added in v1.0.426
type DescribeJobConfigsRequestParams struct { // 作业Id JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 作业配置版本 JobConfigVersions []*uint64 `json:"JobConfigVersions,omitnil,omitempty" name:"JobConfigVersions"` // 偏移量,默认0 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 分页大小,默认20,最大100 Limit *uint64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 过滤条件 Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"` // true 表示只展示草稿 OnlyDraft *bool `json:"OnlyDraft,omitnil,omitempty" name:"OnlyDraft"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type DescribeJobConfigsResponse ¶
type DescribeJobConfigsResponse struct { *tchttp.BaseResponse Response *DescribeJobConfigsResponseParams `json:"Response"` }
func NewDescribeJobConfigsResponse ¶
func NewDescribeJobConfigsResponse() (response *DescribeJobConfigsResponse)
func (*DescribeJobConfigsResponse) FromJsonString ¶
func (r *DescribeJobConfigsResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeJobConfigsResponse) ToJsonString ¶
func (r *DescribeJobConfigsResponse) ToJsonString() string
type DescribeJobConfigsResponseParams ¶ added in v1.0.426
type DescribeJobConfigsResponseParams struct { // 总的配置版本数量 TotalCount *int64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"` // 作业配置列表 JobConfigSet []*JobConfig `json:"JobConfigSet,omitnil,omitempty" name:"JobConfigSet"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeJobEventsRequest ¶ added in v1.0.822
type DescribeJobEventsRequest struct { *tchttp.BaseRequest // 作业的 ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 筛选条件:起始 Unix 时间戳(秒) StartTimestamp *uint64 `json:"StartTimestamp,omitnil,omitempty" name:"StartTimestamp"` // 筛选条件:结束 Unix 时间戳(秒) EndTimestamp *uint64 `json:"EndTimestamp,omitnil,omitempty" name:"EndTimestamp"` // 事件类型。如果不传则返回所有类型的数据 Types []*string `json:"Types,omitnil,omitempty" name:"Types"` // 运行实例 ID 数组 RunningOrderIds []*uint64 `json:"RunningOrderIds,omitnil,omitempty" name:"RunningOrderIds"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewDescribeJobEventsRequest ¶ added in v1.0.822
func NewDescribeJobEventsRequest() (request *DescribeJobEventsRequest)
func (*DescribeJobEventsRequest) FromJsonString ¶ added in v1.0.822
func (r *DescribeJobEventsRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeJobEventsRequest) ToJsonString ¶ added in v1.0.822
func (r *DescribeJobEventsRequest) ToJsonString() string
type DescribeJobEventsRequestParams ¶ added in v1.0.822
type DescribeJobEventsRequestParams struct { // 作业的 ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 筛选条件:起始 Unix 时间戳(秒) StartTimestamp *uint64 `json:"StartTimestamp,omitnil,omitempty" name:"StartTimestamp"` // 筛选条件:结束 Unix 时间戳(秒) EndTimestamp *uint64 `json:"EndTimestamp,omitnil,omitempty" name:"EndTimestamp"` // 事件类型。如果不传则返回所有类型的数据 Types []*string `json:"Types,omitnil,omitempty" name:"Types"` // 运行实例 ID 数组 RunningOrderIds []*uint64 `json:"RunningOrderIds,omitnil,omitempty" name:"RunningOrderIds"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type DescribeJobEventsResponse ¶ added in v1.0.822
type DescribeJobEventsResponse struct { *tchttp.BaseResponse Response *DescribeJobEventsResponseParams `json:"Response"` }
func NewDescribeJobEventsResponse ¶ added in v1.0.822
func NewDescribeJobEventsResponse() (response *DescribeJobEventsResponse)
func (*DescribeJobEventsResponse) FromJsonString ¶ added in v1.0.822
func (r *DescribeJobEventsResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeJobEventsResponse) ToJsonString ¶ added in v1.0.822
func (r *DescribeJobEventsResponse) ToJsonString() string
type DescribeJobEventsResponseParams ¶ added in v1.0.822
type DescribeJobEventsResponseParams struct { // 该作业指定范围内的事件列表 // 注意:此字段可能返回 null,表示取不到有效值。 Events []*JobEvent `json:"Events,omitnil,omitempty" name:"Events"` // 该作业指定范围内运行实例 ID 数组,仅当入参没有传入 RunningOrderIds 参数时才会返回。倒序输出 // 注意:此字段可能返回 null,表示取不到有效值。 RunningOrderIds []*uint64 `json:"RunningOrderIds,omitnil,omitempty" name:"RunningOrderIds"` // 事件的总数 // 注意:此字段可能返回 null,表示取不到有效值。 TotalCount *uint64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeJobSavepointRequest ¶ added in v1.0.404
type DescribeJobSavepointRequest struct { *tchttp.BaseRequest // 作业 SerialId JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 分页参数,单页总数 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 分页参数,偏移量 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 2 是checkpoint // 1 是触发savepoint // 3 停止触发的savepoint RecordTypes []*int64 `json:"RecordTypes,omitnil,omitempty" name:"RecordTypes"` }
func NewDescribeJobSavepointRequest ¶ added in v1.0.404
func NewDescribeJobSavepointRequest() (request *DescribeJobSavepointRequest)
func (*DescribeJobSavepointRequest) FromJsonString ¶ added in v1.0.404
func (r *DescribeJobSavepointRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeJobSavepointRequest) ToJsonString ¶ added in v1.0.404
func (r *DescribeJobSavepointRequest) ToJsonString() string
type DescribeJobSavepointRequestParams ¶ added in v1.0.426
type DescribeJobSavepointRequestParams struct { // 作业 SerialId JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 分页参数,单页总数 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 分页参数,偏移量 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 2 是checkpoint // 1 是触发savepoint // 3 停止触发的savepoint RecordTypes []*int64 `json:"RecordTypes,omitnil,omitempty" name:"RecordTypes"` }
Predefined struct for user
type DescribeJobSavepointResponse ¶ added in v1.0.404
type DescribeJobSavepointResponse struct { *tchttp.BaseResponse Response *DescribeJobSavepointResponseParams `json:"Response"` }
func NewDescribeJobSavepointResponse ¶ added in v1.0.404
func NewDescribeJobSavepointResponse() (response *DescribeJobSavepointResponse)
func (*DescribeJobSavepointResponse) FromJsonString ¶ added in v1.0.404
func (r *DescribeJobSavepointResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeJobSavepointResponse) ToJsonString ¶ added in v1.0.404
func (r *DescribeJobSavepointResponse) ToJsonString() string
type DescribeJobSavepointResponseParams ¶ added in v1.0.426
type DescribeJobSavepointResponseParams struct { // 快照列表总数 // 注意:此字段可能返回 null,表示取不到有效值。 TotalNumber *int64 `json:"TotalNumber,omitnil,omitempty" name:"TotalNumber"` // 快照列表 // 注意:此字段可能返回 null,表示取不到有效值。 Savepoint []*Savepoint `json:"Savepoint,omitnil,omitempty" name:"Savepoint"` // 进行中的快照列表 // 注意:此字段可能返回 null,表示取不到有效值。 RunningSavepoint []*Savepoint `json:"RunningSavepoint,omitnil,omitempty" name:"RunningSavepoint"` // 进行中的快照列表总数 // 注意:此字段可能返回 null,表示取不到有效值。 RunningTotalNumber *int64 `json:"RunningTotalNumber,omitnil,omitempty" name:"RunningTotalNumber"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeJobSubmissionLogRequest ¶ added in v1.0.702
type DescribeJobSubmissionLogRequest struct { *tchttp.BaseRequest // 作业ID,例如:cql-6v1jkxrn JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 起始时间,unix时间戳,毫秒级,例如:1611754219108 StartTime *int64 `json:"StartTime,omitnil,omitempty" name:"StartTime"` // 结束时间,unix时间戳,毫秒级,例如:1611754219108 EndTime *int64 `json:"EndTime,omitnil,omitempty" name:"EndTime"` // 作业运行的实例ID, 例如:1,2,3。默认为0,表示未选中任何实例,搜索该时间段内最近的一个实例的日志 RunningOrderId *int64 `json:"RunningOrderId,omitnil,omitempty" name:"RunningOrderId"` // 日志搜索的关键词,默认为空 Keyword *string `json:"Keyword,omitnil,omitempty" name:"Keyword"` // 日志搜索的游标,可透传上次返回的值,默认为空 Cursor *string `json:"Cursor,omitnil,omitempty" name:"Cursor"` // 时间戳排序规则,asc - 升序,desc - 降序。默认为升序 OrderType *string `json:"OrderType,omitnil,omitempty" name:"OrderType"` // 搜索的日志条数上限值,最大为100 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` }
func NewDescribeJobSubmissionLogRequest ¶ added in v1.0.702
func NewDescribeJobSubmissionLogRequest() (request *DescribeJobSubmissionLogRequest)
func (*DescribeJobSubmissionLogRequest) FromJsonString ¶ added in v1.0.702
func (r *DescribeJobSubmissionLogRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeJobSubmissionLogRequest) ToJsonString ¶ added in v1.0.702
func (r *DescribeJobSubmissionLogRequest) ToJsonString() string
type DescribeJobSubmissionLogRequestParams ¶ added in v1.0.702
type DescribeJobSubmissionLogRequestParams struct { // 作业ID,例如:cql-6v1jkxrn JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 起始时间,unix时间戳,毫秒级,例如:1611754219108 StartTime *int64 `json:"StartTime,omitnil,omitempty" name:"StartTime"` // 结束时间,unix时间戳,毫秒级,例如:1611754219108 EndTime *int64 `json:"EndTime,omitnil,omitempty" name:"EndTime"` // 作业运行的实例ID, 例如:1,2,3。默认为0,表示未选中任何实例,搜索该时间段内最近的一个实例的日志 RunningOrderId *int64 `json:"RunningOrderId,omitnil,omitempty" name:"RunningOrderId"` // 日志搜索的关键词,默认为空 Keyword *string `json:"Keyword,omitnil,omitempty" name:"Keyword"` // 日志搜索的游标,可透传上次返回的值,默认为空 Cursor *string `json:"Cursor,omitnil,omitempty" name:"Cursor"` // 时间戳排序规则,asc - 升序,desc - 降序。默认为升序 OrderType *string `json:"OrderType,omitnil,omitempty" name:"OrderType"` // 搜索的日志条数上限值,最大为100 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` }
Predefined struct for user
type DescribeJobSubmissionLogResponse ¶ added in v1.0.702
type DescribeJobSubmissionLogResponse struct { *tchttp.BaseResponse Response *DescribeJobSubmissionLogResponseParams `json:"Response"` }
func NewDescribeJobSubmissionLogResponse ¶ added in v1.0.702
func NewDescribeJobSubmissionLogResponse() (response *DescribeJobSubmissionLogResponse)
func (*DescribeJobSubmissionLogResponse) FromJsonString ¶ added in v1.0.702
func (r *DescribeJobSubmissionLogResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeJobSubmissionLogResponse) ToJsonString ¶ added in v1.0.702
func (r *DescribeJobSubmissionLogResponse) ToJsonString() string
type DescribeJobSubmissionLogResponseParams ¶ added in v1.0.702
type DescribeJobSubmissionLogResponseParams struct { // 日志搜索的游标,需要搜索更多时透传这个值 Cursor *string `json:"Cursor,omitnil,omitempty" name:"Cursor"` // 是否返回了所有的日志记录 ListOver *bool `json:"ListOver,omitnil,omitempty" name:"ListOver"` // 作业启动的requestId // 注意:此字段可能返回 null,表示取不到有效值。 JobRequestId *string `json:"JobRequestId,omitnil,omitempty" name:"JobRequestId"` // 该时间段内符合关键字的所有的作业实例列表 // 注意:此字段可能返回 null,表示取不到有效值。 JobInstanceList []*JobInstanceForSubmissionLog `json:"JobInstanceList,omitnil,omitempty" name:"JobInstanceList"` // 废弃,请使用LogContentList // 注意:此字段可能返回 null,表示取不到有效值。 LogList []*string `json:"LogList,omitnil,omitempty" name:"LogList"` // 日志列表 // 注意:此字段可能返回 null,表示取不到有效值。 LogContentList []*LogContent `json:"LogContentList,omitnil,omitempty" name:"LogContentList"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeJobsRequest ¶
type DescribeJobsRequest struct { *tchttp.BaseRequest // 按照一个或者多个作业ID查询。作业ID形如:cql-11112222,每次请求的作业上限为100。参数不支持同时指定JobIds和Filters。 JobIds []*string `json:"JobIds,omitnil,omitempty" name:"JobIds"` // 过滤条件,支持的 Filter.Name 为:作业名 Name、作业状态 Status、所属集群 ClusterId、作业id JobId、集群名称 ClusterName。 每次请求的 Filters 个数的上限为 5,Filter.Values 的个数上限为 5。参数不支持同时指定 JobIds 和 Filters。 Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"` // 偏移量,默认为0 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 分页大小,默认为20,最大值为100 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 查询额外的作业信息,例如 JobEventInfo ExtraResult []*string `json:"ExtraResult,omitnil,omitempty" name:"ExtraResult"` }
func NewDescribeJobsRequest ¶
func NewDescribeJobsRequest() (request *DescribeJobsRequest)
func (*DescribeJobsRequest) FromJsonString ¶
func (r *DescribeJobsRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeJobsRequest) ToJsonString ¶
func (r *DescribeJobsRequest) ToJsonString() string
type DescribeJobsRequestParams ¶ added in v1.0.426
type DescribeJobsRequestParams struct { // 按照一个或者多个作业ID查询。作业ID形如:cql-11112222,每次请求的作业上限为100。参数不支持同时指定JobIds和Filters。 JobIds []*string `json:"JobIds,omitnil,omitempty" name:"JobIds"` // 过滤条件,支持的 Filter.Name 为:作业名 Name、作业状态 Status、所属集群 ClusterId、作业id JobId、集群名称 ClusterName。 每次请求的 Filters 个数的上限为 5,Filter.Values 的个数上限为 5。参数不支持同时指定 JobIds 和 Filters。 Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"` // 偏移量,默认为0 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 分页大小,默认为20,最大值为100 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 查询额外的作业信息,例如 JobEventInfo ExtraResult []*string `json:"ExtraResult,omitnil,omitempty" name:"ExtraResult"` }
Predefined struct for user
type DescribeJobsResponse ¶
type DescribeJobsResponse struct { *tchttp.BaseResponse Response *DescribeJobsResponseParams `json:"Response"` }
func NewDescribeJobsResponse ¶
func NewDescribeJobsResponse() (response *DescribeJobsResponse)
func (*DescribeJobsResponse) FromJsonString ¶
func (r *DescribeJobsResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeJobsResponse) ToJsonString ¶
func (r *DescribeJobsResponse) ToJsonString() string
type DescribeJobsResponseParams ¶ added in v1.0.426
type DescribeJobsResponseParams struct { // 作业总数 TotalCount *int64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"` // 作业列表 JobSet []*JobV1 `json:"JobSet,omitnil,omitempty" name:"JobSet"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeResourceConfigsRequest ¶
type DescribeResourceConfigsRequest struct { *tchttp.BaseRequest // 资源ID ResourceId *string `json:"ResourceId,omitnil,omitempty" name:"ResourceId"` // 偏移量,仅当设置 Limit 时该参数有效 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 返回值大小,不填则返回全量数据 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 资源配置Versions集合 ResourceConfigVersions []*int64 `json:"ResourceConfigVersions,omitnil,omitempty" name:"ResourceConfigVersions"` // 作业配置版本 JobConfigVersion *int64 `json:"JobConfigVersion,omitnil,omitempty" name:"JobConfigVersion"` // 作业ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewDescribeResourceConfigsRequest ¶
func NewDescribeResourceConfigsRequest() (request *DescribeResourceConfigsRequest)
func (*DescribeResourceConfigsRequest) FromJsonString ¶
func (r *DescribeResourceConfigsRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeResourceConfigsRequest) ToJsonString ¶
func (r *DescribeResourceConfigsRequest) ToJsonString() string
type DescribeResourceConfigsRequestParams ¶ added in v1.0.426
type DescribeResourceConfigsRequestParams struct { // 资源ID ResourceId *string `json:"ResourceId,omitnil,omitempty" name:"ResourceId"` // 偏移量,仅当设置 Limit 时该参数有效 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 返回值大小,不填则返回全量数据 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 资源配置Versions集合 ResourceConfigVersions []*int64 `json:"ResourceConfigVersions,omitnil,omitempty" name:"ResourceConfigVersions"` // 作业配置版本 JobConfigVersion *int64 `json:"JobConfigVersion,omitnil,omitempty" name:"JobConfigVersion"` // 作业ID JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type DescribeResourceConfigsResponse ¶
type DescribeResourceConfigsResponse struct { *tchttp.BaseResponse Response *DescribeResourceConfigsResponseParams `json:"Response"` }
func NewDescribeResourceConfigsResponse ¶
func NewDescribeResourceConfigsResponse() (response *DescribeResourceConfigsResponse)
func (*DescribeResourceConfigsResponse) FromJsonString ¶
func (r *DescribeResourceConfigsResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeResourceConfigsResponse) ToJsonString ¶
func (r *DescribeResourceConfigsResponse) ToJsonString() string
type DescribeResourceConfigsResponseParams ¶ added in v1.0.426
type DescribeResourceConfigsResponseParams struct { // 资源配置描述数组 ResourceConfigSet []*ResourceConfigItem `json:"ResourceConfigSet,omitnil,omitempty" name:"ResourceConfigSet"` // 资源配置数量 TotalCount *int64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeResourceRelatedJobsRequest ¶
type DescribeResourceRelatedJobsRequest struct { *tchttp.BaseRequest // 资源ID ResourceId *string `json:"ResourceId,omitnil,omitempty" name:"ResourceId"` // 默认0; 1: 按照作业版本创建时间降序 DESCByJobConfigCreateTime *int64 `json:"DESCByJobConfigCreateTime,omitnil,omitempty" name:"DESCByJobConfigCreateTime"` // 偏移量,默认为0 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 分页大小,默认为20,最大值为100 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 资源版本号 ResourceConfigVersion *int64 `json:"ResourceConfigVersion,omitnil,omitempty" name:"ResourceConfigVersion"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewDescribeResourceRelatedJobsRequest ¶
func NewDescribeResourceRelatedJobsRequest() (request *DescribeResourceRelatedJobsRequest)
func (*DescribeResourceRelatedJobsRequest) FromJsonString ¶
func (r *DescribeResourceRelatedJobsRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeResourceRelatedJobsRequest) ToJsonString ¶
func (r *DescribeResourceRelatedJobsRequest) ToJsonString() string
type DescribeResourceRelatedJobsRequestParams ¶ added in v1.0.426
type DescribeResourceRelatedJobsRequestParams struct { // 资源ID ResourceId *string `json:"ResourceId,omitnil,omitempty" name:"ResourceId"` // 默认0; 1: 按照作业版本创建时间降序 DESCByJobConfigCreateTime *int64 `json:"DESCByJobConfigCreateTime,omitnil,omitempty" name:"DESCByJobConfigCreateTime"` // 偏移量,默认为0 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 分页大小,默认为20,最大值为100 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 资源版本号 ResourceConfigVersion *int64 `json:"ResourceConfigVersion,omitnil,omitempty" name:"ResourceConfigVersion"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type DescribeResourceRelatedJobsResponse ¶
type DescribeResourceRelatedJobsResponse struct { *tchttp.BaseResponse Response *DescribeResourceRelatedJobsResponseParams `json:"Response"` }
func NewDescribeResourceRelatedJobsResponse ¶
func NewDescribeResourceRelatedJobsResponse() (response *DescribeResourceRelatedJobsResponse)
func (*DescribeResourceRelatedJobsResponse) FromJsonString ¶
func (r *DescribeResourceRelatedJobsResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeResourceRelatedJobsResponse) ToJsonString ¶
func (r *DescribeResourceRelatedJobsResponse) ToJsonString() string
type DescribeResourceRelatedJobsResponseParams ¶ added in v1.0.426
type DescribeResourceRelatedJobsResponseParams struct { // 总数 TotalCount *int64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"` // 关联作业信息 RefJobInfos []*ResourceRefJobInfo `json:"RefJobInfos,omitnil,omitempty" name:"RefJobInfos"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeResourcesRequest ¶
type DescribeResourcesRequest struct { *tchttp.BaseRequest // 需要查询的资源ID数组,数量不超过100个。如果填写了该参数则忽略Filters参数。 ResourceIds []*string `json:"ResourceIds,omitnil,omitempty" name:"ResourceIds"` // 偏移量,仅当设置 Limit 参数时有效 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 条数限制。如果不填,默认返回 20 条 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // <li><strong>ResourceName</strong></li> // <p style="padding-left: 30px;">按照资源名字过滤,支持模糊过滤。传入的过滤名字不超过5个</p><p style="padding-left: 30px;">类型: String</p><p style="padding-left: 30px;">必选: 否</p> Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewDescribeResourcesRequest ¶
func NewDescribeResourcesRequest() (request *DescribeResourcesRequest)
func (*DescribeResourcesRequest) FromJsonString ¶
func (r *DescribeResourcesRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeResourcesRequest) ToJsonString ¶
func (r *DescribeResourcesRequest) ToJsonString() string
type DescribeResourcesRequestParams ¶ added in v1.0.426
type DescribeResourcesRequestParams struct { // 需要查询的资源ID数组,数量不超过100个。如果填写了该参数则忽略Filters参数。 ResourceIds []*string `json:"ResourceIds,omitnil,omitempty" name:"ResourceIds"` // 偏移量,仅当设置 Limit 参数时有效 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 条数限制。如果不填,默认返回 20 条 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // <li><strong>ResourceName</strong></li> // <p style="padding-left: 30px;">按照资源名字过滤,支持模糊过滤。传入的过滤名字不超过5个</p><p style="padding-left: 30px;">类型: String</p><p style="padding-left: 30px;">必选: 否</p> Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type DescribeResourcesResponse ¶
type DescribeResourcesResponse struct { *tchttp.BaseResponse Response *DescribeResourcesResponseParams `json:"Response"` }
func NewDescribeResourcesResponse ¶
func NewDescribeResourcesResponse() (response *DescribeResourcesResponse)
func (*DescribeResourcesResponse) FromJsonString ¶
func (r *DescribeResourcesResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeResourcesResponse) ToJsonString ¶
func (r *DescribeResourcesResponse) ToJsonString() string
type DescribeResourcesResponseParams ¶ added in v1.0.426
type DescribeResourcesResponseParams struct { // 资源详细信息集合 ResourceSet []*ResourceItem `json:"ResourceSet,omitnil,omitempty" name:"ResourceSet"` // 总数量 TotalCount *int64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeSystemResourcesRequest ¶
type DescribeSystemResourcesRequest struct { *tchttp.BaseRequest // 需要查询的资源ID数组 ResourceIds []*string `json:"ResourceIds,omitnil,omitempty" name:"ResourceIds"` // 偏移量,仅当设置 Limit 参数时有效 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 条数限制,默认返回 20 条 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 查询资源配置列表, 如果不填写,返回该 ResourceIds.N 下所有作业配置列表 Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"` // 集群ID ClusterId *string `json:"ClusterId,omitnil,omitempty" name:"ClusterId"` // 查询对应Flink版本的内置connector FlinkVersion *string `json:"FlinkVersion,omitnil,omitempty" name:"FlinkVersion"` }
func NewDescribeSystemResourcesRequest ¶
func NewDescribeSystemResourcesRequest() (request *DescribeSystemResourcesRequest)
func (*DescribeSystemResourcesRequest) FromJsonString ¶
func (r *DescribeSystemResourcesRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeSystemResourcesRequest) ToJsonString ¶
func (r *DescribeSystemResourcesRequest) ToJsonString() string
type DescribeSystemResourcesRequestParams ¶ added in v1.0.426
type DescribeSystemResourcesRequestParams struct { // 需要查询的资源ID数组 ResourceIds []*string `json:"ResourceIds,omitnil,omitempty" name:"ResourceIds"` // 偏移量,仅当设置 Limit 参数时有效 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 条数限制,默认返回 20 条 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 查询资源配置列表, 如果不填写,返回该 ResourceIds.N 下所有作业配置列表 Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"` // 集群ID ClusterId *string `json:"ClusterId,omitnil,omitempty" name:"ClusterId"` // 查询对应Flink版本的内置connector FlinkVersion *string `json:"FlinkVersion,omitnil,omitempty" name:"FlinkVersion"` }
Predefined struct for user
type DescribeSystemResourcesResponse ¶
type DescribeSystemResourcesResponse struct { *tchttp.BaseResponse Response *DescribeSystemResourcesResponseParams `json:"Response"` }
func NewDescribeSystemResourcesResponse ¶
func NewDescribeSystemResourcesResponse() (response *DescribeSystemResourcesResponse)
func (*DescribeSystemResourcesResponse) FromJsonString ¶
func (r *DescribeSystemResourcesResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeSystemResourcesResponse) ToJsonString ¶
func (r *DescribeSystemResourcesResponse) ToJsonString() string
type DescribeSystemResourcesResponseParams ¶ added in v1.0.426
type DescribeSystemResourcesResponseParams struct { // 资源详细信息集合 ResourceSet []*SystemResourceItem `json:"ResourceSet,omitnil,omitempty" name:"ResourceSet"` // 总数量 TotalCount *int64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeTreeJobsRequest ¶ added in v1.0.441
type DescribeTreeJobsRequest struct { *tchttp.BaseRequest // 筛选条件字段 Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"` // 工作空间 Serialid WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewDescribeTreeJobsRequest ¶ added in v1.0.441
func NewDescribeTreeJobsRequest() (request *DescribeTreeJobsRequest)
func (*DescribeTreeJobsRequest) FromJsonString ¶ added in v1.0.441
func (r *DescribeTreeJobsRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeTreeJobsRequest) ToJsonString ¶ added in v1.0.441
func (r *DescribeTreeJobsRequest) ToJsonString() string
type DescribeTreeJobsRequestParams ¶ added in v1.0.441
type DescribeTreeJobsRequestParams struct { // 筛选条件字段 Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"` // 工作空间 Serialid WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type DescribeTreeJobsResponse ¶ added in v1.0.441
type DescribeTreeJobsResponse struct { *tchttp.BaseResponse Response *DescribeTreeJobsResponseParams `json:"Response"` }
func NewDescribeTreeJobsResponse ¶ added in v1.0.441
func NewDescribeTreeJobsResponse() (response *DescribeTreeJobsResponse)
func (*DescribeTreeJobsResponse) FromJsonString ¶ added in v1.0.441
func (r *DescribeTreeJobsResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeTreeJobsResponse) ToJsonString ¶ added in v1.0.441
func (r *DescribeTreeJobsResponse) ToJsonString() string
type DescribeTreeJobsResponseParams ¶ added in v1.0.441
type DescribeTreeJobsResponseParams struct { // 父节点ID // 注意:此字段可能返回 null,表示取不到有效值。 ParentId *string `json:"ParentId,omitnil,omitempty" name:"ParentId"` // 当前文件夹ID // 注意:此字段可能返回 null,表示取不到有效值。 Id *string `json:"Id,omitnil,omitempty" name:"Id"` // 当前文件夹名 // 注意:此字段可能返回 null,表示取不到有效值。 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 当前文件夹下的作业列表 // 注意:此字段可能返回 null,表示取不到有效值。 JobSet []*TreeJobSets `json:"JobSet,omitnil,omitempty" name:"JobSet"` // 迭代子目录 // 注意:此字段可能返回 null,表示取不到有效值。 Children []*DescribeTreeJobsRsp `json:"Children,omitnil,omitempty" name:"Children"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeTreeJobsRsp ¶ added in v1.0.772
type DescribeTreeJobsRsp struct { // 父节点ID // 注意:此字段可能返回 null,表示取不到有效值。 ParentId *string `json:"ParentId,omitnil,omitempty" name:"ParentId"` // 当前文件夹ID // 注意:此字段可能返回 null,表示取不到有效值。 Id *string `json:"Id,omitnil,omitempty" name:"Id"` // 当前文件夹名 // 注意:此字段可能返回 null,表示取不到有效值。 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 当前文件夹下的作业集合 // 注意:此字段可能返回 null,表示取不到有效值。 JobSet []*TreeJobSets `json:"JobSet,omitnil,omitempty" name:"JobSet"` // 迭代子目录 // 注意:此字段可能返回 null,表示取不到有效值。 Children []*DescribeTreeJobsRsp `json:"Children,omitnil,omitempty" name:"Children"` // 请求ID // 注意:此字段可能返回 null,表示取不到有效值。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
type DescribeTreeResourcesRequest ¶ added in v1.0.482
type DescribeTreeResourcesRequest struct { *tchttp.BaseRequest // 筛选条件字段 Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 分页游标 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 单页显示数 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` }
func NewDescribeTreeResourcesRequest ¶ added in v1.0.482
func NewDescribeTreeResourcesRequest() (request *DescribeTreeResourcesRequest)
func (*DescribeTreeResourcesRequest) FromJsonString ¶ added in v1.0.482
func (r *DescribeTreeResourcesRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeTreeResourcesRequest) ToJsonString ¶ added in v1.0.482
func (r *DescribeTreeResourcesRequest) ToJsonString() string
type DescribeTreeResourcesRequestParams ¶ added in v1.0.482
type DescribeTreeResourcesRequestParams struct { // 筛选条件字段 Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 分页游标 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 单页显示数 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` }
Predefined struct for user
type DescribeTreeResourcesResponse ¶ added in v1.0.482
type DescribeTreeResourcesResponse struct { *tchttp.BaseResponse Response *DescribeTreeResourcesResponseParams `json:"Response"` }
func NewDescribeTreeResourcesResponse ¶ added in v1.0.482
func NewDescribeTreeResourcesResponse() (response *DescribeTreeResourcesResponse)
func (*DescribeTreeResourcesResponse) FromJsonString ¶ added in v1.0.482
func (r *DescribeTreeResourcesResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeTreeResourcesResponse) ToJsonString ¶ added in v1.0.482
func (r *DescribeTreeResourcesResponse) ToJsonString() string
type DescribeTreeResourcesResponseParams ¶ added in v1.0.482
type DescribeTreeResourcesResponseParams struct { // 父节点ID // 注意:此字段可能返回 null,表示取不到有效值。 ParentId *string `json:"ParentId,omitnil,omitempty" name:"ParentId"` // 文件夹ID // 注意:此字段可能返回 null,表示取不到有效值。 Id *string `json:"Id,omitnil,omitempty" name:"Id"` // 文件夹名 // 注意:此字段可能返回 null,表示取不到有效值。 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 文件列表 // 注意:此字段可能返回 null,表示取不到有效值。 Items []*TreeResourceItem `json:"Items,omitnil,omitempty" name:"Items"` // 子目录列表 // 注意:此字段可能返回 null,表示取不到有效值。 Children []*DescribeTreeResourcesRsp `json:"Children,omitnil,omitempty" name:"Children"` // 资源总数 // 注意:此字段可能返回 null,表示取不到有效值。 TotalCount *int64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type DescribeTreeResourcesRsp ¶ added in v1.0.599
type DescribeTreeResourcesRsp struct { // 父节点ID ParentId *string `json:"ParentId,omitnil,omitempty" name:"ParentId"` // 文件夹ID Id *string `json:"Id,omitnil,omitempty" name:"Id"` // 文件夹名称 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 文件夹下资源数字 // 注意:此字段可能返回 null,表示取不到有效值。 Items []*TreeResourceItem `json:"Items,omitnil,omitempty" name:"Items"` // 子节点 // 注意:此字段可能返回 null,表示取不到有效值。 Children []*DescribeTreeResourcesRsp `json:"Children,omitnil,omitempty" name:"Children"` // 资源总数 // 注意:此字段可能返回 null,表示取不到有效值。 TotalCount *int64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"` }
type DescribeWorkSpacesRequest ¶ added in v1.0.683
type DescribeWorkSpacesRequest struct { *tchttp.BaseRequest // 偏移量,默认 0 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 1 按照创建时间降序排序(默认) 2.按照创建时间升序排序,3. 按照状态降序排序 4. 按照状态升序排序 默认为0 OrderType *int64 `json:"OrderType,omitnil,omitempty" name:"OrderType"` // 请求的集群数量,默认 20 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 过滤规则 Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"` }
func NewDescribeWorkSpacesRequest ¶ added in v1.0.683
func NewDescribeWorkSpacesRequest() (request *DescribeWorkSpacesRequest)
func (*DescribeWorkSpacesRequest) FromJsonString ¶ added in v1.0.683
func (r *DescribeWorkSpacesRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeWorkSpacesRequest) ToJsonString ¶ added in v1.0.683
func (r *DescribeWorkSpacesRequest) ToJsonString() string
type DescribeWorkSpacesRequestParams ¶ added in v1.0.683
type DescribeWorkSpacesRequestParams struct { // 偏移量,默认 0 Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"` // 1 按照创建时间降序排序(默认) 2.按照创建时间升序排序,3. 按照状态降序排序 4. 按照状态升序排序 默认为0 OrderType *int64 `json:"OrderType,omitnil,omitempty" name:"OrderType"` // 请求的集群数量,默认 20 Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"` // 过滤规则 Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"` }
Predefined struct for user
type DescribeWorkSpacesResponse ¶ added in v1.0.683
type DescribeWorkSpacesResponse struct { *tchttp.BaseResponse Response *DescribeWorkSpacesResponseParams `json:"Response"` }
func NewDescribeWorkSpacesResponse ¶ added in v1.0.683
func NewDescribeWorkSpacesResponse() (response *DescribeWorkSpacesResponse)
func (*DescribeWorkSpacesResponse) FromJsonString ¶ added in v1.0.683
func (r *DescribeWorkSpacesResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*DescribeWorkSpacesResponse) ToJsonString ¶ added in v1.0.683
func (r *DescribeWorkSpacesResponse) ToJsonString() string
type DescribeWorkSpacesResponseParams ¶ added in v1.0.683
type DescribeWorkSpacesResponseParams struct { // 空间详情列表 // 注意:此字段可能返回 null,表示取不到有效值。 WorkSpaceSetItem []*WorkSpaceSetItem `json:"WorkSpaceSetItem,omitnil,omitempty" name:"WorkSpaceSetItem"` // 空间总数 TotalCount *int64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type ExpertModeConfiguration ¶ added in v1.0.712
type ExpertModeConfiguration struct { // Job graph // 注意:此字段可能返回 null,表示取不到有效值。 JobGraph *JobGraph `json:"JobGraph,omitnil,omitempty" name:"JobGraph"` // Node configuration // 注意:此字段可能返回 null,表示取不到有效值。 NodeConfig []*NodeConfig `json:"NodeConfig,omitnil,omitempty" name:"NodeConfig"` // Slot sharing groups // 注意:此字段可能返回 null,表示取不到有效值。 SlotSharingGroups []*SlotSharingGroup `json:"SlotSharingGroups,omitnil,omitempty" name:"SlotSharingGroups"` }
type FetchSqlGatewayStatementResultRequest ¶ added in v1.0.767
type FetchSqlGatewayStatementResultRequest struct { *tchttp.BaseRequest // 集群ID ClusterId *string `json:"ClusterId,omitnil,omitempty" name:"ClusterId"` // Sql Gateway会话ID SessionId *string `json:"SessionId,omitnil,omitempty" name:"SessionId"` // sql的查询id OperationHandleId *string `json:"OperationHandleId,omitnil,omitempty" name:"OperationHandleId"` // 下一条结果的获取url,首次获取执行结果时可以为空,当获取下一批查询结果时需要传递 ResultUri *string `json:"ResultUri,omitnil,omitempty" name:"ResultUri"` }
func NewFetchSqlGatewayStatementResultRequest ¶ added in v1.0.767
func NewFetchSqlGatewayStatementResultRequest() (request *FetchSqlGatewayStatementResultRequest)
func (*FetchSqlGatewayStatementResultRequest) FromJsonString ¶ added in v1.0.767
func (r *FetchSqlGatewayStatementResultRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*FetchSqlGatewayStatementResultRequest) ToJsonString ¶ added in v1.0.767
func (r *FetchSqlGatewayStatementResultRequest) ToJsonString() string
type FetchSqlGatewayStatementResultRequestParams ¶ added in v1.0.767
type FetchSqlGatewayStatementResultRequestParams struct { // 集群ID ClusterId *string `json:"ClusterId,omitnil,omitempty" name:"ClusterId"` // Sql Gateway会话ID SessionId *string `json:"SessionId,omitnil,omitempty" name:"SessionId"` // sql的查询id OperationHandleId *string `json:"OperationHandleId,omitnil,omitempty" name:"OperationHandleId"` // 下一条结果的获取url,首次获取执行结果时可以为空,当获取下一批查询结果时需要传递 ResultUri *string `json:"ResultUri,omitnil,omitempty" name:"ResultUri"` }
Predefined struct for user
type FetchSqlGatewayStatementResultResponse ¶ added in v1.0.767
type FetchSqlGatewayStatementResultResponse struct { *tchttp.BaseResponse Response *FetchSqlGatewayStatementResultResponseParams `json:"Response"` }
func NewFetchSqlGatewayStatementResultResponse ¶ added in v1.0.767
func NewFetchSqlGatewayStatementResultResponse() (response *FetchSqlGatewayStatementResultResponse)
func (*FetchSqlGatewayStatementResultResponse) FromJsonString ¶ added in v1.0.767
func (r *FetchSqlGatewayStatementResultResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*FetchSqlGatewayStatementResultResponse) ToJsonString ¶ added in v1.0.767
func (r *FetchSqlGatewayStatementResultResponse) ToJsonString() string
type FetchSqlGatewayStatementResultResponseParams ¶ added in v1.0.767
type FetchSqlGatewayStatementResultResponseParams struct { // 错误信息 // 注意:此字段可能返回 null,表示取不到有效值。 ErrorMessage []*string `json:"ErrorMessage,omitnil,omitempty" name:"ErrorMessage"` // 返回类型 // 注意:此字段可能返回 null,表示取不到有效值。 ResultType *string `json:"ResultType,omitnil,omitempty" name:"ResultType"` // 是否DQL结果 // 注意:此字段可能返回 null,表示取不到有效值。 IsQueryResult *bool `json:"IsQueryResult,omitnil,omitempty" name:"IsQueryResult"` // 结果类型 // 注意:此字段可能返回 null,表示取不到有效值。 ResultKind *string `json:"ResultKind,omitnil,omitempty" name:"ResultKind"` // 结果 // 注意:此字段可能返回 null,表示取不到有效值。 Results *StatementResult `json:"Results,omitnil,omitempty" name:"Results"` // 下一次请求的uri // 注意:此字段可能返回 null,表示取不到有效值。 NextResultUri *string `json:"NextResultUri,omitnil,omitempty" name:"NextResultUri"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type GatewayRefItem ¶ added in v1.0.764
type GatewayRefItem struct { // 空间唯一标识 // 注意:此字段可能返回 null,表示取不到有效值。 WorkspaceId *string `json:"WorkspaceId,omitnil,omitempty" name:"WorkspaceId"` // 资源唯一标识 // 注意:此字段可能返回 null,表示取不到有效值。 ResourceId *string `json:"ResourceId,omitnil,omitempty" name:"ResourceId"` // 版本号 // 注意:此字段可能返回 null,表示取不到有效值。 Version *int64 `json:"Version,omitnil,omitempty" name:"Version"` // 引用类型,0:用户资源 // 注意:此字段可能返回 null,表示取不到有效值。 Type *uint64 `json:"Type,omitnil,omitempty" name:"Type"` }
type GetMetaTableRequest ¶ added in v1.0.829
type GetMetaTableRequest struct { *tchttp.BaseRequest // 目录名 Catalog *string `json:"Catalog,omitnil,omitempty" name:"Catalog"` // 库名 Database *string `json:"Database,omitnil,omitempty" name:"Database"` // 表名 Table *string `json:"Table,omitnil,omitempty" name:"Table"` // 空间唯一标识 WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewGetMetaTableRequest ¶ added in v1.0.829
func NewGetMetaTableRequest() (request *GetMetaTableRequest)
func (*GetMetaTableRequest) FromJsonString ¶ added in v1.0.829
func (r *GetMetaTableRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*GetMetaTableRequest) ToJsonString ¶ added in v1.0.829
func (r *GetMetaTableRequest) ToJsonString() string
type GetMetaTableRequestParams ¶ added in v1.0.829
type GetMetaTableRequestParams struct { // 目录名 Catalog *string `json:"Catalog,omitnil,omitempty" name:"Catalog"` // 库名 Database *string `json:"Database,omitnil,omitempty" name:"Database"` // 表名 Table *string `json:"Table,omitnil,omitempty" name:"Table"` // 空间唯一标识 WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type GetMetaTableResponse ¶ added in v1.0.829
type GetMetaTableResponse struct { *tchttp.BaseResponse Response *GetMetaTableResponseParams `json:"Response"` }
func NewGetMetaTableResponse ¶ added in v1.0.829
func NewGetMetaTableResponse() (response *GetMetaTableResponse)
func (*GetMetaTableResponse) FromJsonString ¶ added in v1.0.829
func (r *GetMetaTableResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*GetMetaTableResponse) ToJsonString ¶ added in v1.0.829
func (r *GetMetaTableResponse) ToJsonString() string
type GetMetaTableResponseParams ¶ added in v1.0.829
type GetMetaTableResponseParams struct { // 元数据表唯一标识 SerialId *string `json:"SerialId,omitnil,omitempty" name:"SerialId"` // 目录名 Catalog *string `json:"Catalog,omitnil,omitempty" name:"Catalog"` // 库名 Database *string `json:"Database,omitnil,omitempty" name:"Database"` // 表名 Table *string `json:"Table,omitnil,omitempty" name:"Table"` // 建表语句,使用 Base64 编码。 // 例如 // Q1JFQVRFIFRBQkxFIGRhdGFnZW5fc291cmNlX3RhYmxlICggCiAgICBpZCBJTlQsIAogICAgbmFtZSBTVFJJTkcgCikgV0lUSCAoCidjb25uZWN0b3InPSdkYXRhZ2VuJywKJ3Jvd3MtcGVyLXNlY29uZCcgPSAnMScKKTs= DDL *string `json:"DDL,omitnil,omitempty" name:"DDL"` // 创建时间 CreateTime *string `json:"CreateTime,omitnil,omitempty" name:"CreateTime"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type JobConfig ¶
type JobConfig struct { // 作业Id JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 主类 // 注意:此字段可能返回 null,表示取不到有效值。 EntrypointClass *string `json:"EntrypointClass,omitnil,omitempty" name:"EntrypointClass"` // 主类入参 // 注意:此字段可能返回 null,表示取不到有效值。 ProgramArgs *string `json:"ProgramArgs,omitnil,omitempty" name:"ProgramArgs"` // 备注 // 注意:此字段可能返回 null,表示取不到有效值。 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 作业配置创建时间 CreateTime *string `json:"CreateTime,omitnil,omitempty" name:"CreateTime"` // 作业配置的版本号 Version *int64 `json:"Version,omitnil,omitempty" name:"Version"` // 作业默认并行度 // 注意:此字段可能返回 null,表示取不到有效值。 DefaultParallelism *uint64 `json:"DefaultParallelism,omitnil,omitempty" name:"DefaultParallelism"` // 系统参数 // 注意:此字段可能返回 null,表示取不到有效值。 Properties []*Property `json:"Properties,omitnil,omitempty" name:"Properties"` // 引用资源 // 注意:此字段可能返回 null,表示取不到有效值。 ResourceRefDetails []*ResourceRefDetail `json:"ResourceRefDetails,omitnil,omitempty" name:"ResourceRefDetails"` // 创建者uin // 注意:此字段可能返回 null,表示取不到有效值。 CreatorUin *string `json:"CreatorUin,omitnil,omitempty" name:"CreatorUin"` // 作业配置上次启动时间 // 注意:此字段可能返回 null,表示取不到有效值。 UpdateTime *string `json:"UpdateTime,omitnil,omitempty" name:"UpdateTime"` // 作业绑定的存储桶 // 注意:此字段可能返回 null,表示取不到有效值。 COSBucket *string `json:"COSBucket,omitnil,omitempty" name:"COSBucket"` // 是否启用日志收集,0-未启用,1-已启用,2-历史集群未设置日志集,3-历史集群已开启 // 注意:此字段可能返回 null,表示取不到有效值。 LogCollect *int64 `json:"LogCollect,omitnil,omitempty" name:"LogCollect"` // 作业的最大并行度 // 注意:此字段可能返回 null,表示取不到有效值。 MaxParallelism *uint64 `json:"MaxParallelism,omitnil,omitempty" name:"MaxParallelism"` // JobManager规格 // 注意:此字段可能返回 null,表示取不到有效值。 JobManagerSpec *float64 `json:"JobManagerSpec,omitnil,omitempty" name:"JobManagerSpec"` // TaskManager规格 // 注意:此字段可能返回 null,表示取不到有效值。 TaskManagerSpec *float64 `json:"TaskManagerSpec,omitnil,omitempty" name:"TaskManagerSpec"` // CLS日志集ID // 注意:此字段可能返回 null,表示取不到有效值。 ClsLogsetId *string `json:"ClsLogsetId,omitnil,omitempty" name:"ClsLogsetId"` // CLS日志主题ID // 注意:此字段可能返回 null,表示取不到有效值。 ClsTopicId *string `json:"ClsTopicId,omitnil,omitempty" name:"ClsTopicId"` // pyflink作业运行的python版本 // 注意:此字段可能返回 null,表示取不到有效值。 PythonVersion *string `json:"PythonVersion,omitnil,omitempty" name:"PythonVersion"` // Oceanus 平台恢复作业开关 1:开启 -1: 关闭 // 注意:此字段可能返回 null,表示取不到有效值。 AutoRecover *int64 `json:"AutoRecover,omitnil,omitempty" name:"AutoRecover"` // 日志级别 // 注意:此字段可能返回 null,表示取不到有效值。 LogLevel *string `json:"LogLevel,omitnil,omitempty" name:"LogLevel"` // 类日志级别 // 注意:此字段可能返回 null,表示取不到有效值。 ClazzLevels []*ClazzLevel `json:"ClazzLevels,omitnil,omitempty" name:"ClazzLevels"` // 是否开启专家模式 // 注意:此字段可能返回 null,表示取不到有效值。 ExpertModeOn *bool `json:"ExpertModeOn,omitnil,omitempty" name:"ExpertModeOn"` // 专家模式的配置 // 注意:此字段可能返回 null,表示取不到有效值。 ExpertModeConfiguration *ExpertModeConfiguration `json:"ExpertModeConfiguration,omitnil,omitempty" name:"ExpertModeConfiguration"` // trace链路 // 注意:此字段可能返回 null,表示取不到有效值。 TraceModeOn *bool `json:"TraceModeOn,omitnil,omitempty" name:"TraceModeOn"` // trace链路配置 // 注意:此字段可能返回 null,表示取不到有效值。 TraceModeConfiguration *TraceModeConfiguration `json:"TraceModeConfiguration,omitnil,omitempty" name:"TraceModeConfiguration"` // checkpoint保留个数 // 注意:此字段可能返回 null,表示取不到有效值。 CheckpointRetainedNum *int64 `json:"CheckpointRetainedNum,omitnil,omitempty" name:"CheckpointRetainedNum"` // 算子拓扑图 // 注意:此字段可能返回 null,表示取不到有效值。 JobGraph *JobGraph `json:"JobGraph,omitnil,omitempty" name:"JobGraph"` // es索引 // 注意:此字段可能返回 null,表示取不到有效值。 EsServerlessIndex *string `json:"EsServerlessIndex,omitnil,omitempty" name:"EsServerlessIndex"` // es空间 // 注意:此字段可能返回 null,表示取不到有效值。 EsServerlessSpace *string `json:"EsServerlessSpace,omitnil,omitempty" name:"EsServerlessSpace"` // es索引中文 // 注意:此字段可能返回 null,表示取不到有效值。 IndexName *string `json:"IndexName,omitnil,omitempty" name:"IndexName"` // es空间中文 // 注意:此字段可能返回 null,表示取不到有效值。 WorkspaceName *string `json:"WorkspaceName,omitnil,omitempty" name:"WorkspaceName"` }
type JobEvent ¶ added in v1.0.822
type JobEvent struct { // 内部定义的事件类型 Type *string `json:"Type,omitnil,omitempty" name:"Type"` // 事件类型的说明文字 Description *string `json:"Description,omitnil,omitempty" name:"Description"` // 事件发生的 Unix 时间戳(秒) Timestamp *uint64 `json:"Timestamp,omitnil,omitempty" name:"Timestamp"` // 事件发生时的运行 ID // 注意:此字段可能返回 null,表示取不到有效值。 RunningOrderId *uint64 `json:"RunningOrderId,omitnil,omitempty" name:"RunningOrderId"` // 事件的一些可选说明 // 注意:此字段可能返回 null,表示取不到有效值。 Message *string `json:"Message,omitnil,omitempty" name:"Message"` // 异常事件的排查手册链接 // 注意:此字段可能返回 null,表示取不到有效值。 SolutionLink *string `json:"SolutionLink,omitnil,omitempty" name:"SolutionLink"` }
type JobEventInfo ¶ added in v1.0.830
type JobEventInfo struct { // 异常事件总数 // 注意:此字段可能返回 null,表示取不到有效值。 ErrorEventTotal *int64 `json:"ErrorEventTotal,omitnil,omitempty" name:"ErrorEventTotal"` }
type JobGraph ¶ added in v1.0.712
type JobGraph struct { // 运行图的点集合 // 注意:此字段可能返回 null,表示取不到有效值。 Nodes []*JobGraphNode `json:"Nodes,omitnil,omitempty" name:"Nodes"` // 运行图的边集合 // 注意:此字段可能返回 null,表示取不到有效值。 Edges []*JobGraphEdge `json:"Edges,omitnil,omitempty" name:"Edges"` }
type JobGraphEdge ¶ added in v1.0.712
type JobGraphNode ¶ added in v1.0.712
type JobGraphNode struct { // 节点ID // 注意:此字段可能返回 null,表示取不到有效值。 Id *int64 `json:"Id,omitnil,omitempty" name:"Id"` // 节点描述 // 注意:此字段可能返回 null,表示取不到有效值。 Description *string `json:"Description,omitnil,omitempty" name:"Description"` // 节点名称 // 注意:此字段可能返回 null,表示取不到有效值。 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 节点并行度 // 注意:此字段可能返回 null,表示取不到有效值。 Parallelism *int64 `json:"Parallelism,omitnil,omitempty" name:"Parallelism"` }
type JobInstanceForSubmissionLog ¶ added in v1.0.702
type JobInstanceForSubmissionLog struct { // 实例的Id, 按照启动的时间顺序,从1开始 RunningOrderId *int64 `json:"RunningOrderId,omitnil,omitempty" name:"RunningOrderId"` // 作业实例的启动时间 JobInstanceStartTime *string `json:"JobInstanceStartTime,omitnil,omitempty" name:"JobInstanceStartTime"` // 作业实例启动的时间(毫秒) StartingMillis *int64 `json:"StartingMillis,omitnil,omitempty" name:"StartingMillis"` }
type JobV1 ¶
type JobV1 struct { // 作业ID // 注意:此字段可能返回 null,表示取不到有效值。 JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 地域 // 注意:此字段可能返回 null,表示取不到有效值。 Region *string `json:"Region,omitnil,omitempty" name:"Region"` // 可用区 // 注意:此字段可能返回 null,表示取不到有效值。 Zone *string `json:"Zone,omitnil,omitempty" name:"Zone"` // 用户AppId // 注意:此字段可能返回 null,表示取不到有效值。 AppId *int64 `json:"AppId,omitnil,omitempty" name:"AppId"` // 用户UIN // 注意:此字段可能返回 null,表示取不到有效值。 OwnerUin *string `json:"OwnerUin,omitnil,omitempty" name:"OwnerUin"` // 创建者UIN // 注意:此字段可能返回 null,表示取不到有效值。 CreatorUin *string `json:"CreatorUin,omitnil,omitempty" name:"CreatorUin"` // 作业名字 // 注意:此字段可能返回 null,表示取不到有效值。 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 作业类型,1:sql作业,2:Jar作业 // 注意:此字段可能返回 null,表示取不到有效值。 JobType *int64 `json:"JobType,omitnil,omitempty" name:"JobType"` // 作业状态,1:未初始化,2:未发布,3:操作中,4:运行中,5:停止,6:暂停,-1:故障 // 注意:此字段可能返回 null,表示取不到有效值。 Status *int64 `json:"Status,omitnil,omitempty" name:"Status"` // 作业创建时间 // 注意:此字段可能返回 null,表示取不到有效值。 CreateTime *string `json:"CreateTime,omitnil,omitempty" name:"CreateTime"` // 作业启动时间 // 注意:此字段可能返回 null,表示取不到有效值。 StartTime *string `json:"StartTime,omitnil,omitempty" name:"StartTime"` // 作业停止时间 // 注意:此字段可能返回 null,表示取不到有效值。 StopTime *string `json:"StopTime,omitnil,omitempty" name:"StopTime"` // 作业更新时间 // 注意:此字段可能返回 null,表示取不到有效值。 UpdateTime *string `json:"UpdateTime,omitnil,omitempty" name:"UpdateTime"` // 作业累计运行时间 // 注意:此字段可能返回 null,表示取不到有效值。 TotalRunMillis *int64 `json:"TotalRunMillis,omitnil,omitempty" name:"TotalRunMillis"` // 备注信息 // 注意:此字段可能返回 null,表示取不到有效值。 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 操作错误提示信息 // 注意:此字段可能返回 null,表示取不到有效值。 LastOpResult *string `json:"LastOpResult,omitnil,omitempty" name:"LastOpResult"` // 集群名字 // 注意:此字段可能返回 null,表示取不到有效值。 ClusterName *string `json:"ClusterName,omitnil,omitempty" name:"ClusterName"` // 最新配置版本号 // 注意:此字段可能返回 null,表示取不到有效值。 LatestJobConfigVersion *int64 `json:"LatestJobConfigVersion,omitnil,omitempty" name:"LatestJobConfigVersion"` // 已发布的配置版本 // 注意:此字段可能返回 null,表示取不到有效值。 PublishedJobConfigVersion *int64 `json:"PublishedJobConfigVersion,omitnil,omitempty" name:"PublishedJobConfigVersion"` // 运行的CU数量 // 注意:此字段可能返回 null,表示取不到有效值。 RunningCuNum *int64 `json:"RunningCuNum,omitnil,omitempty" name:"RunningCuNum"` // 作业内存规格 // 注意:此字段可能返回 null,表示取不到有效值。 CuMem *int64 `json:"CuMem,omitnil,omitempty" name:"CuMem"` // 作业状态描述 // 注意:此字段可能返回 null,表示取不到有效值。 StatusDesc *string `json:"StatusDesc,omitnil,omitempty" name:"StatusDesc"` // 运行状态时表示单次运行时间 // 注意:此字段可能返回 null,表示取不到有效值。 CurrentRunMillis *int64 `json:"CurrentRunMillis,omitnil,omitempty" name:"CurrentRunMillis"` // 作业所在的集群ID // 注意:此字段可能返回 null,表示取不到有效值。 ClusterId *string `json:"ClusterId,omitnil,omitempty" name:"ClusterId"` // 作业管理WEB UI 入口 // 注意:此字段可能返回 null,表示取不到有效值。 WebUIUrl *string `json:"WebUIUrl,omitnil,omitempty" name:"WebUIUrl"` // 作业所在集群类型 // 注意:此字段可能返回 null,表示取不到有效值。 SchedulerType *int64 `json:"SchedulerType,omitnil,omitempty" name:"SchedulerType"` // 作业所在集群状态 // 注意:此字段可能返回 null,表示取不到有效值。 ClusterStatus *int64 `json:"ClusterStatus,omitnil,omitempty" name:"ClusterStatus"` // 细粒度下的运行的CU数量 // 注意:此字段可能返回 null,表示取不到有效值。 RunningCu *float64 `json:"RunningCu,omitnil,omitempty" name:"RunningCu"` // 作业运行的 Flink 版本 // 注意:此字段可能返回 null,表示取不到有效值。 FlinkVersion *string `json:"FlinkVersion,omitnil,omitempty" name:"FlinkVersion"` // 工作空间 SerialId // 注意:此字段可能返回 null,表示取不到有效值。 WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 工作空间名称 // 注意:此字段可能返回 null,表示取不到有效值。 WorkSpaceName *string `json:"WorkSpaceName,omitnil,omitempty" name:"WorkSpaceName"` // 作业标签 // 注意:此字段可能返回 null,表示取不到有效值。 Tags []*Tag `json:"Tags,omitnil,omitempty" name:"Tags"` // 作业异常事件信息 // 注意:此字段可能返回 null,表示取不到有效值。 EventInfo *JobEventInfo `json:"EventInfo,omitnil,omitempty" name:"EventInfo"` // 描述信息 // 注意:此字段可能返回 null,表示取不到有效值。 Description *string `json:"Description,omitnil,omitempty" name:"Description"` }
type LogContent ¶ added in v1.0.702
type LogContent struct { // 日志内容 // 注意:此字段可能返回 null,表示取不到有效值。 Log *string `json:"Log,omitnil,omitempty" name:"Log"` // 毫秒级时间戳 // 注意:此字段可能返回 null,表示取不到有效值。 Time *int64 `json:"Time,omitnil,omitempty" name:"Time"` // 日志组Id // 注意:此字段可能返回 null,表示取不到有效值。 PkgId *string `json:"PkgId,omitnil,omitempty" name:"PkgId"` // 日志Id,在日志组范围里唯一 PkgLogId *int64 `json:"PkgLogId,omitnil,omitempty" name:"PkgLogId"` // 日志所属的容器名 // 注意:此字段可能返回 null,表示取不到有效值。 ContainerName *string `json:"ContainerName,omitnil,omitempty" name:"ContainerName"` }
type LogicalType ¶ added in v1.0.768
type LogicalType struct { // 类型 // 注意:此字段可能返回 null,表示取不到有效值。 Type *string `json:"Type,omitnil,omitempty" name:"Type"` // 是否允许为空 // 注意:此字段可能返回 null,表示取不到有效值。 NullAble *bool `json:"NullAble,omitnil,omitempty" name:"NullAble"` // 长度 // 注意:此字段可能返回 null,表示取不到有效值。 Length *int64 `json:"Length,omitnil,omitempty" name:"Length"` }
type ModifyFolderRequest ¶ added in v1.0.769
type ModifyFolderRequest struct { *tchttp.BaseRequest // 文件夹ID(必填) SourceFolderId *string `json:"SourceFolderId,omitnil,omitempty" name:"SourceFolderId"` // 如需拖拽文件夹,需传入目标文件夹ID TargetFolderId *string `json:"TargetFolderId,omitnil,omitempty" name:"TargetFolderId"` // 如需修改文件夹名,需传入FolderName字段 FolderName *string `json:"FolderName,omitnil,omitempty" name:"FolderName"` // 文件夹类型,0是任务文件夹,1是依赖文件夹 FolderType *int64 `json:"FolderType,omitnil,omitempty" name:"FolderType"` // 批量移动的作业serial id 列表 SourceJobIds []*string `json:"SourceJobIds,omitnil,omitempty" name:"SourceJobIds"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewModifyFolderRequest ¶ added in v1.0.769
func NewModifyFolderRequest() (request *ModifyFolderRequest)
func (*ModifyFolderRequest) FromJsonString ¶ added in v1.0.769
func (r *ModifyFolderRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifyFolderRequest) ToJsonString ¶ added in v1.0.769
func (r *ModifyFolderRequest) ToJsonString() string
type ModifyFolderRequestParams ¶ added in v1.0.769
type ModifyFolderRequestParams struct { // 文件夹ID(必填) SourceFolderId *string `json:"SourceFolderId,omitnil,omitempty" name:"SourceFolderId"` // 如需拖拽文件夹,需传入目标文件夹ID TargetFolderId *string `json:"TargetFolderId,omitnil,omitempty" name:"TargetFolderId"` // 如需修改文件夹名,需传入FolderName字段 FolderName *string `json:"FolderName,omitnil,omitempty" name:"FolderName"` // 文件夹类型,0是任务文件夹,1是依赖文件夹 FolderType *int64 `json:"FolderType,omitnil,omitempty" name:"FolderType"` // 批量移动的作业serial id 列表 SourceJobIds []*string `json:"SourceJobIds,omitnil,omitempty" name:"SourceJobIds"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type ModifyFolderResponse ¶ added in v1.0.769
type ModifyFolderResponse struct { *tchttp.BaseResponse Response *ModifyFolderResponseParams `json:"Response"` }
func NewModifyFolderResponse ¶ added in v1.0.769
func NewModifyFolderResponse() (response *ModifyFolderResponse)
func (*ModifyFolderResponse) FromJsonString ¶ added in v1.0.769
func (r *ModifyFolderResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifyFolderResponse) ToJsonString ¶ added in v1.0.769
func (r *ModifyFolderResponse) ToJsonString() string
type ModifyFolderResponseParams ¶ added in v1.0.769
type ModifyFolderResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type ModifyJobRequest ¶ added in v1.0.420
type ModifyJobRequest struct { *tchttp.BaseRequest // 作业Id JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 作业名称,支持长度小于50的中文/英文/数字/”-”/”_”/”.”,不能重名 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 描述 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 拖拽文件需传入此参数 TargetFolderId *string `json:"TargetFolderId,omitnil,omitempty" name:"TargetFolderId"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 作业描述 Description *string `json:"Description,omitnil,omitempty" name:"Description"` }
func NewModifyJobRequest ¶ added in v1.0.420
func NewModifyJobRequest() (request *ModifyJobRequest)
func (*ModifyJobRequest) FromJsonString ¶ added in v1.0.420
func (r *ModifyJobRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifyJobRequest) ToJsonString ¶ added in v1.0.420
func (r *ModifyJobRequest) ToJsonString() string
type ModifyJobRequestParams ¶ added in v1.0.426
type ModifyJobRequestParams struct { // 作业Id JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 作业名称,支持长度小于50的中文/英文/数字/”-”/”_”/”.”,不能重名 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 描述 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 拖拽文件需传入此参数 TargetFolderId *string `json:"TargetFolderId,omitnil,omitempty" name:"TargetFolderId"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 作业描述 Description *string `json:"Description,omitnil,omitempty" name:"Description"` }
Predefined struct for user
type ModifyJobResponse ¶ added in v1.0.420
type ModifyJobResponse struct { *tchttp.BaseResponse Response *ModifyJobResponseParams `json:"Response"` }
func NewModifyJobResponse ¶ added in v1.0.420
func NewModifyJobResponse() (response *ModifyJobResponse)
func (*ModifyJobResponse) FromJsonString ¶ added in v1.0.420
func (r *ModifyJobResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifyJobResponse) ToJsonString ¶ added in v1.0.420
func (r *ModifyJobResponse) ToJsonString() string
type ModifyJobResponseParams ¶ added in v1.0.426
type ModifyJobResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type ModifyWorkSpaceRequest ¶ added in v1.0.769
type ModifyWorkSpaceRequest struct { *tchttp.BaseRequest // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 待修改的工作空间名称 WorkSpaceName *string `json:"WorkSpaceName,omitnil,omitempty" name:"WorkSpaceName"` // 待修改的工作空间备注 Description *string `json:"Description,omitnil,omitempty" name:"Description"` }
func NewModifyWorkSpaceRequest ¶ added in v1.0.769
func NewModifyWorkSpaceRequest() (request *ModifyWorkSpaceRequest)
func (*ModifyWorkSpaceRequest) FromJsonString ¶ added in v1.0.769
func (r *ModifyWorkSpaceRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifyWorkSpaceRequest) ToJsonString ¶ added in v1.0.769
func (r *ModifyWorkSpaceRequest) ToJsonString() string
type ModifyWorkSpaceRequestParams ¶ added in v1.0.769
type ModifyWorkSpaceRequestParams struct { // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 待修改的工作空间名称 WorkSpaceName *string `json:"WorkSpaceName,omitnil,omitempty" name:"WorkSpaceName"` // 待修改的工作空间备注 Description *string `json:"Description,omitnil,omitempty" name:"Description"` }
Predefined struct for user
type ModifyWorkSpaceResponse ¶ added in v1.0.769
type ModifyWorkSpaceResponse struct { *tchttp.BaseResponse Response *ModifyWorkSpaceResponseParams `json:"Response"` }
func NewModifyWorkSpaceResponse ¶ added in v1.0.769
func NewModifyWorkSpaceResponse() (response *ModifyWorkSpaceResponse)
func (*ModifyWorkSpaceResponse) FromJsonString ¶ added in v1.0.769
func (r *ModifyWorkSpaceResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*ModifyWorkSpaceResponse) ToJsonString ¶ added in v1.0.769
func (r *ModifyWorkSpaceResponse) ToJsonString() string
type ModifyWorkSpaceResponseParams ¶ added in v1.0.769
type ModifyWorkSpaceResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type NodeConfig ¶ added in v1.0.712
type NodeConfig struct { // Node ID // 注意:此字段可能返回 null,表示取不到有效值。 Id *int64 `json:"Id,omitnil,omitempty" name:"Id"` // Node parallelism // 注意:此字段可能返回 null,表示取不到有效值。 Parallelism *int64 `json:"Parallelism,omitnil,omitempty" name:"Parallelism"` // Slot sharing group // 注意:此字段可能返回 null,表示取不到有效值。 SlotSharingGroup *string `json:"SlotSharingGroup,omitnil,omitempty" name:"SlotSharingGroup"` // Configuration properties // 注意:此字段可能返回 null,表示取不到有效值。 Configuration []*Property `json:"Configuration,omitnil,omitempty" name:"Configuration"` // 节点的状态ttl配置, 多个用 ; 分割 // 注意:此字段可能返回 null,表示取不到有效值。 StateTTL *string `json:"StateTTL,omitnil,omitempty" name:"StateTTL"` }
type Order ¶ added in v1.0.736
type Order struct { // 创建、续费、扩缩容 1 2 3 // 注意:此字段可能返回 null,表示取不到有效值。 Type *int64 `json:"Type,omitnil,omitempty" name:"Type"` // 自动续费 1 // 注意:此字段可能返回 null,表示取不到有效值。 AutoRenewFlag *int64 `json:"AutoRenewFlag,omitnil,omitempty" name:"AutoRenewFlag"` // 操作人的UIN // 注意:此字段可能返回 null,表示取不到有效值。 OperateUin *string `json:"OperateUin,omitnil,omitempty" name:"OperateUin"` // 最终集群的CU数量 // 注意:此字段可能返回 null,表示取不到有效值。 ComputeCu *int64 `json:"ComputeCu,omitnil,omitempty" name:"ComputeCu"` // 订单的时间 // 注意:此字段可能返回 null,表示取不到有效值。 OrderTime *string `json:"OrderTime,omitnil,omitempty" name:"OrderTime"` }
type RefJobStatusCountItem ¶ added in v1.0.612
type ResourceConfigItem ¶
type ResourceConfigItem struct { // 资源ID ResourceId *string `json:"ResourceId,omitnil,omitempty" name:"ResourceId"` // 资源类型 ResourceType *int64 `json:"ResourceType,omitnil,omitempty" name:"ResourceType"` // 资源所属地域 Region *string `json:"Region,omitnil,omitempty" name:"Region"` // 资源所属AppId AppId *int64 `json:"AppId,omitnil,omitempty" name:"AppId"` // 主账号Uin OwnerUin *string `json:"OwnerUin,omitnil,omitempty" name:"OwnerUin"` // 子账号Uin CreatorUin *string `json:"CreatorUin,omitnil,omitempty" name:"CreatorUin"` // 资源位置描述 ResourceLoc *ResourceLoc `json:"ResourceLoc,omitnil,omitempty" name:"ResourceLoc"` // 资源创建时间 CreateTime *string `json:"CreateTime,omitnil,omitempty" name:"CreateTime"` // 资源版本 Version *int64 `json:"Version,omitnil,omitempty" name:"Version"` // 资源描述 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 资源状态:0: 资源同步中,1:资源已就绪 // 注意:此字段可能返回 null,表示取不到有效值。 Status *int64 `json:"Status,omitnil,omitempty" name:"Status"` // 关联作业个数 // 注意:此字段可能返回 null,表示取不到有效值。 RefJobCount *int64 `json:"RefJobCount,omitnil,omitempty" name:"RefJobCount"` // 分状态统计关联作业数 // 注意:此字段可能返回 null,表示取不到有效值。 RefJobStatusCountSet []*RefJobStatusCountItem `json:"RefJobStatusCountSet,omitnil,omitempty" name:"RefJobStatusCountSet"` }
type ResourceItem ¶
type ResourceItem struct { // 资源ID ResourceId *string `json:"ResourceId,omitnil,omitempty" name:"ResourceId"` // 资源名称 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 资源类型 ResourceType *uint64 `json:"ResourceType,omitnil,omitempty" name:"ResourceType"` // 资源位置 ResourceLoc *ResourceLoc `json:"ResourceLoc,omitnil,omitempty" name:"ResourceLoc"` // 资源地域 Region *string `json:"Region,omitnil,omitempty" name:"Region"` // 应用ID AppId *uint64 `json:"AppId,omitnil,omitempty" name:"AppId"` // 主账号Uin OwnerUin *string `json:"OwnerUin,omitnil,omitempty" name:"OwnerUin"` // 子账号Uin CreatorUin *string `json:"CreatorUin,omitnil,omitempty" name:"CreatorUin"` // 资源创建时间 CreateTime *string `json:"CreateTime,omitnil,omitempty" name:"CreateTime"` // 资源最后更新时间 UpdateTime *string `json:"UpdateTime,omitnil,omitempty" name:"UpdateTime"` // 资源的资源版本ID LatestResourceConfigVersion *int64 `json:"LatestResourceConfigVersion,omitnil,omitempty" name:"LatestResourceConfigVersion"` // 资源备注 // 注意:此字段可能返回 null,表示取不到有效值。 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 版本个数 // 注意:此字段可能返回 null,表示取不到有效值。 VersionCount *int64 `json:"VersionCount,omitnil,omitempty" name:"VersionCount"` // 关联作业数 // 注意:此字段可能返回 null,表示取不到有效值。 RefJobCount *int64 `json:"RefJobCount,omitnil,omitempty" name:"RefJobCount"` // 作业运行状态 // 注意:此字段可能返回 null,表示取不到有效值。 IsJobRun *int64 `json:"IsJobRun,omitnil,omitempty" name:"IsJobRun"` // 文件名 // 注意:此字段可能返回 null,表示取不到有效值。 FileName *string `json:"FileName,omitnil,omitempty" name:"FileName"` // 工作空间ID // 注意:此字段可能返回 null,表示取不到有效值。 WorkSpaceId *int64 `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 分状态统计关联作业数 // 注意:此字段可能返回 null,表示取不到有效值。 RefJobStatusCountSet []*RefJobStatusCountItem `json:"RefJobStatusCountSet,omitnil,omitempty" name:"RefJobStatusCountSet"` }
type ResourceLoc ¶
type ResourceLoc struct { // 资源位置的存储类型,目前只支持1:COS StorageType *int64 `json:"StorageType,omitnil,omitempty" name:"StorageType"` // 描述资源位置的json Param *ResourceLocParam `json:"Param,omitnil,omitempty" name:"Param"` }
type ResourceLocParam ¶
type ResourceRef ¶
type ResourceRefDetail ¶
type ResourceRefDetail struct { // 资源id ResourceId *string `json:"ResourceId,omitnil,omitempty" name:"ResourceId"` // 资源版本,-1表示使用最新版本 Version *int64 `json:"Version,omitnil,omitempty" name:"Version"` // 资源名称 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 1: 主资源 Type *int64 `json:"Type,omitnil,omitempty" name:"Type"` // 1: 系统内置资源 SystemProvide *int64 `json:"SystemProvide,omitnil,omitempty" name:"SystemProvide"` }
type ResourceRefJobInfo ¶
type ResourceRefJobInfo struct { // Job id JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // Job配置版本 JobConfigVersion *int64 `json:"JobConfigVersion,omitnil,omitempty" name:"JobConfigVersion"` // 资源版本 ResourceVersion *int64 `json:"ResourceVersion,omitnil,omitempty" name:"ResourceVersion"` }
type ResultColumn ¶ added in v1.0.768
type ResultColumn struct { // 名称 // 注意:此字段可能返回 null,表示取不到有效值。 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 本地类型描述 // 注意:此字段可能返回 null,表示取不到有效值。 LogicalType *LogicalType `json:"LogicalType,omitnil,omitempty" name:"LogicalType"` // 备注 // 注意:此字段可能返回 null,表示取不到有效值。 Comment *string `json:"Comment,omitnil,omitempty" name:"Comment"` }
type ResultData ¶ added in v1.0.768
type RoleAuth ¶ added in v1.0.683
type RoleAuth struct { // 用户 AppID AppId *int64 `json:"AppId,omitnil,omitempty" name:"AppId"` // 工作空间 SerialId WorkSpaceSerialId *string `json:"WorkSpaceSerialId,omitnil,omitempty" name:"WorkSpaceSerialId"` // 主账号 UIN OwnerUin *string `json:"OwnerUin,omitnil,omitempty" name:"OwnerUin"` // 创建者 UIN CreatorUin *string `json:"CreatorUin,omitnil,omitempty" name:"CreatorUin"` // 绑定授权的 UIN AuthSubAccountUin *string `json:"AuthSubAccountUin,omitnil,omitempty" name:"AuthSubAccountUin"` // 对应 role表的id Permission *int64 `json:"Permission,omitnil,omitempty" name:"Permission"` // 创建时间 CreateTime *string `json:"CreateTime,omitnil,omitempty" name:"CreateTime"` // 最后一次操作时间 UpdateTime *string `json:"UpdateTime,omitnil,omitempty" name:"UpdateTime"` // 2 启用 1 停用 Status *int64 `json:"Status,omitnil,omitempty" name:"Status"` // id // 注意:此字段可能返回 null,表示取不到有效值。 Id *int64 `json:"Id,omitnil,omitempty" name:"Id"` // 工作空间id // 注意:此字段可能返回 null,表示取不到有效值。 WorkSpaceId *int64 `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 权限名称 // 注意:此字段可能返回 null,表示取不到有效值。 RoleName *string `json:"RoleName,omitnil,omitempty" name:"RoleName"` }
type RunJobDescription ¶
type RunJobDescription struct { // 作业Id JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 运行类型,1:启动,2:恢复 RunType *int64 `json:"RunType,omitnil,omitempty" name:"RunType"` // 兼容旧版 SQL 类型作业启动参数:指定数据源消费起始时间点(建议传值) // 保证参数为 LATEST、EARLIEST、T+Timestamp (例:T1557394288000) StartMode *string `json:"StartMode,omitnil,omitempty" name:"StartMode"` // 当前作业的某个版本 // (不传默认为非草稿的作业版本) JobConfigVersion *uint64 `json:"JobConfigVersion,omitnil,omitempty" name:"JobConfigVersion"` // Savepoint路径 SavepointPath *string `json:"SavepointPath,omitnil,omitempty" name:"SavepointPath"` // Savepoint的Id SavepointId *string `json:"SavepointId,omitnil,omitempty" name:"SavepointId"` // 使用历史版本系统依赖 UseOldSystemConnector *bool `json:"UseOldSystemConnector,omitnil,omitempty" name:"UseOldSystemConnector"` // 自定义时间戳 CustomTimestamp *int64 `json:"CustomTimestamp,omitnil,omitempty" name:"CustomTimestamp"` }
type RunJobsRequest ¶
type RunJobsRequest struct { *tchttp.BaseRequest // 批量启动作业的描述信息 RunJobDescriptions []*RunJobDescription `json:"RunJobDescriptions,omitnil,omitempty" name:"RunJobDescriptions"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewRunJobsRequest ¶
func NewRunJobsRequest() (request *RunJobsRequest)
func (*RunJobsRequest) FromJsonString ¶
func (r *RunJobsRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*RunJobsRequest) ToJsonString ¶
func (r *RunJobsRequest) ToJsonString() string
type RunJobsRequestParams ¶ added in v1.0.426
type RunJobsRequestParams struct { // 批量启动作业的描述信息 RunJobDescriptions []*RunJobDescription `json:"RunJobDescriptions,omitnil,omitempty" name:"RunJobDescriptions"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type RunJobsResponse ¶
type RunJobsResponse struct { *tchttp.BaseResponse Response *RunJobsResponseParams `json:"Response"` }
func NewRunJobsResponse ¶
func NewRunJobsResponse() (response *RunJobsResponse)
func (*RunJobsResponse) FromJsonString ¶
func (r *RunJobsResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*RunJobsResponse) ToJsonString ¶
func (r *RunJobsResponse) ToJsonString() string
type RunJobsResponseParams ¶ added in v1.0.426
type RunJobsResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type RunSqlGatewayStatementRequest ¶ added in v1.0.767
type RunSqlGatewayStatementRequest struct { *tchttp.BaseRequest // 集群ID ClusterId *string `json:"ClusterId,omitnil,omitempty" name:"ClusterId"` // 需要执行的sql,该sql会被Sql Gateway执行,当前支持的是paimon修改需求,因此主要是DDL语句 Sql *string `json:"Sql,omitnil,omitempty" name:"Sql"` // Sql Gateway会话ID,可不填,如果不填则会自动创建一个会话ID,每个会话ID都有一个存活时间,测试环境为10分钟,线上默认是30分钟 SessionId *string `json:"SessionId,omitnil,omitempty" name:"SessionId"` }
func NewRunSqlGatewayStatementRequest ¶ added in v1.0.767
func NewRunSqlGatewayStatementRequest() (request *RunSqlGatewayStatementRequest)
func (*RunSqlGatewayStatementRequest) FromJsonString ¶ added in v1.0.767
func (r *RunSqlGatewayStatementRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*RunSqlGatewayStatementRequest) ToJsonString ¶ added in v1.0.767
func (r *RunSqlGatewayStatementRequest) ToJsonString() string
type RunSqlGatewayStatementRequestParams ¶ added in v1.0.767
type RunSqlGatewayStatementRequestParams struct { // 集群ID ClusterId *string `json:"ClusterId,omitnil,omitempty" name:"ClusterId"` // 需要执行的sql,该sql会被Sql Gateway执行,当前支持的是paimon修改需求,因此主要是DDL语句 Sql *string `json:"Sql,omitnil,omitempty" name:"Sql"` // Sql Gateway会话ID,可不填,如果不填则会自动创建一个会话ID,每个会话ID都有一个存活时间,测试环境为10分钟,线上默认是30分钟 SessionId *string `json:"SessionId,omitnil,omitempty" name:"SessionId"` }
Predefined struct for user
type RunSqlGatewayStatementResponse ¶ added in v1.0.767
type RunSqlGatewayStatementResponse struct { *tchttp.BaseResponse Response *RunSqlGatewayStatementResponseParams `json:"Response"` }
func NewRunSqlGatewayStatementResponse ¶ added in v1.0.767
func NewRunSqlGatewayStatementResponse() (response *RunSqlGatewayStatementResponse)
func (*RunSqlGatewayStatementResponse) FromJsonString ¶ added in v1.0.767
func (r *RunSqlGatewayStatementResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*RunSqlGatewayStatementResponse) ToJsonString ¶ added in v1.0.767
func (r *RunSqlGatewayStatementResponse) ToJsonString() string
type RunSqlGatewayStatementResponseParams ¶ added in v1.0.767
type RunSqlGatewayStatementResponseParams struct { // 错误信息 // 注意:此字段可能返回 null,表示取不到有效值。 ErrorMessage []*string `json:"ErrorMessage,omitnil,omitempty" name:"ErrorMessage"` // 会话id,若入参未传,则返回自动创建的会话id,若入参已经传递,则返回值与原传入值一致 SessionId *string `json:"SessionId,omitnil,omitempty" name:"SessionId"` // 返回执行id,可以根据该执行id和会话id获取执行结果 OperationHandleId *string `json:"OperationHandleId,omitnil,omitempty" name:"OperationHandleId"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type Savepoint ¶ added in v1.0.404
type Savepoint struct { // 主键 // 注意:此字段可能返回 null,表示取不到有效值。 Id *int64 `json:"Id,omitnil,omitempty" name:"Id"` // 版本号 // 注意:此字段可能返回 null,表示取不到有效值。 VersionId *int64 `json:"VersionId,omitnil,omitempty" name:"VersionId"` // 状态 1: Active; 2: Expired; 3: InProgress; 4: Failed; 5: Timeout // 注意:此字段可能返回 null,表示取不到有效值。 Status *int64 `json:"Status,omitnil,omitempty" name:"Status"` // 创建时间 // 注意:此字段可能返回 null,表示取不到有效值。 CreateTime *int64 `json:"CreateTime,omitnil,omitempty" name:"CreateTime"` // 更新时间 // 注意:此字段可能返回 null,表示取不到有效值。 UpdateTime *int64 `json:"UpdateTime,omitnil,omitempty" name:"UpdateTime"` // 路径 // 注意:此字段可能返回 null,表示取不到有效值。 Path *string `json:"Path,omitnil,omitempty" name:"Path"` // 大小 // 注意:此字段可能返回 null,表示取不到有效值。 Size *int64 `json:"Size,omitnil,omitempty" name:"Size"` // 快照类型 1: savepoint;2: checkpoint;3: cancelWithSavepoint // 注意:此字段可能返回 null,表示取不到有效值。 RecordType *int64 `json:"RecordType,omitnil,omitempty" name:"RecordType"` // 运行作业实例的顺序 ID // 注意:此字段可能返回 null,表示取不到有效值。 JobRuntimeId *int64 `json:"JobRuntimeId,omitnil,omitempty" name:"JobRuntimeId"` // 描述 // 注意:此字段可能返回 null,表示取不到有效值。 Description *string `json:"Description,omitnil,omitempty" name:"Description"` // 固定超时时间 // 注意:此字段可能返回 null,表示取不到有效值。 Timeout *int64 `json:"Timeout,omitnil,omitempty" name:"Timeout"` // 快照 serialId // 注意:此字段可能返回 null,表示取不到有效值。 SerialId *string `json:"SerialId,omitnil,omitempty" name:"SerialId"` // 耗时 // 注意:此字段可能返回 null,表示取不到有效值。 TimeConsuming *int64 `json:"TimeConsuming,omitnil,omitempty" name:"TimeConsuming"` // 快照路径状态 1:可用;2:不可用; // 注意:此字段可能返回 null,表示取不到有效值。 PathStatus *int64 `json:"PathStatus,omitnil,omitempty" name:"PathStatus"` }
type SlotSharingGroup ¶ added in v1.0.712
type SlotSharingGroup struct { // SlotSharingGroup的名字 // 注意:此字段可能返回 null,表示取不到有效值。 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // SlotSharingGroup的规格 // 注意:此字段可能返回 null,表示取不到有效值。 Spec *SlotSharingGroupSpec `json:"Spec,omitnil,omitempty" name:"Spec"` // SlotSharingGroup的描述 // 注意:此字段可能返回 null,表示取不到有效值。 Description *string `json:"Description,omitnil,omitempty" name:"Description"` }
type SlotSharingGroupSpec ¶ added in v1.0.712
type SlotSharingGroupSpec struct { // 适用的cpu // 注意:此字段可能返回 null,表示取不到有效值。 CPU *float64 `json:"CPU,omitnil,omitempty" name:"CPU"` // 默认为b, 支持单位有 b, kb, mb, gb // 注意:此字段可能返回 null,表示取不到有效值。 HeapMemory *string `json:"HeapMemory,omitnil,omitempty" name:"HeapMemory"` // 默认为b, 支持单位有 b, kb, mb, gb // 注意:此字段可能返回 null,表示取不到有效值。 OffHeapMemory *string `json:"OffHeapMemory,omitnil,omitempty" name:"OffHeapMemory"` // 默认为b, 支持单位有 b, kb, mb, gb // 注意:此字段可能返回 null,表示取不到有效值。 ManagedMemory *string `json:"ManagedMemory,omitnil,omitempty" name:"ManagedMemory"` }
type SqlGatewayItem ¶ added in v1.0.764
type SqlGatewayItem struct { // 唯一标识 // 注意:此字段可能返回 null,表示取不到有效值。 SerialId *string `json:"SerialId,omitnil,omitempty" name:"SerialId"` // Flink内核版本 // 注意:此字段可能返回 null,表示取不到有效值。 FlinkVersion *string `json:"FlinkVersion,omitnil,omitempty" name:"FlinkVersion"` // 状态,1.停止 2. 开启中 3. 开启 4. 开启失败 5. 停止中 // 注意:此字段可能返回 null,表示取不到有效值。 Status *int64 `json:"Status,omitnil,omitempty" name:"Status"` // 创建人 // 注意:此字段可能返回 null,表示取不到有效值。 CreatorUin *string `json:"CreatorUin,omitnil,omitempty" name:"CreatorUin"` // 引用资源 // 注意:此字段可能返回 null,表示取不到有效值。 ResourceRefs []*GatewayRefItem `json:"ResourceRefs,omitnil,omitempty" name:"ResourceRefs"` // Cu规格 // 注意:此字段可能返回 null,表示取不到有效值。 CuSpec *float64 `json:"CuSpec,omitnil,omitempty" name:"CuSpec"` // 创建时间 // 注意:此字段可能返回 null,表示取不到有效值。 CreateTime *string `json:"CreateTime,omitnil,omitempty" name:"CreateTime"` // 更新时间 // 注意:此字段可能返回 null,表示取不到有效值。 UpdateTime *string `json:"UpdateTime,omitnil,omitempty" name:"UpdateTime"` // 配置参数 // 注意:此字段可能返回 null,表示取不到有效值。 Properties []*Property `json:"Properties,omitnil,omitempty" name:"Properties"` }
type StatementResult ¶ added in v1.0.768
type StatementResult struct { // 返回结果列 // 注意:此字段可能返回 null,表示取不到有效值。 Columns []*ResultColumn `json:"Columns,omitnil,omitempty" name:"Columns"` // 格式 // 注意:此字段可能返回 null,表示取不到有效值。 RowFormat *string `json:"RowFormat,omitnil,omitempty" name:"RowFormat"` // 结果值 // 注意:此字段可能返回 null,表示取不到有效值。 Data []*ResultData `json:"Data,omitnil,omitempty" name:"Data"` }
type StopJobDescription ¶
type StopJobsRequest ¶
type StopJobsRequest struct { *tchttp.BaseRequest // 批量停止作业的描述信息 StopJobDescriptions []*StopJobDescription `json:"StopJobDescriptions,omitnil,omitempty" name:"StopJobDescriptions"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewStopJobsRequest ¶
func NewStopJobsRequest() (request *StopJobsRequest)
func (*StopJobsRequest) FromJsonString ¶
func (r *StopJobsRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*StopJobsRequest) ToJsonString ¶
func (r *StopJobsRequest) ToJsonString() string
type StopJobsRequestParams ¶ added in v1.0.426
type StopJobsRequestParams struct { // 批量停止作业的描述信息 StopJobDescriptions []*StopJobDescription `json:"StopJobDescriptions,omitnil,omitempty" name:"StopJobDescriptions"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type StopJobsResponse ¶
type StopJobsResponse struct { *tchttp.BaseResponse Response *StopJobsResponseParams `json:"Response"` }
func NewStopJobsResponse ¶
func NewStopJobsResponse() (response *StopJobsResponse)
func (*StopJobsResponse) FromJsonString ¶
func (r *StopJobsResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*StopJobsResponse) ToJsonString ¶
func (r *StopJobsResponse) ToJsonString() string
type StopJobsResponseParams ¶ added in v1.0.426
type StopJobsResponseParams struct { // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type SubEks ¶ added in v1.0.933
type SubEks struct { // 集群id // 注意:此字段可能返回 null,表示取不到有效值。 SerialId *string `json:"SerialId,omitnil,omitempty" name:"SerialId"` // cu数 // 注意:此字段可能返回 null,表示取不到有效值。 CuNum *int64 `json:"CuNum,omitnil,omitempty" name:"CuNum"` // 状态 // 注意:此字段可能返回 null,表示取不到有效值。 Status *int64 `json:"Status,omitnil,omitempty" name:"Status"` // 状态描述 // 注意:此字段可能返回 null,表示取不到有效值。 StatusDesc *string `json:"StatusDesc,omitnil,omitempty" name:"StatusDesc"` // 运行cu // 注意:此字段可能返回 null,表示取不到有效值。 RunningCu *float64 `json:"RunningCu,omitnil,omitempty" name:"RunningCu"` }
type SubFolderInfo ¶ added in v1.0.810
type SystemResourceItem ¶
type SystemResourceItem struct { // 资源ID ResourceId *string `json:"ResourceId,omitnil,omitempty" name:"ResourceId"` // 资源名称 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 资源类型。1 表示 JAR 包,目前只支持该值。 ResourceType *int64 `json:"ResourceType,omitnil,omitempty" name:"ResourceType"` // 资源备注 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 资源所属地域 Region *string `json:"Region,omitnil,omitempty" name:"Region"` // 资源的最新版本 LatestResourceConfigVersion *int64 `json:"LatestResourceConfigVersion,omitnil,omitempty" name:"LatestResourceConfigVersion"` }
type TraceModeConfiguration ¶ added in v1.0.772
type TraceModeConfiguration struct { // 如1%转换为0.01 // 注意:此字段可能返回 null,表示取不到有效值。 Rate *string `json:"Rate,omitnil,omitempty" name:"Rate"` // 按照算子ID顺序配置,可以对每个算子配置IN、OUT、IN_AND_OUT三个值,分别表示采集输入数据、采集输出数据、同时采集输入和输出数据 // 注意:此字段可能返回 null,表示取不到有效值。 Operator *string `json:"Operator,omitnil,omitempty" name:"Operator"` }
type TreeJobSets ¶ added in v1.0.772
type TreeJobSets struct { // 作业Id // 注意:此字段可能返回 null,表示取不到有效值。 JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 作业名 // 注意:此字段可能返回 null,表示取不到有效值。 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 作业类型 // 注意:此字段可能返回 null,表示取不到有效值。 JobType *int64 `json:"JobType,omitnil,omitempty" name:"JobType"` // 作业占用资源 // 注意:此字段可能返回 null,表示取不到有效值。 RunningCu *float64 `json:"RunningCu,omitnil,omitempty" name:"RunningCu"` // 作业状态 启动或者停止或者暂停 // 注意:此字段可能返回 null,表示取不到有效值。 Status *int64 `json:"Status,omitnil,omitempty" name:"Status"` }
type TreeResourceItem ¶ added in v1.0.599
type TreeResourceItem struct { // 资源ID ResourceId *string `json:"ResourceId,omitnil,omitempty" name:"ResourceId"` // 资源名称 // 注意:此字段可能返回 null,表示取不到有效值。 Name *string `json:"Name,omitnil,omitempty" name:"Name"` // 资源类型 ResourceType *int64 `json:"ResourceType,omitnil,omitempty" name:"ResourceType"` // 备注 // 注意:此字段可能返回 null,表示取不到有效值。 Remark *string `json:"Remark,omitnil,omitempty" name:"Remark"` // 文件名 // 注意:此字段可能返回 null,表示取不到有效值。 FileName *string `json:"FileName,omitnil,omitempty" name:"FileName"` // 目录ID // 注意:此字段可能返回 null,表示取不到有效值。 FolderId *string `json:"FolderId,omitnil,omitempty" name:"FolderId"` // 分状态统计关联作业数 // 注意:此字段可能返回 null,表示取不到有效值。 RefJobStatusCountSet []*RefJobStatusCountItem `json:"RefJobStatusCountSet,omitnil,omitempty" name:"RefJobStatusCountSet"` }
type TriggerJobSavepointRequest ¶ added in v1.0.415
type TriggerJobSavepointRequest struct { *tchttp.BaseRequest // 作业 SerialId JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 描述 Description *string `json:"Description,omitnil,omitempty" name:"Description"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
func NewTriggerJobSavepointRequest ¶ added in v1.0.415
func NewTriggerJobSavepointRequest() (request *TriggerJobSavepointRequest)
func (*TriggerJobSavepointRequest) FromJsonString ¶ added in v1.0.415
func (r *TriggerJobSavepointRequest) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*TriggerJobSavepointRequest) ToJsonString ¶ added in v1.0.415
func (r *TriggerJobSavepointRequest) ToJsonString() string
type TriggerJobSavepointRequestParams ¶ added in v1.0.426
type TriggerJobSavepointRequestParams struct { // 作业 SerialId JobId *string `json:"JobId,omitnil,omitempty" name:"JobId"` // 描述 Description *string `json:"Description,omitnil,omitempty" name:"Description"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` }
Predefined struct for user
type TriggerJobSavepointResponse ¶ added in v1.0.415
type TriggerJobSavepointResponse struct { *tchttp.BaseResponse Response *TriggerJobSavepointResponseParams `json:"Response"` }
func NewTriggerJobSavepointResponse ¶ added in v1.0.415
func NewTriggerJobSavepointResponse() (response *TriggerJobSavepointResponse)
func (*TriggerJobSavepointResponse) FromJsonString ¶ added in v1.0.415
func (r *TriggerJobSavepointResponse) FromJsonString(s string) error
FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check
func (*TriggerJobSavepointResponse) ToJsonString ¶ added in v1.0.415
func (r *TriggerJobSavepointResponse) ToJsonString() string
type TriggerJobSavepointResponseParams ¶ added in v1.0.426
type TriggerJobSavepointResponseParams struct { // 是否成功 SavepointTrigger *bool `json:"SavepointTrigger,omitnil,omitempty" name:"SavepointTrigger"` // 错误消息 // 注意:此字段可能返回 null,表示取不到有效值。 ErrorMsg *string `json:"ErrorMsg,omitnil,omitempty" name:"ErrorMsg"` // 快照路径 // 注意:此字段可能返回 null,表示取不到有效值。 FinalSavepointPath *string `json:"FinalSavepointPath,omitnil,omitempty" name:"FinalSavepointPath"` // 快照 ID // 注意:此字段可能返回 null,表示取不到有效值。 SavepointId *string `json:"SavepointId,omitnil,omitempty" name:"SavepointId"` // 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"` }
Predefined struct for user
type WorkSpaceClusterItem ¶ added in v1.0.441
type WorkSpaceClusterItem struct { // 集群 ID ClusterGroupId *int64 `json:"ClusterGroupId,omitnil,omitempty" name:"ClusterGroupId"` // 集群 SerialId ClusterGroupSerialId *string `json:"ClusterGroupSerialId,omitnil,omitempty" name:"ClusterGroupSerialId"` // 集群名称 ClusterName *string `json:"ClusterName,omitnil,omitempty" name:"ClusterName"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 工作空间名称 WorkSpaceName *string `json:"WorkSpaceName,omitnil,omitempty" name:"WorkSpaceName"` // 绑定状态 2 绑定 1 解除绑定 Status *int64 `json:"Status,omitnil,omitempty" name:"Status"` // 项目ID ProjectId *int64 `json:"ProjectId,omitnil,omitempty" name:"ProjectId"` // 项目ID string类型 // 注意:此字段可能返回 null,表示取不到有效值。 ProjectIdStr *string `json:"ProjectIdStr,omitnil,omitempty" name:"ProjectIdStr"` }
type WorkSpaceSetItem ¶ added in v1.0.683
type WorkSpaceSetItem struct { // 工作空间 SerialId SerialId *string `json:"SerialId,omitnil,omitempty" name:"SerialId"` // 用户 APPID AppId *int64 `json:"AppId,omitnil,omitempty" name:"AppId"` // 主账号 UIN OwnerUin *string `json:"OwnerUin,omitnil,omitempty" name:"OwnerUin"` // 创建者 UIN CreatorUin *string `json:"CreatorUin,omitnil,omitempty" name:"CreatorUin"` // 工作空间名称 WorkSpaceName *string `json:"WorkSpaceName,omitnil,omitempty" name:"WorkSpaceName"` // 区域 Region *string `json:"Region,omitnil,omitempty" name:"Region"` // 创建时间 CreateTime *string `json:"CreateTime,omitnil,omitempty" name:"CreateTime"` // 更新时间 UpdateTime *string `json:"UpdateTime,omitnil,omitempty" name:"UpdateTime"` // 1 未初始化 2 可用 -1 已删除 Status *int64 `json:"Status,omitnil,omitempty" name:"Status"` // 工作空间描述 Description *string `json:"Description,omitnil,omitempty" name:"Description"` // 工作空间包含集群信息 ClusterGroupSetItem []*ClusterGroupSetItem `json:"ClusterGroupSetItem,omitnil,omitempty" name:"ClusterGroupSetItem"` // 工作空间角色的信息 RoleAuth []*RoleAuth `json:"RoleAuth,omitnil,omitempty" name:"RoleAuth"` // 工作空间成员数量 RoleAuthCount *int64 `json:"RoleAuthCount,omitnil,omitempty" name:"RoleAuthCount"` // 工作空间 SerialId WorkSpaceId *string `json:"WorkSpaceId,omitnil,omitempty" name:"WorkSpaceId"` // 1 // 注意:此字段可能返回 null,表示取不到有效值。 JobsCount *int64 `json:"JobsCount,omitnil,omitempty" name:"JobsCount"` }