v20190422

package
v1.0.731 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 25, 2023 License: Apache-2.0 Imports: 7 Imported by: 2

Documentation

Index

Constants

View Source 
const (

	// CAM签名/鉴权错误。
	AUTHFAILURE = "AuthFailure"

	// 未授权操作。
	AUTHFAILURE_UNAUTHORIZEDOPERATION = "AuthFailure.UnauthorizedOperation"

	// 操作失败。
	FAILEDOPERATION = "FailedOperation"

	// 数据库连接失败，请检查参数是否填写正确。
	FAILEDOPERATION_DATASOURCECONNECTIONFAILED = "FailedOperation.DataSourceConnectionFailed"

	// 重复的作业名。
	FAILEDOPERATION_DUPLICATEDJOBNAME = "FailedOperation.DuplicatedJobName"

	// 查询资源关联标签失败。
	FAILEDOPERATION_GETRESOURCETAGSBYRESOURCEIDS = "FailedOperation.GetResourceTagsByResourceIds"

	// 语法检查失败。
	FAILEDOPERATION_GRAMMARCHECKFAILURE = "FailedOperation.GrammarCheckFailure"

	// 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"

	// 非法的 MaxParallelism 参数。
	INVALIDPARAMETER_ILLEGALMAXPARALLELISM = "InvalidParameter.IllegalMaxParallelism"

	// 非法的搜索字符串。
	INVALIDPARAMETER_ILLEGALSEARCHKEYWORD = "InvalidParameter.IllegalSearchKeyword"

	// appid错误。
	INVALIDPARAMETER_INVALIDAPPID = "InvalidParameter.InvalidAppId"

	// 无效集群id。
	INVALIDPARAMETER_INVALIDCLUSTERID = "InvalidParameter.InvalidClusterId"

	// 名字不符合规范。
	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_UNSUPPORTEDCOMPOSITE = "InvalidParameterValue.UnSupportedComposite"

	// 未知停止类型错误。
	INVALIDPARAMETERVALUE_UNKNOWNSTOPTYPE = "InvalidParameterValue.UnknownStopType"

	// 超过配额限制。
	LIMITEXCEEDED = "LimitExceeded"

	// Job个数超过限额。
	LIMITEXCEEDED_JOB = "LimitExceeded.Job"

	// 作业配置超出限制。
	LIMITEXCEEDED_JOBCONFIG = "LimitExceeded.JobConfig"

	// 资源被占用。
	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"

	// 资源不可用。
	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"

	// Cls Sql未启用。
	UNSUPPORTEDOPERATION_CLSSQLNOTENABLED = "UnsupportedOperation.ClsSqlNotEnabled"

	// Checkpoint 时间间隔，错误。
	UNSUPPORTEDOPERATION_INVALIDCHECKPOINTINTERVALERROR = "UnsupportedOperation.InvalidCheckpointIntervalError"

	// 权限拦截,没有进入权限。
	UNSUPPORTEDOPERATION_NOPERMISSIONACCESS = "UnsupportedOperation.NoPermissionAccess"

	// 不支持的启动模式。
	UNSUPPORTEDOPERATION_UNSUPPORTEDSTARTMODE = "UnsupportedOperation.UnsupportedStartMode"
)
View Source 
const APIVersion = "2019-04-22"

Variables

This section is empty.

Functions

This section is empty.

Types

type CCN added in v1.0.441 

type CCN struct {
	// 私有网络 ID
	VpcId *string `json:"VpcId,omitempty" name:"VpcId"`

	// 子网 ID
	SubnetId *string `json:"SubnetId,omitempty" name:"SubnetId"`

	// 云联网 ID，如 ccn-rahigzjd
	CcnId *string `json:"CcnId,omitempty" name:"CcnId"`
}

type CheckSavepointRequest added in v1.0.404 

type CheckSavepointRequest struct {
	*tchttp.BaseRequest

	// 作业 id
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 快照资源 id
	SerialId *string `json:"SerialId,omitempty" name:"SerialId"`

	// 快照类型 1: savepoint；2: checkpoint；3: cancelWithSavepoint
	RecordType *int64 `json:"RecordType,omitempty" name:"RecordType"`

	// 快照路径，目前只支持 cos 路径
	SavepointPath *string `json:"SavepointPath,omitempty" name:"SavepointPath"`

	// 工作空间 id
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"JobId"`

	// 快照资源 id
	SerialId *string `json:"SerialId,omitempty" name:"SerialId"`

	// 快照类型 1: savepoint；2: checkpoint；3: cancelWithSavepoint
	RecordType *int64 `json:"RecordType,omitempty" name:"RecordType"`

	// 快照路径，目前只支持 cos 路径
	SavepointPath *string `json:"SavepointPath,omitempty" name:"SavepointPath"`

	// 工作空间 id
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"SerialId"`

	// 1=可用，2=不可用
	SavepointStatus *int64 `json:"SavepointStatus,omitempty" name:"SavepointStatus"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type ClazzLevel added in v1.0.712 

type ClazzLevel struct {
	// java类全路径
	// 注意：此字段可能返回 null，表示取不到有效值。
	Clazz *string `json:"Clazz,omitempty" name:"Clazz"`

	// 日志级别  TRACE，DEBUG、INFO、WARN、ERROR
	// 注意：此字段可能返回 null，表示取不到有效值。
	Level *string `json:"Level,omitempty" name:"Level"`
}

type Client 

type Client struct {
	common.Client
}

func NewClient 

func NewClient(credential common.CredentialIface, region string, clientProfile *profile.ClientProfile) (client *Client, err error)

func NewClientWithSecretId 

func NewClientWithSecretId(secretId, secretKey, region string) (client *Client, err error)

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) 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) 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"
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"
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) 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) 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_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_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) 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) 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,omitempty" name:"ClusterId"`

	// 集群名称
	Name *string `json:"Name,omitempty" name:"Name"`

	// 地域
	Region *string `json:"Region,omitempty" name:"Region"`

	// 用户 AppID
	AppId *uint64 `json:"AppId,omitempty" name:"AppId"`

	// 主账号 UIN
	OwnerUin *string `json:"OwnerUin,omitempty" name:"OwnerUin"`

	// 创建者 UIN
	CreatorUin *string `json:"CreatorUin,omitempty" name:"CreatorUin"`

	// 集群状态, 1 未初始化,，3 初始化中，2 运行中
	Status *int64 `json:"Status,omitempty" name:"Status"`

	// 描述
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 集群创建时间
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// 最后一次操作集群的时间
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`

	// CU 数量
	CuNum *uint64 `json:"CuNum,omitempty" name:"CuNum"`

	// CU 内存规格
	CuMem *uint64 `json:"CuMem,omitempty" name:"CuMem"`

	// 可用区
	Zone *string `json:"Zone,omitempty" name:"Zone"`

	// 状态描述
	StatusDesc *string `json:"StatusDesc,omitempty" name:"StatusDesc"`

	// 网络
	CCNs []*CCN `json:"CCNs,omitempty" name:"CCNs"`

	// 网络
	NetEnvironmentType *uint64 `json:"NetEnvironmentType,omitempty" name:"NetEnvironmentType"`

	// 空闲 CU
	FreeCuNum *int64 `json:"FreeCuNum,omitempty" name:"FreeCuNum"`

	// 集群绑定的标签
	// 注意：此字段可能返回 null，表示取不到有效值。
	Tags []*Tag `json:"Tags,omitempty" name:"Tags"`

	// 集群隔离时间; 没隔离时间，则为 -
	// 注意：此字段可能返回 null，表示取不到有效值。
	IsolatedTime *string `json:"IsolatedTime,omitempty" name:"IsolatedTime"`

	// 集群过期时间; 没过期概念，则为 -
	// 注意：此字段可能返回 null，表示取不到有效值。
	ExpireTime *string `json:"ExpireTime,omitempty" name:"ExpireTime"`

	// 距离过期还有多少秒; 没过期概念，则为 -
	// 注意：此字段可能返回 null，表示取不到有效值。
	SecondsUntilExpiry *string `json:"SecondsUntilExpiry,omitempty" name:"SecondsUntilExpiry"`

	// 自动续费标记，0 表示默认状态 (用户未设置，即初始状态，用户开通了预付费不停服特权会进行自动续费)， 1 表示自动续费，2表示明确不自动续费(用户设置)
	// 注意：此字段可能返回 null，表示取不到有效值。
	AutoRenewFlag *int64 `json:"AutoRenewFlag,omitempty" name:"AutoRenewFlag"`

	// 集群的默认 COS 存储桶
	// 注意：此字段可能返回 null，表示取不到有效值。
	DefaultCOSBucket *string `json:"DefaultCOSBucket,omitempty" name:"DefaultCOSBucket"`

	// 集群的CLS 日志集 LogSet
	// 注意：此字段可能返回 null，表示取不到有效值。
	CLSLogSet *string `json:"CLSLogSet,omitempty" name:"CLSLogSet"`

	// 集群的CLS 日志主题 TopicId
	// 注意：此字段可能返回 null，表示取不到有效值。
	CLSTopicId *string `json:"CLSTopicId,omitempty" name:"CLSTopicId"`

	// 集群的CLS 日志集  名字
	// 注意：此字段可能返回 null，表示取不到有效值。
	CLSLogName *string `json:"CLSLogName,omitempty" name:"CLSLogName"`

	// 集群的CLS 日志主题  名字
	// 注意：此字段可能返回 null，表示取不到有效值。
	CLSTopicName *string `json:"CLSTopicName,omitempty" name:"CLSTopicName"`

	// 集群的版本信息
	// 注意：此字段可能返回 null，表示取不到有效值。
	Version *ClusterVersion `json:"Version,omitempty" name:"Version"`

	// 细粒度资源下的空闲CU
	// 注意：此字段可能返回 null，表示取不到有效值。
	FreeCu *float64 `json:"FreeCu,omitempty" name:"FreeCu"`

	// 集群的默认日志采集配置
	// 注意：此字段可能返回 null，表示取不到有效值。
	DefaultLogCollectConf *string `json:"DefaultLogCollectConf,omitempty" name:"DefaultLogCollectConf"`

	// 取值：0-没有设置，1-已设置，2-不允许设置
	// 注意：此字段可能返回 null，表示取不到有效值。
	CustomizedDNSEnabled *int64 `json:"CustomizedDNSEnabled,omitempty" name:"CustomizedDNSEnabled"`

	// 空间信息
	// 注意：此字段可能返回 null，表示取不到有效值。
	Correlations []*WorkSpaceClusterItem `json:"Correlations,omitempty" name:"Correlations"`

	// 运行CU
	// 注意：此字段可能返回 null，表示取不到有效值。
	RunningCu *float64 `json:"RunningCu,omitempty" name:"RunningCu"`

	// 0 后付费,1 预付费
	// 注意：此字段可能返回 null，表示取不到有效值。
	PayMode *int64 `json:"PayMode,omitempty" name:"PayMode"`

	// 前端区分 集群是否需要2CU逻辑 因为历史集群 变配不需要, default 1  新集群都需要
	// 注意：此字段可能返回 null，表示取不到有效值。
	IsNeedManageNode *int64 `json:"IsNeedManageNode,omitempty" name:"IsNeedManageNode"`

	// session集群信息
	// 注意：此字段可能返回 null，表示取不到有效值。
	ClusterSessions []*ClusterSession `json:"ClusterSessions,omitempty" name:"ClusterSessions"`
}

type ClusterGroupSetItem added in v1.0.683 

type ClusterGroupSetItem struct {
	// clusterGroup 的 SerialId
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// 集群名称
	Name *string `json:"Name,omitempty" name:"Name"`

	// 地域
	Region *string `json:"Region,omitempty" name:"Region"`

	// 区
	Zone *string `json:"Zone,omitempty" name:"Zone"`

	// 账号 APPID
	AppId *int64 `json:"AppId,omitempty" name:"AppId"`

	// 主账号 UIN
	OwnerUin *string `json:"OwnerUin,omitempty" name:"OwnerUin"`

	// 创建账号 UIN
	CreatorUin *string `json:"CreatorUin,omitempty" name:"CreatorUin"`

	// CU 数量
	CuNum *int64 `json:"CuNum,omitempty" name:"CuNum"`

	// CU 内存规格
	CuMem *int64 `json:"CuMem,omitempty" name:"CuMem"`

	// 集群状态, 1 未初始化,，3 初始化中，2 运行中
	Status *int64 `json:"Status,omitempty" name:"Status"`

	// 状态描述
	StatusDesc *string `json:"StatusDesc,omitempty" name:"StatusDesc"`

	// 集群创建时间
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// 最后一次操作集群的时间
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`

	// 描述
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 网络
	NetEnvironmentType *int64 `json:"NetEnvironmentType,omitempty" name:"NetEnvironmentType"`

	// 空闲 CU
	FreeCuNum *int64 `json:"FreeCuNum,omitempty" name:"FreeCuNum"`

	// 细粒度资源下的空闲CU
	FreeCu *float64 `json:"FreeCu,omitempty" name:"FreeCu"`

	// 运行中CU
	RunningCu *float64 `json:"RunningCu,omitempty" name:"RunningCu"`

	// 付费模式
	PayMode *int64 `json:"PayMode,omitempty" name:"PayMode"`
}

