pyspark样例代码 开发说明 支持对接CloudTable的OpenTSDB和 MRS 的OpenTSDB。 前提条件 在 DLI 管理控制台上已完成创建跨源连接。具体操作请参考《 数据湖探索 用户指南》。 认证用的password硬编码到代码中或者明文存储都有很大的安全风险，建议在配置

查看更多 →

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

查看更多 →

获取代码样例 语音通话平台提供代码样例作为参考，可根据需求更改适配，快速开发，提高开发效率，节省开发时间。 语音回呼代码样例 Node.js：点击查看 Java：点击查看 Python：点击查看 PHP：点击查看 C#：点击查看 语音通知代码样例 Node.js：点击查看 Java：点击查看

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

语音通知代码样例 Node.js Java Python PHP C# 父主题： 线下开发

查看更多 →

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

查看更多 →

Node.js代码样例 AXB模式 AX模式 AXE模式 AXYB模式 父主题： 代码样例

查看更多 →

配置代码检查任务检查模式 您可以根据实际需求设置检查模式和检查目录，提高检查效率。 C#语言和secbrella引擎均不支持MR合入。 设置检查模式 基于项目入口访问CodeArts Check服务首页。 进入代码检查页面，在任务列表中，单击任务名称。 进入“代码检查详情”页面，选择“设置

查看更多 →

Flink异步Checkpoint Java样例代码 代码样例 假定用户需要每隔1秒钟需要统计4秒中窗口中数据的量，并做到状态严格一致性。 快照数据 该数据在算子制作快照时，用于保存到目前为止算子记录的数据条数。 1 2 3 4 5 6 7 8 9 10 11 12

查看更多 →

job，并提交MapReduce作业到hadoop集群。 代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.mapreduce.examples.FemaleInfoCollector类： 样例1：类CollectionMapper定义Mapper抽

查看更多 →

HBase SQL查询样例代码说明 功能简介 Phoenix是构建在HBase之上的一个SQL中间层，提供一个客户端可嵌入的JDBC驱动，Phoenix查询引擎将SQL输入转换为一个或多个HBase scan，编译并执行扫描任务以产生一个标准的JDBC结果集。 代码样例 客户端“hbas

查看更多 →

job，并提交MapReduce作业到hadoop集群。 代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.mapreduce.examples.FemaleInfoCollector类： 样例1：类CollectionMapper定义Mapper抽

查看更多 →

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

查看更多 →

Flink异步Checkpoint Scala样例代码 代码样例 假定用户需要每隔1秒钟需要统计4秒中窗口中数据的量，并做到状态严格一致性。 发送数据形式 1 case class SEvent(id: Long, name: String, info: String, count:

查看更多 →

创建表的具体步骤，请参考创建HBase集群。 下载样例代码，然后参考准备开发环境章节准备开发环境。 如果您不准备使用样例代码的工程，需要将下载的样例代码中“cloudtable-example\lib”目录下的jar包拷贝到您的项目中，并在项目工程中将这些Jar包添加到依赖路径中。 数据表复制样例代码 用户可以根据实际的业务需求基于HBase

查看更多 →

job，并提交MapReduce作业到hadoop集群。 代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.mapreduce.examples.FemaleInfoCollector类： 样例1：类CollectionMapper定义Mapper抽

查看更多 →

job，并提交MapReduce作业到hadoop集群。 代码样例 下面代码片段仅为演示，具体代码参见com.huawei.bigdata.mapreduce.examples.FemaleInfoCollector类： 样例1：类CollectionMapper定义Mapper抽

查看更多 →

Flink DataStream Scala样例代码 功能简介 实时统计连续网购时间超过2个小时的女性网民信息，将统计结果直接打印出来。 样例代码 下面代码片段仅为演示，具体代码参见com.huawei.flink.example.stream.FlinkStreamScalaExample：

查看更多 →