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

查看更多 →

Java样例代码 下面列出的主要逻辑代码作为演示。 完整代码请参阅： com.huawei.bigdata.flink.examples.UserSource。 com.huawei.bigdata.flink.examples.TestPipelineNettySink。 com

查看更多 →

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

查看更多 →

Java样例代码 下面代码片段仅为演示，具体代码参见：com.huawei.spark.examples.HBaseExternalHivetoCarbon。 public static void main(String[] args) throws Exception { spark

查看更多 →

Java样例代码 下面列出的主要逻辑代码作为演示。 完整代码请参阅： com.huawei.bigdata.flink.examples.UserSource。 com.huawei.bigdata.flink.examples.TestPipelineNettySink。 com

查看更多 →

statementSet.execute(); } } 需将当前样例需要的依赖包，即编译之后lib文件下面的jar包拷贝到客户端的lib文件夹内。 以对接普通模式Kafka提交SQL为例： create table kafka_sink ( uuid varchar(20)

查看更多 →

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

查看更多 →

java样例代码 开发说明 mongo只支持增强型跨源。只能使用包年包月队列。 DDS即文档数据库服务，兼容MongoDB协议。 前提条件 在 DLI 管理控制台上已完成创建增强跨源连接，并绑定包年/包月队列。具体操作请参考《 数据湖探索 用户指南》。 认证用的password硬编码到代

查看更多 →

java样例代码 开发说明 本样例只适用于 MRS 的OpenTSDB。 前提条件 在DLI管理控制台上已完成创建跨源连接并绑定队列。具体操作请参考《 数据湖 探索用户指南》。 认证用的password硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全。

查看更多 →

java样例代码 开发说明 本样例只适用于MRS的HBase。 前提条件 在DLI管理控制台上已完成创建跨源连接并绑定队列。具体操作请参考《数据湖探索用户指南》。 认证用的password硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全。

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

多媒体文件下载 媒体文件删除 单卡片5G消息发送 带建议回复消息的多卡片5G消息 码流转成json的多卡片+悬浮菜单 父主题： API代码样例

查看更多 →