Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion VERSION
Original file line number Diff line number Diff line change
@@ -1 +1 @@
0.3.16
0.3.17
20 changes: 10 additions & 10 deletions src/UHadoop/Apis/CreateUHadoopInstanceRequest.php
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ public function __construct()
$this->markRequired("InstanceGroupConfigs");
$this->markRequired("VPCId");
$this->markRequired("SubnetId");
$this->markRequired("AppConfig");
$this->markRequired("AppConfigs");
$this->markRequired("Framework");
}

Expand Down Expand Up @@ -97,7 +97,7 @@ public function setProjectId($projectId)
}

/**
* Password: 集群机器的登录密码
* Password: 集群机器的登录密码,需要输入base64编码后的内容
*
* @return string|null
*/
Expand All @@ -107,7 +107,7 @@ public function getPassword()
}

/**
* Password: 集群机器的登录密码
* Password: 集群机器的登录密码,需要输入base64编码后的内容
*
* @param string $password
*/
Expand Down Expand Up @@ -197,23 +197,23 @@ public function setSubnetId($subnetId)
}

/**
* AppConfig: 集群需要安装的组件,格式:组件#版本通过ListUHadoopFrameworkApp接口获取,例如:Spark#3.3.0
* AppConfigs: 集群需要安装的组件,格式:组件#版本通过ListUHadoopFrameworkApp接口获取,例如:Spark#3.3.0
*
* @return string[]|null
*/
public function getAppConfig()
public function getAppConfigs()
{
return $this->get("AppConfig");
return $this->get("AppConfigs");
}

/**
* AppConfig: 集群需要安装的组件,格式:组件#版本通过ListUHadoopFrameworkApp接口获取,例如:Spark#3.3.0
* AppConfigs: 集群需要安装的组件,格式:组件#版本通过ListUHadoopFrameworkApp接口获取,例如:Spark#3.3.0
*
* @param string[] $appConfig
* @param string[] $appConfigs
*/
public function setAppConfig(array $appConfig)
public function setAppConfigs(array $appConfigs)
{
$this->set("AppConfig", $appConfig);
$this->set("AppConfigs", $appConfigs);
}

