检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
缩容Master节点。API的调用方法请参见如何调用API。 约束限制 集群已创建成功并处于“运行中”。 已获取待创建集群区域的项目ID，请参考获取项目ID获取。 已获取集群ID，即创建集群成功后返回结果中的“cluster_id” 或参考获取集群ID获取。 该示例以缩容Core节点为例。
IAM同步管理接口 获取已经同步的IAM用户和用户组 IAM同步 指定用户、用户组取消同步 父主题： API V2
作业管理接口 新增并执行作业 查询作业列表信息 查询单个作业信息 终止作业 获取SQL结果 批量删除作业 父主题： API V2
场景描述 本章节指导用户通过API创建一个MRS分析集群。API的调用方法请参见如何调用API。 约束限制 已在待创建集群区域通过虚拟私有云服务创建VPC，子网。创建VPC请参考查询VPC列表和创建VPC。创建子网请参考查询子网列表和创建子网。 已获取待创建集群区域的区域和可用区信息，具体请参考终端节点。
FlinkServer REST API样例程序（Java） 功能介绍 通过调用FlinkServer RestAPI创建租户。 代码样例 具体代码参见com.huawei.bigdata.flink.examples.TestCreateTenants。 public class
使用Producer API向安全Topic生产消息 功能简介 用于实现Producer API向安全Topic生产消息。 代码样例 以下为用于实现Producer API向安全Topic生产消息的代码片段。 详细内容在com.huawei.bigdata.kafka.example
使用Producer API向安全Topic生产消息 功能简介 用于实现Producer API向安全Topic生产消息。 代码样例 以下为用于实现Producer API向安全Topic生产消息的代码片段。 详细内容在com.huawei.bigdata.kafka.example
含义 取值 token.server.access.iam.domain.id 访问IAM的用户对应的账号ID。 参考获取账号ID信息获取账号ID信息。 xxx token.server.access.iam.project.id 访问IAM的用户对应的项目ID。 参考获取账号ID信息获取项目ID信息。
terminated by '\\n' stored as textfile location 'obs://AK:SK@sparksql/input'; AK/SK获取方法，请参见前提条件。 方式二：创建一个表src_data1，将数据源中的数据批量load到src_data1表中。
使用Producer API向安全Topic生产消息 功能简介 用于实现Producer API向安全Topic生产消息。 代码样例 以下为用于实现Producer API向安全Topic生产消息的代码片段。 详细内容在com.huawei.bigdata.kafka.example
配置Kafka应用安全认证 使用Sasl Kerberos认证 使用Sasl Plaintext认证 使用Kafka Token认证 父主题： 准备Kafka应用开发环境
FlinkServer REST API样例程序 使用代理用户访问FlinkServer REST API样例程序（Java） 父主题： 开发Flink应用
使用Producer API向安全Topic生产消息 功能简介 用于实现Producer API向安全Topic生产消息。 代码样例 以下为用于实现Producer API向安全Topic生产消息的代码片段。 详细内容在com.huawei.bigdata.kafka.example
FlinkServer REST API样例程序 FlinkServer REST API样例程序开发思路 FlinkServer REST API样例程序（Java） 使用代理用户访问FlinkServer REST API样例程序（Java） 父主题： 开发Flink应用
含义 取值 token.server.access.iam.domain.id 访问IAM的用户对应的账号 ID。 参考获取账号ID信息获取账号ID信息。 xxx token.server.access.iam.project.id 访问IAM的用户对应的项目ID。 参考获取账号ID信息获取项目ID信息。
配置Kafka应用安全认证 使用Sasl Kerberos认证 使用Kafka Token认证 父主题： 准备Kafka应用开发环境
请参见如何调用API。 URI PUT /v2/{project_id}/data-connectors/{connector_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 参数解释： 项目编号。获取方法，请参见获取项目ID。 约束限制：
SQL接口 提交SQL语句 查询SQL结果 取消SQL执行任务 父主题： API V2
须具备调用该接口所需的权限，否则，API请求将调用失败。每个接口所需要的权限，与各个接口所对应的授权项相对应，只有发起请求的用户被授予授权项所对应的策略，该用户才能成功调用该接口。例如，用户要调用接口来查询集群列表，那么这个IAM用户被授予的策略中必须包含允许“mrs:clust
委托管理 查询用户（组）与IAM委托的映射关系 更新用户（组）与IAM委托的映射关系 父主题： API V2
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
