大数据实战手册-开发篇之RDD:计算 transform->action
2.2 RDD:计算 transform->action 2.2.1 aggregate x = sc.parallelize([2,3,4], 2)[Task不能跨分片，task数为2] neutral_zero_value = (0,1) sum: x+0 = x, pro ......使用PySpark计算AUC,KS与PSI
当特征数量或者模型数量很多的时候，使用PySpark去计算相关指标会节省很多的时间。网上关于使用PySpark计算相关指标的资料较少，这里抛砖引玉，写了三个风控常用的指 ......SpringBoot3集成ElasticSearch
目录 一、简介 二、环境搭建 1、下载安装包 2、服务启动 三、工程搭建 1、工程结构 2、依赖管理 3、配置文件 四、基础用法 1、实体类 2、初始化索引 3、仓储接口 4、查询语法 ......![]()
尚医通day13【预约挂号】（内附源码）
页面预览 根据预约周期，展示可预约日期，根据有号、无号、约满等状态展示不同颜色，以示区分 可预约最后一个日期为即将放号日期 选择一个日期展示当天可预约列表 ......![]()
nlp入门（四）新闻分类实验
源码请到：自然语言处理练习: 学习自然语言处理时候写的一些代码 (gitee.com) 数据来源： 搜狗新闻语料库 由于链接失效，现在使用百度网盘分享 链接：https://pan.ba ......![]()
Python下载课件
from urllib.request import urlretrieve 下载网络文件到本地 import os os.chdir("C:/Users/RankFan/Desktop/空间计量经济学") for i in range(4, 6): ......【基因组注释】ncRNA注释
目录 1. ncRNA 2. 软件 tRNA注释 rRNA注释 其他ncRNA注释 3. 注释 tRNA rRNA snRNA、miRNA等 4. snRNA、miRNA等结果的统计 1. ncRNA 非编码RNA(Non-coding RNA, n ......![]()
5-Pandas数据分组的函数应用（df.apply()、df.agg()和df.transform()、df.applymap()）
将自己定义的或其他库的函数应用于Pandas对象，有以下3种方法： apply()：逐行或逐列应用该函数 agg()和transform()：聚合和转换 applymap()：逐元素应用函数 一 、app ......MySQL和sparkSQL合并行
表A 表B 从表A到表B MySQL 写法：select name, group_concat(score seperate ';') as score from A group by name spark 写法：df.groupBy('name').agg(collec ......![]()
Flink 运行时架构
参考链接：https://blog.csdn.net/dajiangtai007/article/details/88575553 1、Flink 运行时架构 Flink 运行时架构主要包含几个部分：Client、JobManager（master节点 ......![]()
↓ 按住下拉
V2AS = Way To Ask
V2AS 一个技术分享与创造的静土
手机扫一扫
移动阅读更方便
近15日热搜文章