/**
Expand Down
6 changes: 3 additions & 3 deletions src/UHadoop/UHadoopClient.php
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ public function addUHadoopInstanceNode(AddUHadoopInstanceNodeRequest $request =
}

/**
* CreateUHadoopInstance - 新建一个uhadoop集群
* CreateUHadoopInstance - 创建实例接口。\\ 创建实例前需要按以下步骤准备必要参数:\\ 1.获取Region(地域)和 Zone(可用区),访问链接:https://docs.ucloud.cn/api/summary/regionlist 可以获取所有支持的地域和可用区;\\ 2.FrameworkVersion,访问链接:https://docs.ucloud.cn/api/uhadoop-api/list_uhadoop_framework_app_by_use_case,响应字段的AppConfigSet[N].FrameworkVersion是框架版本是支持的 UHadoop 版本;\\ 3.ChargeType付费类型,可用值:Dynamic为按小时付费,Month为按月付费,Year为按年付费;\\ 4.InstanceGroupConfigs需要获取NodeType机型详情,访问链接:https://docs.ucloud.cn/api/uhadoop-api/get_uhadoop_node_type,响应字段的InstanceTypeSet[N].NodeType是机型名称,响应字段的InstanceTypeSet[N].SuitableRole是机型可用的节点类型;\\ 5.获取DiskSize磁盘大小范围 ,访问链接:https://docs.ucloud.cn/api/uhadoop-api/get_uhadoop_node_type,该接口响应字段的InstanceTypeSet[N].DiskSet[N].DiskMinSize和InstanceTypeSet[N].DiskSet[N].DiskMaxSize是磁盘大小的取值范围;\\ 6.InstanceName,自定义输入实例名称,只能包含中英文、数字以及- _ ;\\7.Password,集群机器的登录密码,需要输入base64编码后的内容;\\8.AppConfigs 集群需要安装的组件,访问链接,https://docs.ucloud.cn/api/uhadoop-api/list_uhadoop_framework_app ,AppConfigSet[N].AppName是组件名称,AppConfigSet[N].AppVersion是组件版本
*
* See also: https://docs.ucloud.cn/api/uhadoop-api/create_uhadoop_instance
*
Expand All @@ -95,12 +95,12 @@ public function addUHadoopInstanceNode(AddUHadoopInstanceNodeRequest $request =
* "Region" => (string) 地域。 参见 [地域和可用区列表](https://docs.ucloud.cn/api/summary/regionlist)
* "Zone" => (string) 可用区。参见 [可用区列表](https://docs.ucloud.cn/api/summary/regionlist)
* "ProjectId" => (string) 项目ID。不填写为默认项目,子帐号必须填写。 请参考[GetProjectList接口](https://docs.ucloud.cn/api/summary/get_project_list)
* "Password" => (string) 集群机器的登录密码
* "Password" => (string) 集群机器的登录密码,需要输入base64编码后的内容
* "FrameworkVersion" => (string) 版本,例如:3.2.1-udh3.0,通过ListUHadoopFrameworkApp接口获取
* "InstanceGroupConfigs" => (array<string>) 节点配置,里面包括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
* "VPCId" => (string) VPCId
* "SubnetId" => (string) 子网ID
* "AppConfig" => (array<string>) 集群需要安装的组件,格式:组件#版本通过ListUHadoopFrameworkApp接口获取,例如:Spark#3.3.0
* "AppConfigs" => (array<string>) 集群需要安装的组件,格式:组件#版本通过ListUHadoopFrameworkApp接口获取,例如:Spark#3.3.0
* "Framework" => (string) 框架,值为'Hadoop'|'HDFS'|'MR'|'StarRocks'之一,框架,例如Hadoop|MR|HDFS|StarRocks Hadoop框架包含存储与计算服务 MR集群包含计算服务 HDFS只包含存储服务,StarRocks为StarRocks集群
* "ChargeType" => (string) 支付类别,默认:Month
* "Quantity" => (integer) 数量,默认1
Expand Down
4 changes: 2 additions & 2 deletions src/UKafka/Apis/AddUKafkaInstanceNodeRequest.php
Original file line number Diff line number Diff line change
Expand Up @@ -135,7 +135,7 @@ public function setNodeType($nodeType)
/**
* NodeCount: 新添加节点数量
*
* @return integer|null
* @return string|null
*/
public function getNodeCount()
{
Expand All @@ -145,7 +145,7 @@ public function getNodeCount()
/**
* NodeCount: 新添加节点数量
*
* @param int $nodeCount
* @param string $nodeCount
*/
public function setNodeCount($nodeCount)
{
Expand Down
8 changes: 4 additions & 4 deletions src/UKafka/Apis/CreateUKafkaInstanceRequest.php
Original file line number Diff line number Diff line change
Expand Up @@ -217,7 +217,7 @@ public function setDiskSize($diskSize)
}

/**
* InstanceName: 实例名,可自定义
* InstanceName: 实例名,可自定义。只能包含中英文、数字以及- _ .
*
* @return string|null
*/
Expand All @@ -227,7 +227,7 @@ public function getInstanceName()
}

/**
* InstanceName: 实例名,可自定义
* InstanceName: 实例名,可自定义。只能包含中英文、数字以及- _ .
*
* @param string $instanceName
*/
Expand Down Expand Up @@ -277,7 +277,7 @@ public function setQuantity($quantity)
}

/**
* NodeCount: 集群节点数量。默认 3 节点
* NodeCount: 实例节点数量。默认 3 节点
*
* @return integer|null
*/
Expand All @@ -287,7 +287,7 @@ public function getNodeCount()
}

/**
* NodeCount: 集群节点数量。默认 3 节点
* NodeCount: 实例节点数量。默认 3 节点
*
* @param int $nodeCount
*/
Expand Down
4 changes: 2 additions & 2 deletions src/UKafka/Apis/DescribeUKafkaConsumerRequest.php
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ public function setProjectId($projectId)
}

/**
* ClusterInstanceId: Kafka 集群 ID
* ClusterInstanceId: 实例 ID
*
* @return string|null
*/
Expand All @@ -103,7 +103,7 @@ public function getClusterInstanceId()
}

