uhadoop

package
v0.22.65 Latest Latest
Warning

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

Go to latest
Published: Apr 23, 2026 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

Package uhadoop include resources of ucloud uhadoop product

See also

for detail.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddUHadoopInstanceNodeRequest

type AddUHadoopInstanceNodeRequest struct {
	request.CommonBase

	// 系统盘容量,非裸金属机型必填
	BootDiskSize *string `required:"false"`

	// 系统盘类型,非裸金属机型必填,例如:CLOUD_RSSD
	BootDiskType *string `required:"false"`

	// 数据盘数量,非裸金属机型时必填
	DataDiskNum *string `required:"false"`

	// 数据盘容量,非裸金属机型必填
	DataDiskSize *string `required:"false"`

	// 数据盘类型,非裸金属机型必填,例如:CLOUD_RSSD
	DataDiskType *string `required:"false"`

	// 实例ID
	InstanceId *string `required:"true"`

	// 节点数量,默认为1
	NodeCount *int `required:"false"`

	// 节点的角色,值为task|core|client之一
	NodeRole *string `required:"true"`

	// 机型,如:o.hadoop2m.medium,可从GetUHadoopNodeType接口获取
	NodeType *string `required:"true"`

	// 密码,NodeRole为client时必填
	Password *string `required:"false"`
}

AddUHadoopInstanceNodeRequest is request schema for AddUHadoopInstanceNode action

type AddUHadoopInstanceNodeResponse

type AddUHadoopInstanceNodeResponse struct {
	response.CommonBase

	// 错误信息
	Message string
}

AddUHadoopInstanceNodeResponse is response schema for AddUHadoopInstanceNode action

type AppConfig

type AppConfig struct {

	// 需要安装的应用如:Hive,HBase, Spark,Hue,Pig等其他组件
	AppName string

	// 应用的状态(运行中)'Running'|(已停止)'Stopped'|(启动中)'Starting'|(停止中)'Stopping'|(启动失败)'StartFailed'|(停止失败)'StopFailed'|(安装中)'Installing'|(安装失败)'InstallFailed'|(未安装)'NotInstalled',
	AppStatus string

	// 应用的版本号(0.13.1,0.98.6 等等)
	AppVersion string
}

AppConfig - 应用配置详情

type AppConfigVersion

type AppConfigVersion struct {

	// 框架,值为'Hadoop'|'HDFS'|'MR'|'StarRocks'之一,框架,例如Hadoop|MR|HDFS|StarRocks Hadoop框架包含存储与计算服务 MR集群包含计算服务 HDFS只包含存储服务,StarRocks为StarRocks集群
	Framework string

	// 框架版本
	FrameworkVersion string

	// Hadoop版本,值为 hadoop3.2.1-udh3.0|hadoop3.3.4-udh3.1 |hadoop2.8.5-udh2.2
	HadoopVersion string

	// UHadoop版本,值为 uhadoop 3.0|uhadoop 2.2|uhadoop 3.1
	ReleaseVersion string

	// 框架示例
	UseCases []UseCases
}

AppConfigVersion - 组件版本

type ClusterInfo

type ClusterInfo struct {

	// 组件数量
	AppConfigCount string

	// 组件集合
	AppConfigSet string

	// 业务组ID
	BusinessId string

	// 付费类型
	ChargeType string

	// core节点数量
	CoreCount string

	// 创建时间
	CreateTime string

	// 到期时间
	ExpireTime string

	// 框架,值为'Hadoop'|'HDFS'|'MR'|'StarRocks'之一,框架,例如Hadoop|MR|HDFS|StarRocks Hadoop框架包含存储与计算服务 MR集群包含计算服务 HDFS只包含存储服务,StarRocks为StarRocks集群
	Framework string

	// Hadoop版本,值为 hadoop3.2.1-udh3.0|hadoop3.3.4-udh3.1|hadoop2.8.5-udh2.2
	HadoopVersion string

	// 实例ID
	InstanceId string

	// 实例名称
	InstanceName string

	// 是否开启安全组
	IsOpenSecGroup string

	// Master节点数量
	MasterCount string

	// 节点数量
	NodeCount string

	// 节点集合
	NodeSet string

	// Uhadoop版本,值为 uhadoop 3.0|uhadoop 2.2|uhadoop 3.1
	ReleaseVersion string

	// 运行时间
	RunningTime string

	// 状态,值为以下其中之一,Running(运行中)|Creating(创建中)|CreateFailed(创建失败)|Deploying(部署中)|Updating(变更中)
	State string

	// 子网ID
	SubnetId string

	// 集群Tag
	Tag string

	// Task节点数量
	TaskCount string

	// VPC ID
	VPCId string

	// 可用区
	Zone string
}