type ClusterSession added in v1.0.655 

type ClusterSession struct {
}

type ClusterVersion added in v1.0.441 

type ClusterVersion struct {
	// 集群的Flink版本
	// 注意：此字段可能返回 null，表示取不到有效值。
	Flink *string `json:"Flink,omitempty" name:"Flink"`

	// 集群支持的Flink版本
	// 注意：此字段可能返回 null，表示取不到有效值。
	SupportedFlink []*string `json:"SupportedFlink,omitempty" name:"SupportedFlink"`
}

type CopyJobItem added in v1.0.450 

type CopyJobItem struct {
	// 需要复制的作业serial id
	SourceId *string `json:"SourceId,omitempty" name:"SourceId"`

	// 目标集群的cluster serial id
	TargetClusterId *string `json:"TargetClusterId,omitempty" name:"TargetClusterId"`

	// 需要复制的作业名称
	SourceName *string `json:"SourceName,omitempty" name:"SourceName"`

	// 新作业的名称
	TargetName *string `json:"TargetName,omitempty" name:"TargetName"`

	// 新作业的目录id
	TargetFolderId *string `json:"TargetFolderId,omitempty" name:"TargetFolderId"`

	// 源作业类型
	JobType *int64 `json:"JobType,omitempty" name:"JobType"`
}

type CopyJobResult added in v1.0.450 

type CopyJobResult struct {
	// 原作业id
	// 注意：此字段可能返回 null，表示取不到有效值。
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 原作业名称
	// 注意：此字段可能返回 null，表示取不到有效值。
	JobName *string `json:"JobName,omitempty" name:"JobName"`

	// 新作业名称
	// 注意：此字段可能返回 null，表示取不到有效值。
	TargetJobName *string `json:"TargetJobName,omitempty" name:"TargetJobName"`

	// 新作业id
	// 注意：此字段可能返回 null，表示取不到有效值。
	TargetJobId *string `json:"TargetJobId,omitempty" name:"TargetJobId"`

	// 失败时候的信息
	// 注意：此字段可能返回 null，表示取不到有效值。
	Message *string `json:"Message,omitempty" name:"Message"`

	// 0 成功  -1 失败
	// 注意：此字段可能返回 null，表示取不到有效值。
	Result *int64 `json:"Result,omitempty" name:"Result"`

	// 目标集群名称
	// 注意：此字段可能返回 null，表示取不到有效值。
	ClusterName *string `json:"ClusterName,omitempty" name:"ClusterName"`

	// 目标集群id
	// 注意：此字段可能返回 null，表示取不到有效值。
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// 作业类型
	// 注意：此字段可能返回 null，表示取不到有效值。
	JobType *int64 `json:"JobType,omitempty" name:"JobType"`
}

type CopyJobsRequest added in v1.0.449 

type CopyJobsRequest struct {
	*tchttp.BaseRequest

	// 复制明细列表
	JobItems []*CopyJobItem `json:"JobItems,omitempty" name:"JobItems"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`
}

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,omitempty" name:"JobItems"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`
}

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,omitempty" name:"SuccessCount"`

	// 失败条数
	// 注意：此字段可能返回 null，表示取不到有效值。
	FailCount *int64 `json:"FailCount,omitempty" name:"FailCount"`

	// 结果列表
	// 注意：此字段可能返回 null，表示取不到有效值。
	CopyJobsResults []*CopyJobResult `json:"CopyJobsResults,omitempty" name:"CopyJobsResults"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type CreateFolderRequest added in v1.0.449 

type CreateFolderRequest struct {
	*tchttp.BaseRequest

	// 新建文件夹名
	FolderName *string `json:"FolderName,omitempty" name:"FolderName"`

	// 新建文件夹的父目录ID
	ParentId *string `json:"ParentId,omitempty" name:"ParentId"`

	// 文件夹类型，0是任务文件夹，1是依赖文件夹
	FolderType *int64 `json:"FolderType,omitempty" name:"FolderType"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"FolderName"`

	// 新建文件夹的父目录ID
	ParentId *string `json:"ParentId,omitempty" name:"ParentId"`

	// 文件夹类型，0是任务文件夹，1是依赖文件夹
	FolderType *int64 `json:"FolderType,omitempty" name:"FolderType"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"FolderId"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type CreateJobConfigRequest 