/**
* ClusterInstanceId: Kafka 集群 ID
* ClusterInstanceId: 实例 ID
*
* @param string $clusterInstanceId
*/
Expand Down
6 changes: 3 additions & 3 deletions src/UKafka/Apis/DescribeUKafkaConsumerResponse.php
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ public function setType($type)
/**
* Topics: 消费者组所订阅 topic 信息
*
* @return string|null
* @return string[]|null
*/
public function getTopics()
{
Expand All @@ -75,9 +75,9 @@ public function getTopics()
/**
* Topics: 消费者组所订阅 topic 信息
*
* @param string $topics
* @param string[] $topics
*/
public function setTopics($topics)
public function setTopics(array $topics)
{
$this->set("Topics", $topics);
}
Expand Down
4 changes: 2 additions & 2 deletions src/UKafka/Apis/DescribeUKafkaInstanceResponse.php
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ class DescribeUKafkaInstanceResponse extends Response


/**
* ClusterSet: 集群信息列表
* ClusterSet: 实例信息列表
*
* @return ClusterInfo[]|null
*/
Expand All @@ -49,7 +49,7 @@ public function getClusterSet()
}

/**
* ClusterSet: 集群信息列表
* ClusterSet: 实例信息列表
*
* @param ClusterInfo[] $clusterSet
*/
Expand Down
16 changes: 8 additions & 8 deletions src/UKafka/Apis/IsUKafkaTopicNameExistRequest.php
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ public function __construct()


/**
* Region: 地域。 参见 [地域和可用区列表](../summary/regionlist.html)
* Region: 地域。 参见 [地域和可用区列表](https://docs.ucloud.cn/api/summary/regionlist)
*
* @return string|null
*/
Expand All @@ -42,7 +42,7 @@ public function getRegion()
}

/**
* Region: 地域。 参见 [地域和可用区列表](../summary/regionlist.html)
* Region: 地域。 参见 [地域和可用区列表](https://docs.ucloud.cn/api/summary/regionlist)
*
* @param string $region
*/
Expand All @@ -52,7 +52,7 @@ public function setRegion($region)
}

/**
* Zone: 可用区。参见 [可用区列表](../summary/regionlist.html)
* Zone: 可用区。参见 [可用区列表](https://docs.ucloud.cn/api/summary/regionlist)
*
* @return string|null
*/
Expand All @@ -62,7 +62,7 @@ public function getZone()
}

/**
* Zone: 可用区。参见 [可用区列表](../summary/regionlist.html)
* Zone: 可用区。参见 [可用区列表](https://docs.ucloud.cn/api/summary/regionlist)
*
* @param string $zone
*/
Expand All @@ -72,7 +72,7 @@ public function setZone($zone)
}

/**
* ProjectId: 项目ID。不填写为默认项目,子帐号必须填写。 请参考[GetProjectList接口](../summary/get_project_list.html)
* ProjectId: 项目ID。不填写为默认项目,子帐号必须填写。 请参考[GetProjectList接口](https://docs.ucloud.cn/api/summary/get_project_list)
*
* @return string|null
*/
Expand All @@ -82,7 +82,7 @@ public function getProjectId()
}

/**
* ProjectId: 项目ID。不填写为默认项目,子帐号必须填写。 请参考[GetProjectList接口](../summary/get_project_list.html)
* ProjectId: 项目ID。不填写为默认项目,子帐号必须填写。 请参考[GetProjectList接口](https://docs.ucloud.cn/api/summary/get_project_list)
*
* @param string $projectId
*/
Expand All @@ -92,7 +92,7 @@ public function setProjectId($projectId)
}

/**
* ClusterInstanceId: 集群ID
* ClusterInstanceId: 实例ID,可以通过ListUKafkaInstance 接口的ClusterSet. ClusterInstanceId 获取
*
* @return string|null
*/
Expand All @@ -102,7 +102,7 @@ public function getClusterInstanceId()
}

/**
* ClusterInstanceId: 集群ID
* ClusterInstanceId: 实例ID,可以通过ListUKafkaInstance 接口的ClusterSet. ClusterInstanceId 获取
*
* @param string $clusterInstanceId
*/
Expand Down
16 changes: 8 additions & 8 deletions src/UKafka/Apis/ListUKafkaConsumersRequest.php
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ public function __construct()