ClusterInfo - 集群信息

type CreateUHadoopInstanceRequest

type CreateUHadoopInstanceRequest struct {
	request.CommonBase

	// 集群需要安装的组件,格式:组件#版本通过ListUHadoopFrameworkApp接口获取,例如:Spark#3.3.0
	AppConfig []string `required:"true"`

	// 工作组ID,默认Default
	BusinessId *string `required:"false"`

	// 支付类别,默认:Month
	ChargeType *string `required:"false"`

	// 框架,值为'Hadoop'|'HDFS'|'MR'|'StarRocks'之一,框架,例如Hadoop|MR|HDFS|StarRocks Hadoop框架包含存储与计算服务 MR集群包含计算服务 HDFS只包含存储服务,StarRocks为StarRocks集群
	Framework *string `required:"true"`

	// 版本,例如:3.2.1-udh3.0,通过ListUHadoopFrameworkApp接口获取
	FrameworkVersion *string `required:"true"`

	// 节点配置,里面包括NodeType(机型),NodeRole(节点类别,值为其中之一:master|core|task),Count(数量),DataDiskType(数据盘类别),DataDiskSize(数据盘大小),DataDiskNum(数据盘数量),BootDiskType(系统盘类型),BootDiskSize(系统盘大小),通过GetUHadoopNodeType接口获取,示例为:InstanceGroupConfigs.0.NodeType=o.hadoop2m.xlargeInstanceGroupConfigs.0.NodeRole=masterInstanceGroupConfigs.0.Count=2InstanceGroupConfigs.0.DataDiskType=CLOUD_RSSDInstanceGroupConfigs.0.DataDiskSize=100InstanceGroupConfigs.0.DataDiskNum=1InstanceGroupConfigs.0.BootDiskType=CLOUD_RSSDInstanceGroupConfigs.0.BootDiskSize=50InstanceGroupConfigs.1.NodeType=o.hadoop2m.xlargeInstanceGroupConfigs.1.NodeRole=coreInstanceGroupConfigs.1.Count=3InstanceGroupConfigs.1.DataDiskType=CLOUD_RSSDInstanceGroupConfigs.1.DataDiskSize=200InstanceGroupConfigs.1.DataDiskNum=1InstanceGroupConfigs.1.BootDiskType=CLOUD_RSSDInstanceGroupConfigs.1.BootDiskSize=50
	InstanceGroupConfigs []string `required:"true"`

	// 实例名称,默认为实例ID
	InstanceName *string `required:"false"`

	// 是否开启安全组
	IsSecurityEnabled *string `required:"false"`

	// 集群机器的登录密码
	Password *string `required:"true"`

	// 数量,默认1
	Quantity *int `required:"false"`

	// 安全组ID,字符串数组,IsSecurityEnabled为true时生效
	SecGroupIds *string `required:"false"`

	// 目前只支持传‘udb’
	StandAloneMetaStore *string `required:"false"`

	// Framework为‘MR’时,存储集群ID
	StorgeClusterId *string `required:"false"`

	// 子网ID
	SubnetId *string `required:"true"`

	// US3 配置公钥,仅支持框架为StarRocks存算分离时传入
	US3AccessKey *string `required:"false"`

	// US3 bucket名称,仅支持框架为StarRocks存算分离时传入
	US3Bucket *string `required:"false"`

	// US3 配置私钥,仅支持框架为StarRocks存算分离时传入
	US3SecretKey *string `required:"false"`

	// US3 Token名称,仅支持框架为StarRocks存算分离时传入
	US3TokenName *string `required:"false"`

	// VPCId
	VPCId *string `required:"true"`
}

