Java样例代码 功能介绍 在Spark应用中，通过使用StructuredStreaming调用Kafka接口来获取单词记录，然后把单词记录分类统计，得到每个单词记录数。 代码样例 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.spark.examples

查看更多 →

Java样例代码 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.hudi.examples.HoodieWriteClientExample 创建客户端对象来操作Hudi： String tablePath = args[0]; String tableName

查看更多 →

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

查看更多 →

Java样例代码 功能介绍 假定用户需要每隔1秒钟需要统计4秒中窗口中数据的量，并做到状态严格一致性。 代码样例 快照数据 该数据在算子制作快照时用于保存到目前为止算子记录的数据条数。 import java.io.Seriablizale; // 该类作为快照的一部分，保存用户自定义状态

查看更多 →

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

查看更多 →

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

查看更多 →

Java样例代码 功能简介 使用自定义客户端的JDBC接口提交数据分析任务，并返回结果。 样例代码 定义SQL语句。SQL语句必须为单条语句，注意其中不能包含“;”。示例： ArrayList<String> sqlList = new ArrayList<String>(); sqlList

查看更多 →

Java样例代码 功能介绍 用户可以使用Spark调用HBase接口来操作HBase table1表，然后把table1表的数据经过分析后写到HBase table2表中。 代码样例 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.spark.examples

查看更多 →

Java样例代码 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.hudi.examples.HoodieWriteClientExample。 创建客户端对象来操作Hudi： String tablePath = args[0]; String tableName

查看更多 →

Java样例代码 功能简介 通过JDBC连接方式，执行IoTDB SQL语句。 代码样例 下面代码片段仅为演示，具体代码参见“com.huawei.bigdata.iotdb.JDBCExample”类。 其中，在jdbc url里设置待连接的IoTDBServer所在的节点IP、端口、用户名和密码。

查看更多 →

AXE模式话单通知接口 接口功能 用户通话结束后， 隐私保护通话 平台通过此接口向客户推送通话的话单信息。短时间内有多个通话结束时隐私保护通话平台会将话单合并推送，每条消息最多携带50个话单。 请求方向 隐私保护通话平台（服务端） → 客户 服务器 （客户端） 使用说明 前提条件 客户添

查看更多 →

AXB模式话单通知接口 接口功能 用户通话结束后，隐私保护通话平台通过此接口向客户推送通话的话单信息。短时间内有多个通话结束时隐私保护通话平台会将话单合并推送，每条消息最多携带50个话单。 请求方向 隐私保护通话平台（客户端） → 客户服务器（服务端） 使用说明 前提条件 客户添

查看更多 →

AXYB模式话单通知接口 接口功能 用户通话结束后，隐私保护通话平台通过此接口向客户推送通话的话单信息。短时间内有多个通话结束时隐私保护通话平台会将话单合并推送，每条消息最多携带50个话单。 请求方向 隐私保护通话平台（服务端） → 客户服务器（客户端） 使用说明 前提条件 客户

查看更多 →

AX模式话单通知接口 接口功能 用户通话结束后，隐私保护通话平台通过此接口向客户推送通话的话单信息。短时间内有多个通话结束时隐私保护通话平台会将话单合并推送，每条消息最多携带50个话单。 请求方向 隐私保护通话平台（服务端） → 客户服务器（客户端） 使用说明 前提条件 客户添加

查看更多 →

X模式话单通知接口 接口功能 用户通话结束后，隐私保护通话平台通过此接口向客户推送通话的话单信息。短时间内有多个通话结束时隐私保护通话平台会将话单合并推送，每条消息最多携带50个话单。 请求方向 隐私保护通话平台（服务端） → 客户服务器（客户端） 使用说明 前提条件 客户添加应

查看更多 →

基于表单上传(Java SDK) 功能说明 基于表单上传是使用HTML表单形式上传对象到指定桶中，对象最大不能超过5GB。 您可以通过ObsClient.createPostSignature生成基于表单上传的请求参数。使用代码模拟表单上传的完整代码示例，参见PostObject

查看更多 →

单流录制模式和合流录制模式有什么区别？ 单流和合流录制模式的主要区别如下： 单流录制：支持将房间中的每一个用户的音视频流分别录制成独立的文件。例如，在线课堂场景中，若家长只想观看老师和自己孩子的视频，则可以选择单流模式，分别录制老师和每位学生的视频，然后将老师的视频分别与每位学生

查看更多 →

。 本文档所述Demo仅用于功能演示，不允许客户直接进行商业使用。 本文档信息仅供参考，不构成任何要约或承诺。 父主题： 语音验证码代码样例

查看更多 →

//模板1变量，此处以单变量验证码短信为例，请客户自行生成6位验证码，并定义为字符串类型，以杜绝首位0丢失的问题（例如：002569变成了2569）。 String[] templateParas2 = {"234567"}; //模板2变量，此处以单变量验证码短信为例，请客户

查看更多 →

Java Java客户端接入示例 Java开发环境搭建

查看更多 →

LargeFileUploadDemo.java HttpClientDemo.java 引用类: Constant.java SSLCipherSuiteUtil.java UnsupportProtocolException.java 如果使用maven构建，可以使用SDK包中的libs\java-sdk-core-x

查看更多 →