type CreateJobConfigRequest struct {
	*tchttp.BaseRequest

	// 作业Id
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 主类
	EntrypointClass *string `json:"EntrypointClass,omitempty" name:"EntrypointClass"`

	// 主类入参
	ProgramArgs *string `json:"ProgramArgs,omitempty" name:"ProgramArgs"`

	// 备注
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 资源引用数组
	ResourceRefs []*ResourceRef `json:"ResourceRefs,omitempty" name:"ResourceRefs"`

	// 作业默认并行度
	DefaultParallelism *uint64 `json:"DefaultParallelism,omitempty" name:"DefaultParallelism"`

	// 系统参数
	Properties []*Property `json:"Properties,omitempty" name:"Properties"`

	// 1: 作业配置达到上限之后，自动删除可删除的最早版本
	AutoDelete *int64 `json:"AutoDelete,omitempty" name:"AutoDelete"`

	// 作业使用的 COS 存储桶名
	COSBucket *string `json:"COSBucket,omitempty" name:"COSBucket"`

	// 是否采集作业日志
	LogCollect *bool `json:"LogCollect,omitempty" name:"LogCollect"`

	// JobManager规格
	JobManagerSpec *float64 `json:"JobManagerSpec,omitempty" name:"JobManagerSpec"`

	// TaskManager规格
	TaskManagerSpec *float64 `json:"TaskManagerSpec,omitempty" name:"TaskManagerSpec"`

	// CLS日志集ID
	ClsLogsetId *string `json:"ClsLogsetId,omitempty" name:"ClsLogsetId"`

	// CLS日志主题ID
	ClsTopicId *string `json:"ClsTopicId,omitempty" name:"ClsTopicId"`

	// 日志采集类型 2：CLS；3：COS
	LogCollectType *int64 `json:"LogCollectType,omitempty" name:"LogCollectType"`

	// pyflink作业运行时使用的python版本
	PythonVersion *string `json:"PythonVersion,omitempty" name:"PythonVersion"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`

	// 日志级别
	LogLevel *string `json:"LogLevel,omitempty" name:"LogLevel"`

	// Oceanus 平台恢复作业开关 1:开启 -1: 关闭
	AutoRecover *int64 `json:"AutoRecover,omitempty" name:"AutoRecover"`

	// 类日志级别
	ClazzLevels []*ClazzLevel `json:"ClazzLevels,omitempty" name:"ClazzLevels"`

	// 是否打开专家模式
	ExpertModeOn *bool `json:"ExpertModeOn,omitempty" name:"ExpertModeOn"`

	// 专家模式的配置
	ExpertModeConfiguration *ExpertModeConfiguration `json:"ExpertModeConfiguration,omitempty" name:"ExpertModeConfiguration"`
}

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,omitempty" name:"JobId"`

	// 主类
	EntrypointClass *string `json:"EntrypointClass,omitempty" name:"EntrypointClass"`

	// 主类入参
	ProgramArgs *string `json:"ProgramArgs,omitempty" name:"ProgramArgs"`

	// 备注
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 资源引用数组
	ResourceRefs []*ResourceRef `json:"ResourceRefs,omitempty" name:"ResourceRefs"`

	// 作业默认并行度
	DefaultParallelism *uint64 `json:"DefaultParallelism,omitempty" name:"DefaultParallelism"`

	// 系统参数
	Properties []*Property `json:"Properties,omitempty" name:"Properties"`

	// 1: 作业配置达到上限之后，自动删除可删除的最早版本
	AutoDelete *int64 `json:"AutoDelete,omitempty" name:"AutoDelete"`

	// 作业使用的 COS 存储桶名
	COSBucket *string `json:"COSBucket,omitempty" name:"COSBucket"`

	// 是否采集作业日志
	LogCollect *bool `json:"LogCollect,omitempty" name:"LogCollect"`

	// JobManager规格
	JobManagerSpec *float64 `json:"JobManagerSpec,omitempty" name:"JobManagerSpec"`

	// TaskManager规格
	TaskManagerSpec *float64 `json:"TaskManagerSpec,omitempty" name:"TaskManagerSpec"`

	// CLS日志集ID
	ClsLogsetId *string `json:"ClsLogsetId,omitempty" name:"ClsLogsetId"`

	// CLS日志主题ID
	ClsTopicId *string `json:"ClsTopicId,omitempty" name:"ClsTopicId"`

	// 日志采集类型 2：CLS；3：COS
	LogCollectType *int64 `json:"LogCollectType,omitempty" name:"LogCollectType"`

	// pyflink作业运行时使用的python版本
	PythonVersion *string `json:"PythonVersion,omitempty" name:"PythonVersion"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`

	// 日志级别
	LogLevel *string `json:"LogLevel,omitempty" name:"LogLevel"`

	// Oceanus 平台恢复作业开关 1:开启 -1: 关闭
	AutoRecover *int64 `json:"AutoRecover,omitempty" name:"AutoRecover"`

	// 类日志级别
	ClazzLevels []*ClazzLevel `json:"ClazzLevels,omitempty" name:"ClazzLevels"`

	// 是否打开专家模式
	ExpertModeOn *bool `json:"ExpertModeOn,omitempty" name:"ExpertModeOn"`

	// 专家模式的配置
	ExpertModeConfiguration *ExpertModeConfiguration `json:"ExpertModeConfiguration,omitempty" name:"ExpertModeConfiguration"`
}

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,omitempty" name:"Version"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type CreateJobRequest 

type CreateJobRequest struct {
	*tchttp.BaseRequest

	// 作业名称，允许输入长度小于等于50个字符的中文、英文、数字、-（横线）、_（下划线）、.（点），且符号必须半角字符。注意作业名不能和现有作业同名
	Name *string `json:"Name,omitempty" name:"Name"`

	// 作业的类型，1 表示 SQL 作业，2 表示 JAR 作业
	JobType *int64 `json:"JobType,omitempty" name:"JobType"`

	// 集群的类型，1 表示共享集群，2 表示独享集群
	ClusterType *int64 `json:"ClusterType,omitempty" name:"ClusterType"`

	// 当 ClusterType=2 时，必选，用来指定该作业提交的独享集群 ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// 设置每 CU 的内存规格，单位为 GB，支持 2、4、8、16（需申请开通白名单后使用）。默认为 4，即 1 CU 对应 4 GB 的运行内存
	CuMem *uint64 `json:"CuMem,omitempty" name:"CuMem"`

	// 作业的备注信息，可以随意设置
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 作业名所属文件夹ID，根目录为"root"
	FolderId *string `json:"FolderId,omitempty" name:"FolderId"`

	// 作业运行的Flink版本
	FlinkVersion *string `json:"FlinkVersion,omitempty" name:"FlinkVersion"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`

	// 作业标签
	Tags []*Tag `json:"Tags,omitempty" name:"Tags"`
}

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,omitempty" name:"Name"`

	// 作业的类型，1 表示 SQL 作业，2 表示 JAR 作业
	JobType *int64 `json:"JobType,omitempty" name:"JobType"`

	// 集群的类型，1 表示共享集群，2 表示独享集群
	ClusterType *int64 `json:"ClusterType,omitempty" name:"ClusterType"`

	// 当 ClusterType=2 时，必选，用来指定该作业提交的独享集群 ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// 设置每 CU 的内存规格，单位为 GB，支持 2、4、8、16（需申请开通白名单后使用）。默认为 4，即 1 CU 对应 4 GB 的运行内存
	CuMem *uint64 `json:"CuMem,omitempty" name:"CuMem"`

	// 作业的备注信息，可以随意设置
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 作业名所属文件夹ID，根目录为"root"
	FolderId *string `json:"FolderId,omitempty" name:"FolderId"`

	// 作业运行的Flink版本
	FlinkVersion *string `json:"FlinkVersion,omitempty" name:"FlinkVersion"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`

	// 作业标签
	Tags []*Tag `json:"Tags,omitempty" name:"Tags"`
}

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,omitempty" name:"JobId"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type CreateResourceConfigRequest 