CreateUHadoopInstanceRequest is request schema for CreateUHadoopInstance action

type CreateUHadoopInstanceResponse

type CreateUHadoopInstanceResponse struct {
	response.CommonBase

	// 实例ID
	InstanceId string

	// 错误信息
	Message string
}

CreateUHadoopInstanceResponse is response schema for CreateUHadoopInstance action

type DeleteUHadoopInstanceRequest

type DeleteUHadoopInstanceRequest struct {
	request.CommonBase

	// 实例ID
	InstanceId *string `required:"true"`

	// 是否释放绑定的EIP。true: 解绑EIP后,并释放;其他值或不填:解绑EIP。
	ReleaseEIP *bool `required:"false"`
}

DeleteUHadoopInstanceRequest is request schema for DeleteUHadoopInstance action

type DeleteUHadoopInstanceResponse

type DeleteUHadoopInstanceResponse struct {
	response.CommonBase

	// 错误信息
	Message string
}

DeleteUHadoopInstanceResponse is response schema for DeleteUHadoopInstance action

type DescribeUHadoopInstanceRequest

type DescribeUHadoopInstanceRequest struct {
	request.CommonBase

	// 实例ID
	InstanceId *string `required:"true"`

	// 子网ID
	SubnetId *string `required:"false"`

	// VPCID
	VPCId *string `required:"false"`
}

DescribeUHadoopInstanceRequest is request schema for DescribeUHadoopInstance action

type DescribeUHadoopInstanceResponse

type DescribeUHadoopInstanceResponse struct {
	response.CommonBase

	// 集群信息
	ClusterSet []ClusterInfo

	// 错误信息
	Message string
}

DescribeUHadoopInstanceResponse is response schema for DescribeUHadoopInstance action

type DiskSet

type DiskSet struct {

	// 最大磁盘数量
	DiskMaxNum string

	// 最大单块盘容量,单位GB
	DiskMaxSize string

	// 最小磁盘数量
	DiskMinNum string

	// 最小单块盘容量,单位GB
	DiskMinSize string

	// 磁盘数量
	DiskNum int

	// 可支持的磁盘类型
	DiskType []string

	// 单块盘大小
	SingleDiskSize int

	// 总磁盘大小
	Size int

	// 磁盘角色,分Data数据盘和Boot系统盘
	Type string
}

DiskSet -

type GetUHadoopNodeTypeRequest

type GetUHadoopNodeTypeRequest struct {
	request.CommonBase

	// 框架,例如Hadoop|MR|HDFS|StarRocks,Hadoop框架包含存储与计算服务,MR集群包含计算服务,HDFS只包含存储服务,StarRocks为StarRocks集群
	Framework *string `required:"false"`

	// 框架版本,例如3.2.1-udh3.0,通过ListUHadoopFrameworkApp接口获取
	FrameworkVersion *string `required:"false"`

	// 角色,master|core|task
	NodeRole *string `required:"false"`

	// 机型名称
	NodeType *string `required:"false"`
}

GetUHadoopNodeTypeRequest is request schema for GetUHadoopNodeType action

type GetUHadoopNodeTypeResponse

type GetUHadoopNodeTypeResponse struct {
	response.CommonBase

	// 机型可支持的节点类型
	HostTypeSupportNodeType string

	// 类型信息
	InstanceTypeSet []InstanceType

	// 错误信息
	Message string

	// 当前可用区是否支持元数据库使用UDB
	MetaDataUDBUsable bool
}

GetUHadoopNodeTypeResponse is response schema for GetUHadoopNodeType action

type InstanceType

type InstanceType struct {

	// cpu大小
	CPU string

	// cpu内存比
	CPUToMemoryRatio string

	// 磁盘信息
	DiskSet []DiskSet

	// GPU数量
	GpuCount int

	// GPU型号
	GpuType string

	// 机型种类,可选Outstanding(快杰机型)|General(普通机型)|BareMetal(裸金属机型)|GPU(GPU机型)四种类型
	HostType string

	// 是否支持开启安全组
	IsOpenSecgroup string

	// 是否可用,该机型是否支持创建
	IsUsable string

	// 内存大小
	Memory string

	// 机型名称
	NodeType string

	// 可用的节点类型,值为core|task|master之一
	SuitableRole []string
}