/**
* Region: 地域。 参见 [地域和可用区列表](../summary/regionlist.html)
* Region: 地域。 参见 [地域和可用区列表](https://docs.ucloud.cn/api/summary/regionlist)
*
* @return string|null
*/
Expand All @@ -41,7 +41,7 @@ public function getRegion()
}

/**
* Region: 地域。 参见 [地域和可用区列表](../summary/regionlist.html)
* Region: 地域。 参见 [地域和可用区列表](https://docs.ucloud.cn/api/summary/regionlist)
*
* @param string $region
*/
Expand All @@ -51,7 +51,7 @@ public function setRegion($region)
}

/**
* Zone: 可用区。参见 [可用区列表](../summary/regionlist.html)
* Zone: 可用区。参见 [可用区列表](https://docs.ucloud.cn/api/summary/regionlist)
*
* @return string|null
*/
Expand All @@ -61,7 +61,7 @@ public function getZone()
}

/**
* Zone: 可用区。参见 [可用区列表](../summary/regionlist.html)
* Zone: 可用区。参见 [可用区列表](https://docs.ucloud.cn/api/summary/regionlist)
*
* @param string $zone
*/
Expand All @@ -71,7 +71,7 @@ public function setZone($zone)
}

/**
* ProjectId: 项目 ID。不填写为默认项目,子帐号必须填写。 请参考 [GetProjectList 接口](../summary/get_project_list.html)
* ProjectId: 项目 ID。不填写为默认项目,子帐号必须填写。 请参考 [GetProjectList 接口](https://docs.ucloud.cn/api/summary/get_project_list)
*
* @return string|null
*/
Expand All @@ -81,7 +81,7 @@ public function getProjectId()
}

/**
* ProjectId: 项目 ID。不填写为默认项目,子帐号必须填写。 请参考 [GetProjectList 接口](../summary/get_project_list.html)
* ProjectId: 项目 ID。不填写为默认项目,子帐号必须填写。 请参考 [GetProjectList 接口](https://docs.ucloud.cn/api/summary/get_project_list)
*
* @param string $projectId
*/
Expand All @@ -91,7 +91,7 @@ public function setProjectId($projectId)
}

/**
* ClusterInstanceId: Kafka 集群 ID
* ClusterInstanceId: 实例ID,可以通过ListUKafkaInstance 接口的ClusterSet. ClusterInstanceId 获取
*
* @return string|null
*/
Expand All @@ -101,7 +101,7 @@ public function getClusterInstanceId()
}

/**
* ClusterInstanceId: Kafka 集群 ID
* ClusterInstanceId: 实例ID,可以通过ListUKafkaInstance 接口的ClusterSet. ClusterInstanceId 获取
*
* @param string $clusterInstanceId
*/
Expand Down
41 changes: 1 addition & 40 deletions src/UKafka/Apis/ListUKafkaInstanceRequest.php
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ public function __construct()
{
parent::__construct(["Action" => "ListUKafkaInstance"]);
$this->markRequired("Region");
$this->markRequired("Zone");
}


Expand Down Expand Up @@ -128,26 +129,6 @@ public function setOffset($offset)
$this->set("Offset", $offset);
}

/**
* Filter: 是否过滤删除了的节点,默认为‘true’
*
* @return string|null
*/
public function getFilter()
{
return $this->get("Filter");
}

/**
* Filter: 是否过滤删除了的节点,默认为‘true’
*
* @param string $filter
*/
public function setFilter($filter)
{
$this->set("Filter", $filter);
}

/**
* VPCId: VPCId
*
Expand Down Expand Up @@ -207,24 +188,4 @@ public function setBusinessId($businessId)
{
$this->set("BusinessId", $businessId);
}

/**
* ClusterInstanceId: 实例ID
*
* @return string|null
*/
public function getClusterInstanceId()
{
return $this->get("ClusterInstanceId");
}

/**
* ClusterInstanceId: 实例ID
*
* @param string $clusterInstanceId
*/
public function setClusterInstanceId($clusterInstanceId)
{
$this->set("ClusterInstanceId", $clusterInstanceId);
}
}
Loading
Loading