Flink HBase样例程序（Java） 功能介绍 通过调用Flink API读写HBase数据。 代码样例 下面列出WriteHBase和ReadHBase主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink.examples.WriteHBase和com

查看更多 →

Spark SQL样例程序（Java） 功能简介 统计日志文件中本周末网购停留总时间超过2个小时的女性网民信息。 代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.spark.examples.FemaleInfoCollection： public

查看更多 →

Flink Kafka样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 下面列出producer和consumer主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink

查看更多 →

Flink Join样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 用户在开发前需要使用对接安全模式的Kafka，则需要引入kafka-clients-*.jar，该jar包可在client目录下获取。

查看更多 →

业务配置中心”，如图1。 图1 进入业务配置中心 给业务用户授权。 新建业务用户并授权 在“组织用户”页面，选择导航栏中的“用户管理”。 单击“创建用户”，填写用户的基本信息，并设置语言和时区。 在角色的“未选”区域中，选中对应的权限后，单击，赋予业务用户相关权限。 例如，给业务用户张三授予“零码开发者

查看更多 →

Spark SQL样例程序（Java） 功能简介 统计日志文件中本周末网购停留总时间超过2个小时的女性网民信息。 代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.spark.examples.FemaleInfoCollection： public

查看更多 →

Flink Kafka样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 下面列出producer和consumer主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink

查看更多 →

Flink Join样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 用户在开发前需要使用对接安全模式的Kafka，则需要引入kafka-clients-*.jar，该jar包可在client目录下获取。

查看更多 →

Spark SQL样例程序（Java） 功能简介 统计日志文件中本周末网购停留总时间超过2个小时的女性网民信息。 代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.spark.examples.FemaleInfoCollection： public

查看更多 →

Spark Core样例程序（Java） 功能简介 统计日志文件中本周末网购停留总时间超过2个小时的女性网民信息。 代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.spark.examples.FemaleInfoCollection类：

查看更多 →

Flink Join样例程序（Java） 功能介绍 在Flink应用中，调用flink-connector-kafka模块的接口，生产并消费数据。 代码样例 用户在开发前需要使用对接安全模式的Kafka，则需要引入 FusionInsight 的kafka-clients-*.jar

查看更多 →

Flink Hudi样例程序（Java） 功能介绍 通过调用Flink API读写Hudi数据。 代码样例 下面列出WriteIntoHudi和ReadFromHudi主要逻辑代码作为演示。 完整代码参见com.huawei.bigdata.flink.examples.WriteIntoHudi和com

查看更多 →

Flink DataStream样例程序（Java） 功能介绍 统计连续网购时间超过2个小时的女性网民信息，将统计结果直接打印。 DataStream FlinkStreamJavaExample代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.flink

查看更多 →

数据的条数保存在UDFState中；从快照中状态恢复时，读取UDFState中的数据条数并重新赋值给count变量。 import org.apache.flink.api.java.tuple.Tuple4; import org.apache.flink.streaming.api

查看更多 →

如何发文件给对方？ 方法1：打开对方的聊天对话框，点击右下角“+”>“云空间”> 选择云空间里的文件进行分享。 方法2：打开对方的聊天对话框，点击右下角“+”>“本地文件”> 选择本地文件里的文件进行分享。 方法:3：在手机的文件管理中，长按要分享的文件 > 点击“分享”>选择“ WeLink ”>“同事”>

查看更多 →

如何给IAM子账号授权？ 当您需要授予使用子账号操作安全云脑服务时，需要使用主账号对子账号进行授权操作。 操作步骤 使用管理员账号登录管理控制台。 在页面左上角单击，选择“管理与监管 > 统一身份认证服务”，进入统一身份认证服务管理控制台。 创建用户组。 在左侧导航栏选择“用户组

查看更多 →

数据的条数保存在UDFState中；从快照中状态恢复时，读取UDFState中的数据条数并重新赋值给count变量。 import org.apache.flink.api.java.tuple.Tuple4; import org.apache.flink.streaming.api

查看更多 →

数据的条数保存在UDFState中；从快照中状态恢复时，读取UDFState中的数据条数并重新赋值给count变量。 import org.apache.flink.api.java.tuple.Tuple4; import org.apache.flink.streaming.api

查看更多 →

如何设置分页查询（Java） 指定每次查询获取的行数 在创建集群连接时，可以指定每次查询获取的行数，具体为下列setFetchSize内参数。 Cluster cluster = Cluster.builder() .addContactPoint(contactPoint)

查看更多 →

SSL证书是如何收费的？ SSL证书管理服务为您提供了一种证书品牌为DigiCert品牌、证书类型为DV（Basic）、 域名 类型为单域名的用于测试的免费证书。关于免费证书的相关信息请参考如何申请免费证书？。 除此之外，SSL证书管理服务会根据您选择的证书类型、证书品牌、域名类型、域名数量和购买时长进行收费。

查看更多 →

如何给云硬盘添加告警通知？ 问题描述 如何给云硬盘的操作添加告警通知。 操作步骤 登录 云审计 控制台。 左侧导航栏选择“关键操作通知”，单击“创建关键操作通知”。 在“配置操作”模块选择“自定义操作”，依次勾选“EVS > evs”的四个关键操作名称，即可对云硬盘的操作添加告警通知。

查看更多 →