InstanceType - 机型配置

type ListClusterInfo

type ListClusterInfo struct {

	// 业务组ID
	BusinessId string

	// 创建时间
	CreateTime string

	// 框架,值为'Hadoop'|'HDFS'|'MR'|'StarRocks'之一,Hadoop框架包含存储与计算服务,MR集群包含计算服务,HDFS只包含存储服务,StarRocks为StarRocks集群
	Framework string

	// Hadoop版本,值为 hadoop3.2.1-udh3.0|hadoop3.3.4-udh3.1 |hadoop2.8.5-udh2.2
	HadoopVersion string

	// 实例ID
	InstanceId string

	// 实例名称
	InstanceName string

	// Uhadoop版本,值为 uhadoop 3.0|uhadoop 2.2|uhadoop 3.1
	ReleaseVersion string

	// 状态,值为以下其中之一,Running(运行中)|Creating(创建中)|CreateFailed(创建失败)|Deploying(部署中)|Updating(变更中)
	State string

	// 子网ID
	SubnetId string

	// VPC ID
	VPCId string

	// 可用区
	Zone string
}

ListClusterInfo - 集群信息

type ListUHadoopFrameworkAppByUseCaseRequest

type ListUHadoopFrameworkAppByUseCaseRequest struct {
	request.CommonBase
}

ListUHadoopFrameworkAppByUseCaseRequest is request schema for ListUHadoopFrameworkAppByUseCase action

type ListUHadoopFrameworkAppByUseCaseResponse

type ListUHadoopFrameworkAppByUseCaseResponse struct {
	response.CommonBase

	// 使用场景的app版本信息
	AppConfigSet []AppConfigVersion

	// 错误信息
	Message string
}

ListUHadoopFrameworkAppByUseCaseResponse is response schema for ListUHadoopFrameworkAppByUseCase action

type ListUHadoopFrameworkAppRequest

type ListUHadoopFrameworkAppRequest struct {
	request.CommonBase

	// 框架,值为'Hadoop'|'HDFS'|'MR'|'StarRocks'之一,框架,例如Hadoop|MR|HDFS|StarRocks Hadoop框架包含存储与计算服务 MR集群包含计算服务 HDFS只包含存储服务,StarRocks为StarRocks集群
	Framework *string `required:"true"`

	// 实例ID,可选。传的话,过滤出适合此集群的app信息。
	InstanceId *string `required:"false"`
}

ListUHadoopFrameworkAppRequest is request schema for ListUHadoopFrameworkApp action

type ListUHadoopFrameworkAppResponse

type ListUHadoopFrameworkAppResponse struct {
	response.CommonBase

	// 应用配置详情
	AppConfigSet []AppConfig

	// 错误信息
	Message string
}

ListUHadoopFrameworkAppResponse is response schema for ListUHadoopFrameworkApp action

type ListUHadoopInstanceRequest

type ListUHadoopInstanceRequest struct {
	request.CommonBase

	// 获取列表的长度限制,默认值为60
	Limit *int `required:"false"`

	// 获取列表的偏移,默认值为0
	Offset *int `required:"false"`
}

ListUHadoopInstanceRequest is request schema for ListUHadoopInstance action

type ListUHadoopInstanceResponse

type ListUHadoopInstanceResponse struct {
	response.CommonBase

	// 集群信息集合
	ClusterSet []ListClusterInfo

	// 错误信息
	Message string

	// 总数
	TotalCount int
}

ListUHadoopInstanceResponse is response schema for ListUHadoopInstance action

type RestartUHadoopServiceRequest