type CreateResourceConfigRequest struct {
	*tchttp.BaseRequest

	// 资源ID
	ResourceId *string `json:"ResourceId,omitempty" name:"ResourceId"`

	// 位置信息
	ResourceLoc *ResourceLoc `json:"ResourceLoc,omitempty" name:"ResourceLoc"`

	// 资源描述信息
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 1： 资源版本达到上限，自动删除最早可删除的版本
	AutoDelete *int64 `json:"AutoDelete,omitempty" name:"AutoDelete"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"ResourceId"`

	// 位置信息
	ResourceLoc *ResourceLoc `json:"ResourceLoc,omitempty" name:"ResourceLoc"`

	// 资源描述信息
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 1： 资源版本达到上限，自动删除最早可删除的版本
	AutoDelete *int64 `json:"AutoDelete,omitempty" name:"AutoDelete"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"Version"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type CreateResourceRequest 

type CreateResourceRequest struct {
	*tchttp.BaseRequest

	// 资源位置
	ResourceLoc *ResourceLoc `json:"ResourceLoc,omitempty" name:"ResourceLoc"`

	// 资源类型。目前只支持 JAR，取值为 1
	ResourceType *int64 `json:"ResourceType,omitempty" name:"ResourceType"`

	// 资源描述
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 资源名称
	Name *string `json:"Name,omitempty" name:"Name"`

	// 资源版本描述
	ResourceConfigRemark *string `json:"ResourceConfigRemark,omitempty" name:"ResourceConfigRemark"`

	// 目录ID
	FolderId *string `json:"FolderId,omitempty" name:"FolderId"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"ResourceLoc"`

	// 资源类型。目前只支持 JAR，取值为 1
	ResourceType *int64 `json:"ResourceType,omitempty" name:"ResourceType"`

	// 资源描述
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 资源名称
	Name *string `json:"Name,omitempty" name:"Name"`

	// 资源版本描述
	ResourceConfigRemark *string `json:"ResourceConfigRemark,omitempty" name:"ResourceConfigRemark"`

	// 目录ID
	FolderId *string `json:"FolderId,omitempty" name:"FolderId"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"ResourceId"`

	// 资源版本
	Version *int64 `json:"Version,omitempty" name:"Version"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DeleteJobsRequest added in v1.0.441 

type DeleteJobsRequest struct {
	*tchttp.BaseRequest

	// 作业Id列表
	JobIds []*string `json:"JobIds,omitempty" name:"JobIds"`

	// 工作空间Id
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"JobIds"`

	// 工作空间Id
	WorkSpaceId *string `json:"WorkSpaceId,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 *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DeleteResourceConfigsRequest 

type DeleteResourceConfigsRequest struct {
	*tchttp.BaseRequest

	// 资源ID
	ResourceId *string `json:"ResourceId,omitempty" name:"ResourceId"`

	// 资源版本数组
	ResourceConfigVersions []*int64 `json:"ResourceConfigVersions,omitempty" name:"ResourceConfigVersions"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"ResourceId"`

	// 资源版本数组
	ResourceConfigVersions []*int64 `json:"ResourceConfigVersions,omitempty" name:"ResourceConfigVersions"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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 *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DeleteResourcesRequest 

type DeleteResourcesRequest struct {
	*tchttp.BaseRequest

	// 待删除资源ID列表
	ResourceIds []*string `json:"ResourceIds,omitempty" name:"ResourceIds"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"ResourceIds"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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 *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DeleteTableConfigRequest 

type DeleteTableConfigRequest struct {
	*tchttp.BaseRequest

	// 作业ID
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 调试作业ID
	DebugId *int64 `json:"DebugId,omitempty" name:"DebugId"`

	// 表名
	TableName *string `json:"TableName,omitempty" name:"TableName"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"JobId"`

	// 调试作业ID
	DebugId *int64 `json:"DebugId,omitempty" name:"DebugId"`

	// 表名
	TableName *string `json:"TableName,omitempty" name:"TableName"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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 *string `json:"RequestId,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,omitempty" name:"ClusterIds"`

	// 偏移量，默认 0
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 请求的集群数量，默认 20，最大值 100
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// 集群信息结果排序规则，1 按时间降序，2 按照时间升序，3  按照状态排序
	OrderType *int64 `json:"OrderType,omitempty" name:"OrderType"`

	// 过滤规则
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"ClusterIds"`

	// 偏移量，默认 0
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 请求的集群数量，默认 20，最大值 100
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// 集群信息结果排序规则，1 按时间降序，2 按照时间升序，3  按照状态排序
	OrderType *int64 `json:"OrderType,omitempty" name:"OrderType"`

	// 过滤规则
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"TotalCount"`

	// 集群列表
	ClusterSet []*Cluster `json:"ClusterSet,omitempty" name:"ClusterSet"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DescribeJobConfigsRequest 

type DescribeJobConfigsRequest struct {
	*tchttp.BaseRequest

	// 作业Id
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 作业配置版本
	JobConfigVersions []*uint64 `json:"JobConfigVersions,omitempty" name:"JobConfigVersions"`

	// 偏移量，默认0
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 分页大小，默认20，最大100
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// 过滤条件
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`

	// true 表示只展示草稿
	OnlyDraft *bool `json:"OnlyDraft,omitempty" name:"OnlyDraft"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"JobId"`

	// 作业配置版本
	JobConfigVersions []*uint64 `json:"JobConfigVersions,omitempty" name:"JobConfigVersions"`

	// 偏移量，默认0
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 分页大小，默认20，最大100
	Limit *uint64 `json:"Limit,omitempty" name:"Limit"`

	// 过滤条件
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`

	// true 表示只展示草稿
	OnlyDraft *bool `json:"OnlyDraft,omitempty" name:"OnlyDraft"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"TotalCount"`

	// 作业配置列表
	JobConfigSet []*JobConfig `json:"JobConfigSet,omitempty" name:"JobConfigSet"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DescribeJobSavepointRequest added in v1.0.404 

type DescribeJobSavepointRequest struct {
	*tchttp.BaseRequest

	// 作业 SerialId
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 分页参数，单页总数
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// 分页参数，偏移量
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`
}

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,omitempty" name:"JobId"`

	// 分页参数，单页总数
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// 分页参数，偏移量
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`
}

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,omitempty" name:"TotalNumber"`

	// 快照列表
	// 注意：此字段可能返回 null，表示取不到有效值。
	Savepoint []*Savepoint `json:"Savepoint,omitempty" name:"Savepoint"`

	// 进行中的快照列表
	// 注意：此字段可能返回 null，表示取不到有效值。
	RunningSavepoint []*Savepoint `json:"RunningSavepoint,omitempty" name:"RunningSavepoint"`

	// 进行中的快照列表总数
	// 注意：此字段可能返回 null，表示取不到有效值。
	RunningTotalNumber *int64 `json:"RunningTotalNumber,omitempty" name:"RunningTotalNumber"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,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,omitempty" name:"JobId"`

	// 起始时间，unix时间戳，毫秒级，例如：1611754219108
	StartTime *int64 `json:"StartTime,omitempty" name:"StartTime"`

	// 结束时间，unix时间戳，毫秒级，例如：1611754219108
	EndTime *int64 `json:"EndTime,omitempty" name:"EndTime"`

	// 作业运行的实例ID, 例如：1,2,3。默认为0，表示未选中任何实例，搜索该时间段内最近的一个实例的日志
	RunningOrderId *int64 `json:"RunningOrderId,omitempty" name:"RunningOrderId"`

	// 日志搜索的关键词，默认为空
	Keyword *string `json:"Keyword,omitempty" name:"Keyword"`

	// 日志搜索的游标，可透传上次返回的值，默认为空
	Cursor *string `json:"Cursor,omitempty" name:"Cursor"`

	// 时间戳排序规则，asc - 升序，desc - 降序。默认为升序
	OrderType *string `json:"OrderType,omitempty" name:"OrderType"`

	// 搜索的日志条数上限值，最大为100
	Limit *int64 `json:"Limit,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,omitempty" name:"JobId"`

	// 起始时间，unix时间戳，毫秒级，例如：1611754219108
	StartTime *int64 `json:"StartTime,omitempty" name:"StartTime"`

	// 结束时间，unix时间戳，毫秒级，例如：1611754219108
	EndTime *int64 `json:"EndTime,omitempty" name:"EndTime"`

	// 作业运行的实例ID, 例如：1,2,3。默认为0，表示未选中任何实例，搜索该时间段内最近的一个实例的日志
	RunningOrderId *int64 `json:"RunningOrderId,omitempty" name:"RunningOrderId"`

	// 日志搜索的关键词，默认为空
	Keyword *string `json:"Keyword,omitempty" name:"Keyword"`

	// 日志搜索的游标，可透传上次返回的值，默认为空
	Cursor *string `json:"Cursor,omitempty" name:"Cursor"`

	// 时间戳排序规则，asc - 升序，desc - 降序。默认为升序
	OrderType *string `json:"OrderType,omitempty" name:"OrderType"`

	// 搜索的日志条数上限值，最大为100
	Limit *int64 `json:"Limit,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,omitempty" name:"Cursor"`

	// 是否返回了所有的日志记录
	ListOver *bool `json:"ListOver,omitempty" name:"ListOver"`

	// 作业启动的requestId
	// 注意：此字段可能返回 null，表示取不到有效值。
	JobRequestId *string `json:"JobRequestId,omitempty" name:"JobRequestId"`

	// 该时间段内符合关键字的所有的作业实例列表
	// 注意：此字段可能返回 null，表示取不到有效值。
	JobInstanceList []*JobInstanceForSubmissionLog `json:"JobInstanceList,omitempty" name:"JobInstanceList"`

	// 废弃，请使用LogContentList
	// 注意：此字段可能返回 null，表示取不到有效值。
	LogList []*string `json:"LogList,omitempty" name:"LogList"`

	// 日志列表
	// 注意：此字段可能返回 null，表示取不到有效值。
	LogContentList []*LogContent `json:"LogContentList,omitempty" name:"LogContentList"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,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,omitempty" name:"JobIds"`

	// 过滤条件，支持的 Filter.Name 为：作业名 Name、作业状态 Status、所属集群 ClusterId、作业id JobId、集群名称 ClusterName。 每次请求的 Filters 个数的上限为 5，Filter.Values 的个数上限为 5。参数不支持同时指定 JobIds 和 Filters。
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`

	// 偏移量，默认为0
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 分页大小，默认为20，最大值为100
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`
}

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,omitempty" name:"JobIds"`

	// 过滤条件，支持的 Filter.Name 为：作业名 Name、作业状态 Status、所属集群 ClusterId、作业id JobId、集群名称 ClusterName。 每次请求的 Filters 个数的上限为 5，Filter.Values 的个数上限为 5。参数不支持同时指定 JobIds 和 Filters。
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`

	// 偏移量，默认为0
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 分页大小，默认为20，最大值为100
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`
}

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,omitempty" name:"TotalCount"`

	// 作业列表
	JobSet []*JobV1 `json:"JobSet,omitempty" name:"JobSet"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DescribeResourceConfigsRequest 

type DescribeResourceConfigsRequest struct {
	*tchttp.BaseRequest

	// 资源ID
	ResourceId *string `json:"ResourceId,omitempty" name:"ResourceId"`

	// 偏移量，仅当设置 Limit 时该参数有效
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 返回值大小，不填则返回全量数据
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// 资源配置Versions集合
	ResourceConfigVersions []*int64 `json:"ResourceConfigVersions,omitempty" name:"ResourceConfigVersions"`

	// 作业配置版本
	JobConfigVersion *int64 `json:"JobConfigVersion,omitempty" name:"JobConfigVersion"`

	// 作业ID
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"ResourceId"`

	// 偏移量，仅当设置 Limit 时该参数有效
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 返回值大小，不填则返回全量数据
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// 资源配置Versions集合
	ResourceConfigVersions []*int64 `json:"ResourceConfigVersions,omitempty" name:"ResourceConfigVersions"`

	// 作业配置版本
	JobConfigVersion *int64 `json:"JobConfigVersion,omitempty" name:"JobConfigVersion"`

	// 作业ID
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"ResourceConfigSet"`

	// 资源配置数量
	TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DescribeResourceRelatedJobsRequest 

type DescribeResourceRelatedJobsRequest struct {
	*tchttp.BaseRequest

	// 资源ID
	ResourceId *string `json:"ResourceId,omitempty" name:"ResourceId"`

	// 默认0;   1： 按照作业版本创建时间降序
	DESCByJobConfigCreateTime *int64 `json:"DESCByJobConfigCreateTime,omitempty" name:"DESCByJobConfigCreateTime"`

	// 偏移量，默认为0
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 分页大小，默认为20，最大值为100
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// 资源版本号
	ResourceConfigVersion *int64 `json:"ResourceConfigVersion,omitempty" name:"ResourceConfigVersion"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"ResourceId"`

	// 默认0;   1： 按照作业版本创建时间降序
	DESCByJobConfigCreateTime *int64 `json:"DESCByJobConfigCreateTime,omitempty" name:"DESCByJobConfigCreateTime"`

	// 偏移量，默认为0
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 分页大小，默认为20，最大值为100
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// 资源版本号
	ResourceConfigVersion *int64 `json:"ResourceConfigVersion,omitempty" name:"ResourceConfigVersion"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"TotalCount"`

	// 关联作业信息
	RefJobInfos []*ResourceRefJobInfo `json:"RefJobInfos,omitempty" name:"RefJobInfos"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DescribeResourcesRequest 

type DescribeResourcesRequest struct {
	*tchttp.BaseRequest

	// 需要查询的资源ID数组，数量不超过100个。如果填写了该参数则忽略Filters参数。
	ResourceIds []*string `json:"ResourceIds,omitempty" name:"ResourceIds"`

	// 偏移量，仅当设置 Limit 参数时有效
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 条数限制。如果不填，默认返回 20 条
	Limit *int64 `json:"Limit,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,omitempty" name:"Filters"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"ResourceIds"`

	// 偏移量，仅当设置 Limit 参数时有效
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 条数限制。如果不填，默认返回 20 条
	Limit *int64 `json:"Limit,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,omitempty" name:"Filters"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"ResourceSet"`

	// 总数量
	TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DescribeSystemResourcesRequest 

type DescribeSystemResourcesRequest struct {
	*tchttp.BaseRequest

	// 需要查询的资源ID数组
	ResourceIds []*string `json:"ResourceIds,omitempty" name:"ResourceIds"`

	// 偏移量，仅当设置 Limit 参数时有效
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 条数限制，默认返回 20 条
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// 查询资源配置列表， 如果不填写，返回该 ResourceIds.N 下所有作业配置列表
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`

	// 集群ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// 查询对应Flink版本的内置connector
	FlinkVersion *string `json:"FlinkVersion,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,omitempty" name:"ResourceIds"`

	// 偏移量，仅当设置 Limit 参数时有效
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 条数限制，默认返回 20 条
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// 查询资源配置列表， 如果不填写，返回该 ResourceIds.N 下所有作业配置列表
	Filters []*Filter `json:"Filters,omitempty" name:"Filters"`

	// 集群ID
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// 查询对应Flink版本的内置connector
	FlinkVersion *string `json:"FlinkVersion,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,omitempty" name:"ResourceSet"`

	// 总数量
	TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DescribeTreeJobsRequest added in v1.0.441 

type DescribeTreeJobsRequest struct {
	*tchttp.BaseRequest

	// 工作空间 Serialid
	WorkSpaceId *string `json:"WorkSpaceId,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 {
	// 工作空间 Serialid
	WorkSpaceId *string `json:"WorkSpaceId,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，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DescribeTreeResourcesRequest added in v1.0.482 

type DescribeTreeResourcesRequest struct {
	*tchttp.BaseRequest

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`
}

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 {
	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`
}

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,omitempty" name:"ParentId"`

	// 文件夹ID
	// 注意：此字段可能返回 null，表示取不到有效值。
	Id *string `json:"Id,omitempty" name:"Id"`

	// 文件夹名
	// 注意：此字段可能返回 null，表示取不到有效值。
	Name *string `json:"Name,omitempty" name:"Name"`

	// 文件列表
	// 注意：此字段可能返回 null，表示取不到有效值。
	Items []*TreeResourceItem `json:"Items,omitempty" name:"Items"`

	// 子目录列表
	// 注意：此字段可能返回 null，表示取不到有效值。
	Children []*DescribeTreeResourcesRsp `json:"Children,omitempty" name:"Children"`

	// 资源总数
	// 注意：此字段可能返回 null，表示取不到有效值。
	TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type DescribeTreeResourcesRsp added in v1.0.599 

type DescribeTreeResourcesRsp struct {
	// 父节点ID
	ParentId *string `json:"ParentId,omitempty" name:"ParentId"`

	// 文件夹ID
	Id *string `json:"Id,omitempty" name:"Id"`

	// 文件夹名称
	Name *string `json:"Name,omitempty" name:"Name"`

	// 文件夹下资源数字
	// 注意：此字段可能返回 null，表示取不到有效值。
	Items []*TreeResourceItem `json:"Items,omitempty" name:"Items"`

	// 子节点
	// 注意：此字段可能返回 null，表示取不到有效值。
	Children []*DescribeTreeResourcesRsp `json:"Children,omitempty" name:"Children"`

	// 资源总数
	// 注意：此字段可能返回 null，表示取不到有效值。
	TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`
}

type DescribeWorkSpacesRequest added in v1.0.683 

type DescribeWorkSpacesRequest struct {
	*tchttp.BaseRequest

	// 偏移量，默认 0
	Offset *int64 `json:"Offset,omitempty" name:"Offset"`

	// 1 按照创建时间降序排序(默认) 2.按照创建时间升序排序，3. 按照状态降序排序 4. 按照状态升序排序 默认为0
	OrderType *int64 `json:"OrderType,omitempty" name:"OrderType"`

	// 请求的集群数量，默认 20
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// 过滤规则
	Filters []*Filter `json:"Filters,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,omitempty" name:"Offset"`

	// 1 按照创建时间降序排序(默认) 2.按照创建时间升序排序，3. 按照状态降序排序 4. 按照状态升序排序 默认为0
	OrderType *int64 `json:"OrderType,omitempty" name:"OrderType"`

	// 请求的集群数量，默认 20
	Limit *int64 `json:"Limit,omitempty" name:"Limit"`

	// 过滤规则
	Filters []*Filter `json:"Filters,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,omitempty" name:"WorkSpaceSetItem"`

	// 空间总数
	TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type ExpertModeConfiguration added in v1.0.712 

type ExpertModeConfiguration struct {
	// Job graph
	// 注意：此字段可能返回 null，表示取不到有效值。
	JobGraph *JobGraph `json:"JobGraph,omitempty" name:"JobGraph"`

	// Node configuration
	// 注意：此字段可能返回 null，表示取不到有效值。
	NodeConfig []*NodeConfig `json:"NodeConfig,omitempty" name:"NodeConfig"`

	// Slot sharing groups
	// 注意：此字段可能返回 null，表示取不到有效值。
	SlotSharingGroups []*SlotSharingGroup `json:"SlotSharingGroups,omitempty" name:"SlotSharingGroups"`
}

type Filter 

type Filter struct {
	// 要过滤的字段
	Name *string `json:"Name,omitempty" name:"Name"`

	// 字段的过滤值
	Values []*string `json:"Values,omitempty" name:"Values"`
}

type JobConfig 

type JobConfig struct {
	// 作业Id
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 主类
	// 注意：此字段可能返回 null，表示取不到有效值。
	EntrypointClass *string `json:"EntrypointClass,omitempty" name:"EntrypointClass"`

	// 主类入参
	// 注意：此字段可能返回 null，表示取不到有效值。
	ProgramArgs *string `json:"ProgramArgs,omitempty" name:"ProgramArgs"`

	// 备注
	// 注意：此字段可能返回 null，表示取不到有效值。
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 作业配置创建时间
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// 作业配置的版本号
	Version *int64 `json:"Version,omitempty" name:"Version"`

	// 作业默认并行度
	// 注意：此字段可能返回 null，表示取不到有效值。
	DefaultParallelism *uint64 `json:"DefaultParallelism,omitempty" name:"DefaultParallelism"`

	// 系统参数
	// 注意：此字段可能返回 null，表示取不到有效值。
	Properties []*Property `json:"Properties,omitempty" name:"Properties"`

	// 引用资源
	// 注意：此字段可能返回 null，表示取不到有效值。
	ResourceRefDetails []*ResourceRefDetail `json:"ResourceRefDetails,omitempty" name:"ResourceRefDetails"`

	// 创建者uin
	// 注意：此字段可能返回 null，表示取不到有效值。
	CreatorUin *string `json:"CreatorUin,omitempty" name:"CreatorUin"`

	// 作业配置上次启动时间
	// 注意：此字段可能返回 null，表示取不到有效值。
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`

	// 作业绑定的存储桶
	// 注意：此字段可能返回 null，表示取不到有效值。
	COSBucket *string `json:"COSBucket,omitempty" name:"COSBucket"`

	// 是否启用日志收集，0-未启用，1-已启用，2-历史集群未设置日志集，3-历史集群已开启
	// 注意：此字段可能返回 null，表示取不到有效值。
	LogCollect *int64 `json:"LogCollect,omitempty" name:"LogCollect"`

	// 作业的最大并行度
	// 注意：此字段可能返回 null，表示取不到有效值。
	MaxParallelism *uint64 `json:"MaxParallelism,omitempty" name:"MaxParallelism"`

	// JobManager规格
	// 注意：此字段可能返回 null，表示取不到有效值。
	JobManagerSpec *float64 `json:"JobManagerSpec,omitempty" name:"JobManagerSpec"`

	// TaskManager规格
	// 注意：此字段可能返回 null，表示取不到有效值。
	TaskManagerSpec *float64 `json:"TaskManagerSpec,omitempty" name:"TaskManagerSpec"`

	// CLS日志集ID
	// 注意：此字段可能返回 null，表示取不到有效值。
	ClsLogsetId *string `json:"ClsLogsetId,omitempty" name:"ClsLogsetId"`

	// CLS日志主题ID
	// 注意：此字段可能返回 null，表示取不到有效值。
	ClsTopicId *string `json:"ClsTopicId,omitempty" name:"ClsTopicId"`

	// pyflink作业运行的python版本
	// 注意：此字段可能返回 null，表示取不到有效值。
	PythonVersion *string `json:"PythonVersion,omitempty" name:"PythonVersion"`

	// Oceanus 平台恢复作业开关 1:开启 -1: 关闭
	// 注意：此字段可能返回 null，表示取不到有效值。
	AutoRecover *int64 `json:"AutoRecover,omitempty" name:"AutoRecover"`

	// 日志级别
	// 注意：此字段可能返回 null，表示取不到有效值。
	LogLevel *string `json:"LogLevel,omitempty" name:"LogLevel"`

	// 类日志级别
	// 注意：此字段可能返回 null，表示取不到有效值。
	ClazzLevels []*ClazzLevel `json:"ClazzLevels,omitempty" name:"ClazzLevels"`

	// 是否开启专家模式
	// 注意：此字段可能返回 null，表示取不到有效值。
	ExpertModeOn *bool `json:"ExpertModeOn,omitempty" name:"ExpertModeOn"`

	// 专家模式的配置
	// 注意：此字段可能返回 null，表示取不到有效值。
	ExpertModeConfiguration *ExpertModeConfiguration `json:"ExpertModeConfiguration,omitempty" name:"ExpertModeConfiguration"`
}

type JobGraph added in v1.0.712 

type JobGraph struct {
	// 运行图的点集合
	// 注意：此字段可能返回 null，表示取不到有效值。
	Nodes []*JobGraphNode `json:"Nodes,omitempty" name:"Nodes"`

	// 运行图的边集合
	// 注意：此字段可能返回 null，表示取不到有效值。
	Edges []*JobGraphEdge `json:"Edges,omitempty" name:"Edges"`
}

type JobGraphEdge added in v1.0.712 

type JobGraphEdge struct {
	// 边的起始节点ID
	// 注意：此字段可能返回 null，表示取不到有效值。
	Source *int64 `json:"Source,omitempty" name:"Source"`

	// 边的目标节点ID
	// 注意：此字段可能返回 null，表示取不到有效值。
	Target *int64 `json:"Target,omitempty" name:"Target"`
}

type JobGraphNode added in v1.0.712 

type JobGraphNode struct {
	// 节点ID
	// 注意：此字段可能返回 null，表示取不到有效值。
	Id *int64 `json:"Id,omitempty" name:"Id"`

	// 节点描述
	// 注意：此字段可能返回 null，表示取不到有效值。
	Description *string `json:"Description,omitempty" name:"Description"`

	// 节点名称
	// 注意：此字段可能返回 null，表示取不到有效值。
	Name *string `json:"Name,omitempty" name:"Name"`

	// 节点并行度
	// 注意：此字段可能返回 null，表示取不到有效值。
	Parallelism *int64 `json:"Parallelism,omitempty" name:"Parallelism"`
}

type JobInstanceForSubmissionLog added in v1.0.702 

type JobInstanceForSubmissionLog struct {
	// 实例的Id, 按照启动的时间顺序，从1开始
	RunningOrderId *int64 `json:"RunningOrderId,omitempty" name:"RunningOrderId"`

	// 作业实例的启动时间
	JobInstanceStartTime *string `json:"JobInstanceStartTime,omitempty" name:"JobInstanceStartTime"`

	// 作业实例启动的时间（毫秒）
	StartingMillis *int64 `json:"StartingMillis,omitempty" name:"StartingMillis"`
}

type JobV1 

type JobV1 struct {
	// 作业ID
	// 注意：此字段可能返回 null，表示取不到有效值。
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 地域
	// 注意：此字段可能返回 null，表示取不到有效值。
	Region *string `json:"Region,omitempty" name:"Region"`

	// 可用区
	// 注意：此字段可能返回 null，表示取不到有效值。
	Zone *string `json:"Zone,omitempty" name:"Zone"`

	// 用户AppId
	// 注意：此字段可能返回 null，表示取不到有效值。
	AppId *int64 `json:"AppId,omitempty" name:"AppId"`

	// 用户UIN
	// 注意：此字段可能返回 null，表示取不到有效值。
	OwnerUin *string `json:"OwnerUin,omitempty" name:"OwnerUin"`

	// 创建者UIN
	// 注意：此字段可能返回 null，表示取不到有效值。
	CreatorUin *string `json:"CreatorUin,omitempty" name:"CreatorUin"`

	// 作业名字
	// 注意：此字段可能返回 null，表示取不到有效值。
	Name *string `json:"Name,omitempty" name:"Name"`

	// 作业类型，1：sql作业，2：Jar作业
	// 注意：此字段可能返回 null，表示取不到有效值。
	JobType *int64 `json:"JobType,omitempty" name:"JobType"`

	// 作业状态，1：未初始化，2：未发布，3：操作中，4：运行中，5：停止，6：暂停，-1：故障
	// 注意：此字段可能返回 null，表示取不到有效值。
	Status *int64 `json:"Status,omitempty" name:"Status"`

	// 作业创建时间
	// 注意：此字段可能返回 null，表示取不到有效值。
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// 作业启动时间
	// 注意：此字段可能返回 null，表示取不到有效值。
	StartTime *string `json:"StartTime,omitempty" name:"StartTime"`

	// 作业停止时间
	// 注意：此字段可能返回 null，表示取不到有效值。
	StopTime *string `json:"StopTime,omitempty" name:"StopTime"`

	// 作业更新时间
	// 注意：此字段可能返回 null，表示取不到有效值。
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`

	// 作业累计运行时间
	// 注意：此字段可能返回 null，表示取不到有效值。
	TotalRunMillis *int64 `json:"TotalRunMillis,omitempty" name:"TotalRunMillis"`

	// 备注信息
	// 注意：此字段可能返回 null，表示取不到有效值。
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 操作错误提示信息
	// 注意：此字段可能返回 null，表示取不到有效值。
	LastOpResult *string `json:"LastOpResult,omitempty" name:"LastOpResult"`

	// 集群名字
	// 注意：此字段可能返回 null，表示取不到有效值。
	ClusterName *string `json:"ClusterName,omitempty" name:"ClusterName"`

	// 最新配置版本号
	// 注意：此字段可能返回 null，表示取不到有效值。
	LatestJobConfigVersion *int64 `json:"LatestJobConfigVersion,omitempty" name:"LatestJobConfigVersion"`

	// 已发布的配置版本
	// 注意：此字段可能返回 null，表示取不到有效值。
	PublishedJobConfigVersion *int64 `json:"PublishedJobConfigVersion,omitempty" name:"PublishedJobConfigVersion"`

	// 运行的CU数量
	// 注意：此字段可能返回 null，表示取不到有效值。
	RunningCuNum *int64 `json:"RunningCuNum,omitempty" name:"RunningCuNum"`

	// 作业内存规格
	// 注意：此字段可能返回 null，表示取不到有效值。
	CuMem *int64 `json:"CuMem,omitempty" name:"CuMem"`

	// 作业状态描述
	// 注意：此字段可能返回 null，表示取不到有效值。
	StatusDesc *string `json:"StatusDesc,omitempty" name:"StatusDesc"`

	// 运行状态时表示单次运行时间
	// 注意：此字段可能返回 null，表示取不到有效值。
	CurrentRunMillis *int64 `json:"CurrentRunMillis,omitempty" name:"CurrentRunMillis"`

	// 作业所在的集群ID
	// 注意：此字段可能返回 null，表示取不到有效值。
	ClusterId *string `json:"ClusterId,omitempty" name:"ClusterId"`

	// 作业管理WEB UI 入口
	// 注意：此字段可能返回 null，表示取不到有效值。
	WebUIUrl *string `json:"WebUIUrl,omitempty" name:"WebUIUrl"`

	// 作业所在集群类型
	// 注意：此字段可能返回 null，表示取不到有效值。
	SchedulerType *int64 `json:"SchedulerType,omitempty" name:"SchedulerType"`

	// 作业所在集群状态
	// 注意：此字段可能返回 null，表示取不到有效值。
	ClusterStatus *int64 `json:"ClusterStatus,omitempty" name:"ClusterStatus"`

	// 细粒度下的运行的CU数量
	// 注意：此字段可能返回 null，表示取不到有效值。
	RunningCu *float64 `json:"RunningCu,omitempty" name:"RunningCu"`

	// 作业运行的 Flink 版本
	// 注意：此字段可能返回 null，表示取不到有效值。
	FlinkVersion *string `json:"FlinkVersion,omitempty" name:"FlinkVersion"`

	// 工作空间 SerialId
	// 注意：此字段可能返回 null，表示取不到有效值。
	WorkSpaceId *string `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`

	// 工作空间名称
	// 注意：此字段可能返回 null，表示取不到有效值。
	WorkSpaceName *string `json:"WorkSpaceName,omitempty" name:"WorkSpaceName"`

	// 作业标签
	// 注意：此字段可能返回 null，表示取不到有效值。
	Tags []*Tag `json:"Tags,omitempty" name:"Tags"`
}

type LogContent added in v1.0.702 

type LogContent struct {
	// 日志内容
	// 注意：此字段可能返回 null，表示取不到有效值。
	Log *string `json:"Log,omitempty" name:"Log"`

	// 毫秒级时间戳
	// 注意：此字段可能返回 null，表示取不到有效值。
	Time *int64 `json:"Time,omitempty" name:"Time"`

	// 日志组Id
	// 注意：此字段可能返回 null，表示取不到有效值。
	PkgId *string `json:"PkgId,omitempty" name:"PkgId"`

	// 日志Id，在日志组范围里唯一
	PkgLogId *int64 `json:"PkgLogId,omitempty" name:"PkgLogId"`

	// 日志所属的容器名
	// 注意：此字段可能返回 null，表示取不到有效值。
	ContainerName *string `json:"ContainerName,omitempty" name:"ContainerName"`
}

type ModifyJobRequest added in v1.0.420 

type ModifyJobRequest struct {
	*tchttp.BaseRequest

	// 作业Id
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 作业名称，支持长度小于50的中文/英文/数字/”-”/”_”/”.”，不能重名
	Name *string `json:"Name,omitempty" name:"Name"`

	// 描述
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 拖拽文件需传入此参数
	TargetFolderId *string `json:"TargetFolderId,omitempty" name:"TargetFolderId"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`
}

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,omitempty" name:"JobId"`

	// 作业名称，支持长度小于50的中文/英文/数字/”-”/”_”/”.”，不能重名
	Name *string `json:"Name,omitempty" name:"Name"`

	// 描述
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 拖拽文件需传入此参数
	TargetFolderId *string `json:"TargetFolderId,omitempty" name:"TargetFolderId"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`
}

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 *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type NodeConfig added in v1.0.712 

type NodeConfig struct {
	// Node ID
	// 注意：此字段可能返回 null，表示取不到有效值。
	Id *int64 `json:"Id,omitempty" name:"Id"`

	// Node parallelism
	// 注意：此字段可能返回 null，表示取不到有效值。
	Parallelism *int64 `json:"Parallelism,omitempty" name:"Parallelism"`

	// Slot sharing group
	// 注意：此字段可能返回 null，表示取不到有效值。
	SlotSharingGroup *string `json:"SlotSharingGroup,omitempty" name:"SlotSharingGroup"`

	// Configuration properties
	// 注意：此字段可能返回 null，表示取不到有效值。
	Configuration []*Property `json:"Configuration,omitempty" name:"Configuration"`

	// 节点的状态ttl配置, 多个用 ; 分割
	// 注意：此字段可能返回 null，表示取不到有效值。
	StateTTL *string `json:"StateTTL,omitempty" name:"StateTTL"`
}

type Property 

type Property struct {
	// 系统配置的Key
	Key *string `json:"Key,omitempty" name:"Key"`

	// 系统配置的Value
	Value *string `json:"Value,omitempty" name:"Value"`
}

type RefJobStatusCountItem added in v1.0.612 

type RefJobStatusCountItem struct {
	// 作业状态
	// 注意：此字段可能返回 null，表示取不到有效值。
	JobStatus *int64 `json:"JobStatus,omitempty" name:"JobStatus"`

	// 作业数量
	// 注意：此字段可能返回 null，表示取不到有效值。
	Count *int64 `json:"Count,omitempty" name:"Count"`
}

type ResourceConfigItem 

type ResourceConfigItem struct {
	// 资源ID
	ResourceId *string `json:"ResourceId,omitempty" name:"ResourceId"`

	// 资源类型
	ResourceType *int64 `json:"ResourceType,omitempty" name:"ResourceType"`

	// 资源所属地域
	Region *string `json:"Region,omitempty" name:"Region"`

	// 资源所属AppId
	AppId *int64 `json:"AppId,omitempty" name:"AppId"`

	// 主账号Uin
	OwnerUin *string `json:"OwnerUin,omitempty" name:"OwnerUin"`

	// 子账号Uin
	CreatorUin *string `json:"CreatorUin,omitempty" name:"CreatorUin"`

	// 资源位置描述
	ResourceLoc *ResourceLoc `json:"ResourceLoc,omitempty" name:"ResourceLoc"`

	// 资源创建时间
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// 资源版本
	Version *int64 `json:"Version,omitempty" name:"Version"`

	// 资源描述
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 资源状态：0: 资源同步中，1:资源已就绪
	// 注意：此字段可能返回 null，表示取不到有效值。
	Status *int64 `json:"Status,omitempty" name:"Status"`

	// 关联作业个数
	// 注意：此字段可能返回 null，表示取不到有效值。
	RefJobCount *int64 `json:"RefJobCount,omitempty" name:"RefJobCount"`

	// 分状态统计关联作业数
	// 注意：此字段可能返回 null，表示取不到有效值。
	RefJobStatusCountSet []*RefJobStatusCountItem `json:"RefJobStatusCountSet,omitempty" name:"RefJobStatusCountSet"`
}

type ResourceItem 

type ResourceItem struct {
	// 资源ID
	ResourceId *string `json:"ResourceId,omitempty" name:"ResourceId"`

	// 资源名称
	Name *string `json:"Name,omitempty" name:"Name"`

	// 资源类型
	ResourceType *uint64 `json:"ResourceType,omitempty" name:"ResourceType"`

	// 资源位置
	ResourceLoc *ResourceLoc `json:"ResourceLoc,omitempty" name:"ResourceLoc"`

	// 资源地域
	Region *string `json:"Region,omitempty" name:"Region"`

	// 应用ID
	AppId *uint64 `json:"AppId,omitempty" name:"AppId"`

	// 主账号Uin
	OwnerUin *string `json:"OwnerUin,omitempty" name:"OwnerUin"`

	// 子账号Uin
	CreatorUin *string `json:"CreatorUin,omitempty" name:"CreatorUin"`

	// 资源创建时间
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// 资源最后更新时间
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`

	// 资源的资源版本ID
	LatestResourceConfigVersion *int64 `json:"LatestResourceConfigVersion,omitempty" name:"LatestResourceConfigVersion"`

	// 资源备注
	// 注意：此字段可能返回 null，表示取不到有效值。
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 版本个数
	// 注意：此字段可能返回 null，表示取不到有效值。
	VersionCount *int64 `json:"VersionCount,omitempty" name:"VersionCount"`

	// 关联作业数
	// 注意：此字段可能返回 null，表示取不到有效值。
	RefJobCount *int64 `json:"RefJobCount,omitempty" name:"RefJobCount"`

	// 作业运行状态
	// 注意：此字段可能返回 null，表示取不到有效值。
	IsJobRun *int64 `json:"IsJobRun,omitempty" name:"IsJobRun"`

	// 文件名
	// 注意：此字段可能返回 null，表示取不到有效值。
	FileName *string `json:"FileName,omitempty" name:"FileName"`

	// 工作空间ID
	// 注意：此字段可能返回 null，表示取不到有效值。
	WorkSpaceId *int64 `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`

	// 分状态统计关联作业数
	// 注意：此字段可能返回 null，表示取不到有效值。
	RefJobStatusCountSet []*RefJobStatusCountItem `json:"RefJobStatusCountSet,omitempty" name:"RefJobStatusCountSet"`
}

type ResourceLoc 

type ResourceLoc struct {
	// 资源位置的存储类型，目前只支持1:COS
	StorageType *int64 `json:"StorageType,omitempty" name:"StorageType"`

	// 描述资源位置的json
	Param *ResourceLocParam `json:"Param,omitempty" name:"Param"`
}

type ResourceLocParam 

type ResourceLocParam struct {
	// 资源bucket
	Bucket *string `json:"Bucket,omitempty" name:"Bucket"`

	// 资源路径
	Path *string `json:"Path,omitempty" name:"Path"`

	// 资源所在地域，如果不填，则使用Resource的Region
	// 注意：此字段可能返回 null，表示取不到有效值。
	Region *string `json:"Region,omitempty" name:"Region"`
}

type ResourceRef 

type ResourceRef struct {
	// 资源ID
	ResourceId *string `json:"ResourceId,omitempty" name:"ResourceId"`

	// 资源版本ID，-1表示使用最新版本
	Version *int64 `json:"Version,omitempty" name:"Version"`

	// 引用资源类型，例如主资源设置为1，代表main class所在的jar包
	Type *int64 `json:"Type,omitempty" name:"Type"`
}

type ResourceRefDetail 

type ResourceRefDetail struct {
	// 资源id
	ResourceId *string `json:"ResourceId,omitempty" name:"ResourceId"`

	// 资源版本，-1表示使用最新版本
	Version *int64 `json:"Version,omitempty" name:"Version"`

	// 资源名称
	Name *string `json:"Name,omitempty" name:"Name"`

	// 1: 主资源
	Type *int64 `json:"Type,omitempty" name:"Type"`

	// 1: 系统内置资源
	SystemProvide *int64 `json:"SystemProvide,omitempty" name:"SystemProvide"`
}

type ResourceRefJobInfo 

type ResourceRefJobInfo struct {
	// Job id
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// Job配置版本
	JobConfigVersion *int64 `json:"JobConfigVersion,omitempty" name:"JobConfigVersion"`

	// 资源版本
	ResourceVersion *int64 `json:"ResourceVersion,omitempty" name:"ResourceVersion"`
}

type RoleAuth added in v1.0.683 

type RoleAuth struct {
	// 用户 AppID
	AppId *int64 `json:"AppId,omitempty" name:"AppId"`

	// 工作空间 SerialId
	WorkSpaceSerialId *string `json:"WorkSpaceSerialId,omitempty" name:"WorkSpaceSerialId"`

	// 主账号 UIN
	OwnerUin *string `json:"OwnerUin,omitempty" name:"OwnerUin"`

	// 创建者 UIN
	CreatorUin *string `json:"CreatorUin,omitempty" name:"CreatorUin"`

	// 绑定授权的 UIN
	AuthSubAccountUin *string `json:"AuthSubAccountUin,omitempty" name:"AuthSubAccountUin"`

	// 对应 role表的id
	Permission *int64 `json:"Permission,omitempty" name:"Permission"`

	// 创建时间
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// 最后一次操作时间
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`

	// 2 启用 1 停用
	Status *int64 `json:"Status,omitempty" name:"Status"`

	// id
	// 注意：此字段可能返回 null，表示取不到有效值。
	Id *int64 `json:"Id,omitempty" name:"Id"`

	// 工作空间id
	// 注意：此字段可能返回 null，表示取不到有效值。
	WorkSpaceId *int64 `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`

	// 权限名称
	// 注意：此字段可能返回 null，表示取不到有效值。
	RoleName *string `json:"RoleName,omitempty" name:"RoleName"`
}

type RunJobDescription 

type RunJobDescription struct {
	// 作业Id
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 运行类型，1：启动，2：恢复
	RunType *int64 `json:"RunType,omitempty" name:"RunType"`

	// 兼容旧版 SQL 类型作业启动参数：指定数据源消费起始时间点（例:T1557394288000）
	StartMode *string `json:"StartMode,omitempty" name:"StartMode"`

	// 当前作业的某个版本
	JobConfigVersion *uint64 `json:"JobConfigVersion,omitempty" name:"JobConfigVersion"`

	// Savepoint路径
	SavepointPath *string `json:"SavepointPath,omitempty" name:"SavepointPath"`

	// Savepoint的Id
	SavepointId *string `json:"SavepointId,omitempty" name:"SavepointId"`

	// 使用历史版本系统依赖
	UseOldSystemConnector *bool `json:"UseOldSystemConnector,omitempty" name:"UseOldSystemConnector"`
}

type RunJobsRequest 

type RunJobsRequest struct {
	*tchttp.BaseRequest

	// 批量启动作业的描述信息
	RunJobDescriptions []*RunJobDescription `json:"RunJobDescriptions,omitempty" name:"RunJobDescriptions"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"RunJobDescriptions"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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 *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type Savepoint added in v1.0.404 

type Savepoint struct {
	// 主键
	// 注意：此字段可能返回 null，表示取不到有效值。
	Id *int64 `json:"Id,omitempty" name:"Id"`

	// 版本号
	// 注意：此字段可能返回 null，表示取不到有效值。
	VersionId *int64 `json:"VersionId,omitempty" name:"VersionId"`

	// 状态 1: Active; 2: Expired; 3: InProgress; 4: Failed; 5: Timeout
	// 注意：此字段可能返回 null，表示取不到有效值。
	Status *int64 `json:"Status,omitempty" name:"Status"`

	// 创建时间
	// 注意：此字段可能返回 null，表示取不到有效值。
	CreateTime *int64 `json:"CreateTime,omitempty" name:"CreateTime"`

	// 更新时间
	// 注意：此字段可能返回 null，表示取不到有效值。
	UpdateTime *int64 `json:"UpdateTime,omitempty" name:"UpdateTime"`

	// 路径
	// 注意：此字段可能返回 null，表示取不到有效值。
	Path *string `json:"Path,omitempty" name:"Path"`

	// 大小
	// 注意：此字段可能返回 null，表示取不到有效值。
	Size *int64 `json:"Size,omitempty" name:"Size"`

	// 快照类型 1: savepoint；2: checkpoint；3: cancelWithSavepoint
	// 注意：此字段可能返回 null，表示取不到有效值。
	RecordType *int64 `json:"RecordType,omitempty" name:"RecordType"`

	// 运行作业实例的顺序 ID
	// 注意：此字段可能返回 null，表示取不到有效值。
	JobRuntimeId *int64 `json:"JobRuntimeId,omitempty" name:"JobRuntimeId"`

	// 描述
	// 注意：此字段可能返回 null，表示取不到有效值。
	Description *string `json:"Description,omitempty" name:"Description"`

	// 固定超时时间
	// 注意：此字段可能返回 null，表示取不到有效值。
	Timeout *int64 `json:"Timeout,omitempty" name:"Timeout"`

	// 快照 serialId
	// 注意：此字段可能返回 null，表示取不到有效值。
	SerialId *string `json:"SerialId,omitempty" name:"SerialId"`

	// 耗时
	// 注意：此字段可能返回 null，表示取不到有效值。
	TimeConsuming *int64 `json:"TimeConsuming,omitempty" name:"TimeConsuming"`

	// 快照路径状态 1：可用；2：不可用；
	// 注意：此字段可能返回 null，表示取不到有效值。
	PathStatus *int64 `json:"PathStatus,omitempty" name:"PathStatus"`
}

type SlotSharingGroup added in v1.0.712 

type SlotSharingGroup struct {
	// SlotSharingGroup的名字
	// 注意：此字段可能返回 null，表示取不到有效值。
	Name *string `json:"Name,omitempty" name:"Name"`

	// SlotSharingGroup的规格
	// 注意：此字段可能返回 null，表示取不到有效值。
	Spec *SlotSharingGroupSpec `json:"Spec,omitempty" name:"Spec"`

	// SlotSharingGroup的描述
	// 注意：此字段可能返回 null，表示取不到有效值。
	Description *string `json:"Description,omitempty" name:"Description"`
}

type SlotSharingGroupSpec added in v1.0.712 

type SlotSharingGroupSpec struct {
	// 适用的cpu
	// 注意：此字段可能返回 null，表示取不到有效值。
	CPU *float64 `json:"CPU,omitempty" name:"CPU"`

	// 默认为b, 支持单位有 b, kb, mb, gb
	// 注意：此字段可能返回 null，表示取不到有效值。
	HeapMemory *string `json:"HeapMemory,omitempty" name:"HeapMemory"`

	// 默认为b, 支持单位有 b, kb, mb, gb
	// 注意：此字段可能返回 null，表示取不到有效值。
	OffHeapMemory *string `json:"OffHeapMemory,omitempty" name:"OffHeapMemory"`

	// 默认为b, 支持单位有 b, kb, mb, gb
	// 注意：此字段可能返回 null，表示取不到有效值。
	ManagedMemory *string `json:"ManagedMemory,omitempty" name:"ManagedMemory"`
}

type StopJobDescription 

type StopJobDescription struct {
	// 作业Id
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 停止类型，1 停止 2 暂停
	StopType *int64 `json:"StopType,omitempty" name:"StopType"`
}

type StopJobsRequest 

type StopJobsRequest struct {
	*tchttp.BaseRequest

	// 批量停止作业的描述信息
	StopJobDescriptions []*StopJobDescription `json:"StopJobDescriptions,omitempty" name:"StopJobDescriptions"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"StopJobDescriptions"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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 *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type SystemResourceItem 

type SystemResourceItem struct {
	// 资源ID
	ResourceId *string `json:"ResourceId,omitempty" name:"ResourceId"`

	// 资源名称
	Name *string `json:"Name,omitempty" name:"Name"`

	// 资源类型。1 表示 JAR 包，目前只支持该值。
	ResourceType *int64 `json:"ResourceType,omitempty" name:"ResourceType"`

	// 资源备注
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 资源所属地域
	Region *string `json:"Region,omitempty" name:"Region"`

	// 资源的最新版本
	LatestResourceConfigVersion *int64 `json:"LatestResourceConfigVersion,omitempty" name:"LatestResourceConfigVersion"`
}

type Tag added in v1.0.441 

type Tag struct {
	// 标签键
	// 注意：此字段可能返回 null，表示取不到有效值。
	TagKey *string `json:"TagKey,omitempty" name:"TagKey"`

	// 标签值
	// 注意：此字段可能返回 null，表示取不到有效值。
	TagValue *string `json:"TagValue,omitempty" name:"TagValue"`
}

type TreeResourceItem added in v1.0.599 

type TreeResourceItem struct {
	// 资源ID
	ResourceId *string `json:"ResourceId,omitempty" name:"ResourceId"`

	// 资源名称
	// 注意：此字段可能返回 null，表示取不到有效值。
	Name *string `json:"Name,omitempty" name:"Name"`

	// 资源类型
	ResourceType *int64 `json:"ResourceType,omitempty" name:"ResourceType"`

	// 备注
	// 注意：此字段可能返回 null，表示取不到有效值。
	Remark *string `json:"Remark,omitempty" name:"Remark"`

	// 文件名
	// 注意：此字段可能返回 null，表示取不到有效值。
	FileName *string `json:"FileName,omitempty" name:"FileName"`

	// 目录ID
	// 注意：此字段可能返回 null，表示取不到有效值。
	FolderId *string `json:"FolderId,omitempty" name:"FolderId"`

	// 分状态统计关联作业数
	// 注意：此字段可能返回 null，表示取不到有效值。
	RefJobStatusCountSet []*RefJobStatusCountItem `json:"RefJobStatusCountSet,omitempty" name:"RefJobStatusCountSet"`
}

type TriggerJobSavepointRequest added in v1.0.415 

type TriggerJobSavepointRequest struct {
	*tchttp.BaseRequest

	// 作业 SerialId
	JobId *string `json:"JobId,omitempty" name:"JobId"`

	// 描述
	Description *string `json:"Description,omitempty" name:"Description"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"JobId"`

	// 描述
	Description *string `json:"Description,omitempty" name:"Description"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,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,omitempty" name:"SavepointTrigger"`

	// 错误消息
	// 注意：此字段可能返回 null，表示取不到有效值。
	ErrorMsg *string `json:"ErrorMsg,omitempty" name:"ErrorMsg"`

	// 快照路径
	// 注意：此字段可能返回 null，表示取不到有效值。
	FinalSavepointPath *string `json:"FinalSavepointPath,omitempty" name:"FinalSavepointPath"`

	// 快照 ID
	// 注意：此字段可能返回 null，表示取不到有效值。
	SavepointId *string `json:"SavepointId,omitempty" name:"SavepointId"`

	// 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitempty" name:"RequestId"`
}

Predefined struct for user

type WorkSpaceClusterItem added in v1.0.441 

type WorkSpaceClusterItem struct {
	// 集群 ID
	ClusterGroupId *int64 `json:"ClusterGroupId,omitempty" name:"ClusterGroupId"`

	// 集群 SerialId
	ClusterGroupSerialId *string `json:"ClusterGroupSerialId,omitempty" name:"ClusterGroupSerialId"`

	// 集群名称
	ClusterName *string `json:"ClusterName,omitempty" name:"ClusterName"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`

	// 工作空间名称
	WorkSpaceName *string `json:"WorkSpaceName,omitempty" name:"WorkSpaceName"`

	// 绑定状态  2 绑定 1  解除绑定
	Status *int64 `json:"Status,omitempty" name:"Status"`

	// 项目ID
	ProjectId *int64 `json:"ProjectId,omitempty" name:"ProjectId"`

	// 项目ID string类型
	// 注意：此字段可能返回 null，表示取不到有效值。
	ProjectIdStr *string `json:"ProjectIdStr,omitempty" name:"ProjectIdStr"`
}

type WorkSpaceSetItem added in v1.0.683 

type WorkSpaceSetItem struct {
	// 工作空间 SerialId
	SerialId *string `json:"SerialId,omitempty" name:"SerialId"`

	// 用户 APPID
	AppId *int64 `json:"AppId,omitempty" name:"AppId"`

	// 主账号 UIN
	OwnerUin *string `json:"OwnerUin,omitempty" name:"OwnerUin"`

	// 创建者 UIN
	CreatorUin *string `json:"CreatorUin,omitempty" name:"CreatorUin"`

	// 工作空间名称
	WorkSpaceName *string `json:"WorkSpaceName,omitempty" name:"WorkSpaceName"`

	// 区域
	Region *string `json:"Region,omitempty" name:"Region"`

	// 创建时间
	CreateTime *string `json:"CreateTime,omitempty" name:"CreateTime"`

	// 更新时间
	UpdateTime *string `json:"UpdateTime,omitempty" name:"UpdateTime"`

	// 1 未初始化 2 可用  -1 已删除
	Status *int64 `json:"Status,omitempty" name:"Status"`

	// 工作空间描述
	Description *string `json:"Description,omitempty" name:"Description"`

	// 工作空间包含集群信息
	ClusterGroupSetItem []*ClusterGroupSetItem `json:"ClusterGroupSetItem,omitempty" name:"ClusterGroupSetItem"`

	// 工作空间角色的信息
	RoleAuth []*RoleAuth `json:"RoleAuth,omitempty" name:"RoleAuth"`

	// 工作空间成员数量
	RoleAuthCount *int64 `json:"RoleAuthCount,omitempty" name:"RoleAuthCount"`

	// 工作空间 SerialId
	WorkSpaceId *string `json:"WorkSpaceId,omitempty" name:"WorkSpaceId"`

	// 1
	// 注意：此字段可能返回 null，表示取不到有效值。
	JobsCount *int64 `json:"JobsCount,omitempty" name:"JobsCount"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.