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

查看更多 →

Python样例代码 下面代码片段仅为演示，具体代码参见：HudiPythonExample.py。 插入数据： #insert inserts = sc._jvm.org.apache.hudi.QuickstartUtils.convertToStringList(dataGen

查看更多 →

Python样例代码 功能简介 统计日志文件中本周末网购停留总时间超过2个小时的女性网民信息。 代码样例 下面代码片段仅为演示，具体代码参见SparkSQLPythonExample： # -*- coding:utf-8 -*- import sys from pyspark

查看更多 →

Python样例代码 功能介绍 用户可以使用Spark调用HBase接口来操作HBase table1表，然后把table1表的数据经过分析后写到HBase table2表中。 代码样例 由于pyspark不提供Hbase相关api，本样例使用Python调用Java的方式实现。

查看更多 →

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

查看更多 →

Python样例代码 功能介绍 用户可以使用Spark调用HBase接口来操作HBase table1表，然后把table1表的数据经过分析后写到HBase table2表中。 代码样例 由于pyspark不提供Hbase相关api，本样例使用Python调用Java的方式实现。

查看更多 →

Python样例代码 功能介绍 在Spark应用中，通过使用Spark调用Hive接口来操作hive表，然后把Hive表的数据经过分析后写到HBase表。 代码样例 由于pyspark不提供Hbase相关api，本样例使用Python调用Java的方式实现。 下面代码片段仅为演示

查看更多 →

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

查看更多 →

Python样例代码 下面代码片段仅为演示，具体代码参见：HudiPythonExample.py。 插入数据： #insert inserts = sc._jvm.org.apache.hudi.QuickstartUtils.convertToStringList(dataGen

查看更多 →

Python样例代码 功能简介 统计日志文件中本周末网购停留总时间超过2个小时的女性网民信息。 代码样例 下面代码片段仅为演示，具体代码参见collectFemaleInfo.py： def contains(str, substr): if substr in str:

查看更多 →

Python样例代码 功能简介 统计日志文件中本周末网购停留总时间超过2个小时的女性网民信息。 代码样例 下面代码片段仅为演示，具体代码参见SparkSQLPythonExample： # -*- coding:utf-8 -*- import sys from pyspark

查看更多 →

Python3样例代码 通过HSBroker方式访问Hive数据源 通过HSFabric方式访问Hive数据源 父主题： 开发程序

查看更多 →

Python3样例代码 通过HSBroker实现用户名密码认证 通过HSFabric实现用户名密码认证 通过HSFabric实现KeyTab文件认证 父主题： 开发程序

查看更多 →

HBase python样例代码调测 仅MRS 1.9.x及之前版本支持HBase python样例代码调测。 HBase支持使用自带的ThriftServer2服务通过python来访问HBase服务。python样例仅支持在Linux环境中运行，调测HBase python样例程序

查看更多 →

下载SDK的最新版本，获取“ApiGateway-python-sdk.zip”压缩包，解压后目录结构如下： 名称 说明 apig_sdk\__init__.py SDK代码 apig_sdk\signer.py main.py 示例代码 backend_signature.py 后端签名示例代码 licenses\license-requests

查看更多 →

Python 环境要求 Python 3.0及以上版本。 引用库 requests 2.18.1 请自行下载安装Python 3.x，并完成环境配置。 打开命令行窗口，执行pip install requests命令。 执行pip list查看安装结果。 本文档所述Demo在提供

查看更多 →

Python 样例 发送短信示例、发送分批短信示例、接收状态报告示例、 环境要求 基于Python 3.7.0版本，要求Python 3.7及以上版本。 发送短信为单模板群发短信示例，发送分批短信为多模板群发短信示例。 本文档所述Demo在提供服务的过程中，可能会涉及个人数据的使

查看更多 →

Python 简介 开始工程 构建环境 编辑代码 浏览代码 搜索代码 代码校验 测试 调试 启动配置

查看更多 →

Python 由于Spark开源版本升级，为避免出现API兼容性或可靠性问题，建议用户使用配套版本的开源API。 Spark Core常用接口 Spark主要使用到如下这几个类： pyspark.SparkContext：是Spark的对外接口。负责向调用该类的python应用提

查看更多 →

Python 由于Spark开源版本升级，为避免出现API兼容性或可靠性问题，建议用户使用配套版本的API。 Spark Core常用接口 Spark主要使用到如下这几个类： pyspark.SparkContext：是Spark的对外接口。负责向调用该类的python应用提供S

查看更多 →

Python 环境要求 Python 3.0及以上版本。 引用库 requests 2.18.1 请自行下载安装Python 3.x，并完成环境配置。 打开命令行窗口，执行pip install requests命令。 执行pip list查看安装结果。 本文档所述Demo在提供

查看更多 →