type RestartUHadoopServiceRequest struct {
	request.CommonBase

	// 应用版本,ApplicationVersion传参时,表示这次操作是整个应用所有服务。
	ApplicationVersion *string `required:"false"`

	// 实例ID
	InstanceId *string `required:"true"`

	// 要操作的NodeId数组。如果传入,则用于过滤操作哪些Node。
	NodeId []string `required:"false"`

	// 要操作的NodeRole数组。如果传入,则用于过滤操作哪些Node。值为以下之一master|core|task
	NodeRole []string `required:"false"`

	// 只启动。值为false|true之一,默认false,当OnlyStart和OnlyStop同时置为true,则重启。
	OnlyStart *bool `required:"false"`

	// 只停止。值为false|true之一,默认false。当OnlyStart和OnlyStop同时置为true,则重启。
	OnlyStop *bool `required:"false"`

	// 要操作的服务名。可通过ListUHadoopFrameworkApp接口获取
	ServiceName *string `required:"true"`
}

RestartUHadoopServiceRequest is request schema for RestartUHadoopService action

type RestartUHadoopServiceResponse

type RestartUHadoopServiceResponse struct {
	response.CommonBase

	// 错误信息
	Message string

	// 当前执行状态,running(操作运行中)|success(操作成功)|failed(操作失败)|killed(操作被终止)。
	State string
}

RestartUHadoopServiceResponse is response schema for RestartUHadoopService action

type UHadoopClient

type UHadoopClient struct {
	*ucloud.Client
}

UHadoopClient is the client of UHadoop

func NewClient

func NewClient(config *ucloud.Config, credential *auth.Credential) *UHadoopClient

NewClient will return a instance of UHadoopClient

func (*UHadoopClient) AddUHadoopInstanceNode

API: AddUHadoopInstanceNode

给已有集群添加一定数量的节点

func (*UHadoopClient) CreateUHadoopInstance

API: CreateUHadoopInstance

新建一个uhadoop集群

func (*UHadoopClient) DeleteUHadoopInstance

API: DeleteUHadoopInstance

删除掉一个uhadoop集群

func (*UHadoopClient) DescribeUHadoopInstance

API: DescribeUHadoopInstance

描述集群

func (*UHadoopClient) GetUHadoopNodeType

API: GetUHadoopNodeType

获取节点类型信息

func (*UHadoopClient) ListUHadoopFrameworkApp

API: ListUHadoopFrameworkApp

列举可选app

func (*UHadoopClient) ListUHadoopFrameworkAppByUseCase

API: ListUHadoopFrameworkAppByUseCase

按使用场景列出uhadoop的框架和框架中的应用

func (*UHadoopClient) ListUHadoopInstance

API: ListUHadoopInstance

列出用户所有的uhadoop集群

func (*UHadoopClient) NewAddUHadoopInstanceNodeRequest

func (c *UHadoopClient) NewAddUHadoopInstanceNodeRequest() *AddUHadoopInstanceNodeRequest

NewAddUHadoopInstanceNodeRequest will create request of AddUHadoopInstanceNode action.

func (*UHadoopClient) NewCreateUHadoopInstanceRequest

func (c *UHadoopClient) NewCreateUHadoopInstanceRequest() *CreateUHadoopInstanceRequest

NewCreateUHadoopInstanceRequest will create request of CreateUHadoopInstance action.

func (*UHadoopClient) NewDeleteUHadoopInstanceRequest

func (c *UHadoopClient) NewDeleteUHadoopInstanceRequest() *DeleteUHadoopInstanceRequest

NewDeleteUHadoopInstanceRequest will create request of DeleteUHadoopInstance action.

func (*UHadoopClient) NewDescribeUHadoopInstanceRequest

func (c *UHadoopClient) NewDescribeUHadoopInstanceRequest() *DescribeUHadoopInstanceRequest

NewDescribeUHadoopInstanceRequest will create request of DescribeUHadoopInstance action.

func (*UHadoopClient) NewGetUHadoopNodeTypeRequest

func (c *UHadoopClient) NewGetUHadoopNodeTypeRequest() *GetUHadoopNodeTypeRequest

NewGetUHadoopNodeTypeRequest will create request of GetUHadoopNodeType action.

func (*UHadoopClient) NewListUHadoopFrameworkAppByUseCaseRequest

func (c *UHadoopClient) NewListUHadoopFrameworkAppByUseCaseRequest() *ListUHadoopFrameworkAppByUseCaseRequest

