v2

Documentation

Index

• func GenReqDefForBatchDeleteJobs() *def.HttpRequestDef
• func GenReqDefForCancelSql() *def.HttpRequestDef
• func GenReqDefForCreateCluster() *def.HttpRequestDef
• func GenReqDefForCreateExecuteJob() *def.HttpRequestDef
• func GenReqDefForExecuteSql() *def.HttpRequestDef
• func GenReqDefForShowAgencyMapping() *def.HttpRequestDef
• func GenReqDefForShowHdfsFileList() *def.HttpRequestDef
• func GenReqDefForShowJobExeListNew() *def.HttpRequestDef
• func GenReqDefForShowSingleJobExe() *def.HttpRequestDef
• func GenReqDefForShowSqlResult() *def.HttpRequestDef
• func GenReqDefForShowSqlResultWithJob() *def.HttpRequestDef
• func GenReqDefForStopJob() *def.HttpRequestDef
• func GenReqDefForUpdateAgencyMapping() *def.HttpRequestDef
• func MrsClientBuilder() *http_client.HcHttpClientBuilder
• type MrsClient
  • func NewMrsClient(hcClient *http_client.HcHttpClient) *MrsClient
  • func (c *MrsClient) BatchDeleteJobs(request *model.BatchDeleteJobsRequest) (*model.BatchDeleteJobsResponse, error)
  • func (c *MrsClient) CancelSql(request *model.CancelSqlRequest) (*model.CancelSqlResponse, error)
  • func (c *MrsClient) CreateCluster(request *model.CreateClusterRequest) (*model.CreateClusterResponse, error)
  • func (c *MrsClient) CreateExecuteJob(request *model.CreateExecuteJobRequest) (*model.CreateExecuteJobResponse, error)
  • func (c *MrsClient) ExecuteSql(request *model.ExecuteSqlRequest) (*model.ExecuteSqlResponse, error)
  • func (c *MrsClient) ShowAgencyMapping(request *model.ShowAgencyMappingRequest) (*model.ShowAgencyMappingResponse, error)
  • func (c *MrsClient) ShowHdfsFileList(request *model.ShowHdfsFileListRequest) (*model.ShowHdfsFileListResponse, error)
  • func (c *MrsClient) ShowJobExeListNew(request *model.ShowJobExeListNewRequest) (*model.ShowJobExeListNewResponse, error)
  • func (c *MrsClient) ShowSingleJobExe(request *model.ShowSingleJobExeRequest) (*model.ShowSingleJobExeResponse, error)
  • func (c *MrsClient) ShowSqlResult(request *model.ShowSqlResultRequest) (*model.ShowSqlResultResponse, error)
  • func (c *MrsClient) ShowSqlResultWithJob(request *model.ShowSqlResultWithJobRequest) (*model.ShowSqlResultWithJobResponse, error)
  • func (c *MrsClient) StopJob(request *model.StopJobRequest) (*model.StopJobResponse, error)
  • func (c *MrsClient) UpdateAgencyMapping(request *model.UpdateAgencyMappingRequest) (*model.UpdateAgencyMappingResponse, error)

Functions

func GenReqDefForBatchDeleteJobs

func GenReqDefForBatchDeleteJobs() *def.HttpRequestDef

func GenReqDefForCancelSql

func GenReqDefForCancelSql() *def.HttpRequestDef

func GenReqDefForCreateCluster

func GenReqDefForCreateCluster() *def.HttpRequestDef

func GenReqDefForCreateExecuteJob

func GenReqDefForCreateExecuteJob() *def.HttpRequestDef

func GenReqDefForExecuteSql

func GenReqDefForExecuteSql() *def.HttpRequestDef

func GenReqDefForShowAgencyMapping

func GenReqDefForShowAgencyMapping() *def.HttpRequestDef

func GenReqDefForShowHdfsFileList

func GenReqDefForShowHdfsFileList() *def.HttpRequestDef

func GenReqDefForShowJobExeListNew

func GenReqDefForShowJobExeListNew() *def.HttpRequestDef

func GenReqDefForShowSingleJobExe

func GenReqDefForShowSingleJobExe() *def.HttpRequestDef

func GenReqDefForShowSqlResult

func GenReqDefForShowSqlResult() *def.HttpRequestDef

func GenReqDefForShowSqlResultWithJob

func GenReqDefForShowSqlResultWithJob() *def.HttpRequestDef

func GenReqDefForStopJob

func GenReqDefForStopJob() *def.HttpRequestDef

func GenReqDefForUpdateAgencyMapping

func GenReqDefForUpdateAgencyMapping() *def.HttpRequestDef

func MrsClientBuilder

func MrsClientBuilder() *http_client.HcHttpClientBuilder

Types

type MrsClient

type MrsClient struct {
	HcClient *http_client.HcHttpClient
}

func NewMrsClient

func NewMrsClient(hcClient *http_client.HcHttpClient) *MrsClient

func (*MrsClient) BatchDeleteJobs

func (c *MrsClient) BatchDeleteJobs(request *model.BatchDeleteJobsRequest) (*model.BatchDeleteJobsResponse, error)

批量删除作业

在MRS集群中批量删除作业。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*MrsClient) CancelSql

func (c *MrsClient) CancelSql(request *model.CancelSqlRequest) (*model.CancelSqlResponse, error)

取消SQL执行任务

在MRS集群中取消一条SQL的执行任务。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*MrsClient) CreateCluster

func (c *MrsClient) CreateCluster(request *model.CreateClusterRequest) (*model.CreateClusterResponse, error)

创建集群

创建一个MRS集群。

使用接口前，您需要先获取下的资源信息。 - 通过VPC创建或查询VPC、子网 - 通过ECS创建或查询密钥对 - 通过[终端节点](https://support.huaweicloud.com/api-mrs/mrs_02_0003.html)获取区域信息 - 参考[MRS服务支持的组件](https://support.huaweicloud.com/api-mrs/mrs_02_9001.html)获取MRS版本及对应版本支持的组件信息

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*MrsClient) CreateExecuteJob

func (c *MrsClient) CreateExecuteJob(request *model.CreateExecuteJobRequest) (*model.CreateExecuteJobResponse, error)

新增并执行作业

在MRS集群中新增并提交一个作业。

需要先在集群详情页的“概览”页签，单击“IAM用户同步”右侧的“同步”进行IAM用户同步，然后再通过该接口提交作业。

如需使用OBS加密功能，请先参考“MRS用户指南 > 管理现有集群 > 作业管理 > 使用OBS加密数据运行作业”页面进行相关配置后，再调用API接口运行作业。

所有示例中涉及的OBS路径、样例文件及终端节点和AKSK，请提前准备并在提交请求时根据实际情况替换。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*MrsClient) ExecuteSql

func (c *MrsClient) ExecuteSql(request *model.ExecuteSqlRequest) (*model.ExecuteSqlResponse, error)

提交SQL语句

在MRS集群中提交并执行一条SQL语句。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*MrsClient) ShowAgencyMapping

func (c *MrsClient) ShowAgencyMapping(request *model.ShowAgencyMappingRequest) (*model.ShowAgencyMappingResponse, error)

查询用户（组）与IAM委托的映射关系

获取用户（组）与IAM委托之间的映射关系的详细信息。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*MrsClient) ShowHdfsFileList

func (c *MrsClient) ShowHdfsFileList(request *model.ShowHdfsFileListRequest) (*model.ShowHdfsFileListResponse, error)

获取指定目录文件列表

在MRS集群中获取指定目录文件列表。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*MrsClient) ShowJobExeListNew

func (c *MrsClient) ShowJobExeListNew(request *model.ShowJobExeListNewRequest) (*model.ShowJobExeListNewResponse, error)

查询作业列表信息

在MRS指定集群中查询作业列表信息。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*MrsClient) ShowSingleJobExe

func (c *MrsClient) ShowSingleJobExe(request *model.ShowSingleJobExeRequest) (*model.ShowSingleJobExeResponse, error)

查询单个作业信息

在MRS集群中查询指定作业的详细信息。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*MrsClient) ShowSqlResult

func (c *MrsClient) ShowSqlResult(request *model.ShowSqlResultRequest) (*model.ShowSqlResultResponse, error)

查询SQL结果

在MRS集群中查询一条SQL的执行结果。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*MrsClient) ShowSqlResultWithJob

func (c *MrsClient) ShowSqlResultWithJob(request *model.ShowSqlResultWithJobRequest) (*model.ShowSqlResultWithJobResponse, error)

获取SQL结果

在MRS集群中查询SparkSql和SparkScript两种类型作业的SQL语句运行完成后返回的查询结果。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*MrsClient) StopJob

func (c *MrsClient) StopJob(request *model.StopJobRequest) (*model.StopJobResponse, error)

终止作业

在MRS集群中终止指定作业。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*MrsClient) UpdateAgencyMapping

func (c *MrsClient) UpdateAgencyMapping(request *model.UpdateAgencyMappingRequest) (*model.UpdateAgencyMappingResponse, error)

更新用户（组）与IAM委托的映射关系

更新用户（组）与IAM委托之间的映射关系。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.