NewListUHadoopFrameworkAppByUseCaseRequest will create request of ListUHadoopFrameworkAppByUseCase action.

func (*UHadoopClient) NewListUHadoopFrameworkAppRequest

func (c *UHadoopClient) NewListUHadoopFrameworkAppRequest() *ListUHadoopFrameworkAppRequest

NewListUHadoopFrameworkAppRequest will create request of ListUHadoopFrameworkApp action.

func (*UHadoopClient) NewListUHadoopInstanceRequest

func (c *UHadoopClient) NewListUHadoopInstanceRequest() *ListUHadoopInstanceRequest

NewListUHadoopInstanceRequest will create request of ListUHadoopInstance action.

func (*UHadoopClient) NewRestartUHadoopServiceRequest

func (c *UHadoopClient) NewRestartUHadoopServiceRequest() *RestartUHadoopServiceRequest

NewRestartUHadoopServiceRequest will create request of RestartUHadoopService action.

func (*UHadoopClient) NewUpgradeUHadoopNodeDiskRequest

func (c *UHadoopClient) NewUpgradeUHadoopNodeDiskRequest() *UpgradeUHadoopNodeDiskRequest

NewUpgradeUHadoopNodeDiskRequest will create request of UpgradeUHadoopNodeDisk action.

func (*UHadoopClient) NewUpgradeUHadoopNodeRequest

func (c *UHadoopClient) NewUpgradeUHadoopNodeRequest() *UpgradeUHadoopNodeRequest

NewUpgradeUHadoopNodeRequest will create request of UpgradeUHadoopNode action.

func (*UHadoopClient) RestartUHadoopService

API: RestartUHadoopService

重启集群服务(包含start|stop|restart)

func (*UHadoopClient) UpgradeUHadoopNode

API: UpgradeUHadoopNode

升级uhadoop节点

func (*UHadoopClient) UpgradeUHadoopNodeDisk

API: UpgradeUHadoopNodeDisk

扩容集群节点磁盘

type UpgradeUHadoopNodeDiskRequest

type UpgradeUHadoopNodeDiskRequest struct {
	request.CommonBase

	// 系统盘磁盘大小,仅支持云盘裸金属机型(系统盘和数据盘数值同时增加、只会处理系统盘参数)
	BootDiskSize *int `required:"false"`

	// 新的数据盘磁盘大小
	DataDiskSize *int `required:"true"`

	// 实例ID
	InstanceId *string `required:"true"`

	// 节点名称集合,当NodeRole不为master时必填
	NodeNames []string `required:"false"`

	// 节点角色,值为master|core|task之一
	NodeRole *string `required:"true"`
}

UpgradeUHadoopNodeDiskRequest is request schema for UpgradeUHadoopNodeDisk action

type UpgradeUHadoopNodeDiskResponse

type UpgradeUHadoopNodeDiskResponse struct {
	response.CommonBase

	// 错误信息
	Message string
}

UpgradeUHadoopNodeDiskResponse is response schema for UpgradeUHadoopNodeDisk action

type UpgradeUHadoopNodeRequest

type UpgradeUHadoopNodeRequest struct {
	request.CommonBase

	// 实例ID
	InstanceId *string `required:"true"`

	// 节点名称,当NodeRole不为master时必填
	NodeNames []string `required:"false"`

	// 节点角色,支持"master"|"core"|"task"
	NodeRole *string `required:"true"`

	// 节点新机型,通过GetUHadoopNodeType接口获取
	NodeType *string `required:"true"`
}

UpgradeUHadoopNodeRequest is request schema for UpgradeUHadoopNode action

type UpgradeUHadoopNodeResponse

type UpgradeUHadoopNodeResponse struct {
	response.CommonBase

	// 错误信息
	Message string
}

UpgradeUHadoopNodeResponse is response schema for UpgradeUHadoopNode action

type UseCases

type UseCases struct {

	// 组件版本
	AppVersion string

	// 集群种类
	ClusterCase string

	// 依赖的组件
	MustHas string
}

UseCases - 框架使用示例

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL