spark常用RDD算子 - filter

news/2023/6/5 22:25:06

个人理解就是筛选出需要的结果
例:文件内容 ,需求:将包含zks的行的内容给找出来

aa bb cc aa aa aa dd dd ee ee ee ee 
ff aa bb zks
ee kks
ee zz zks

代码示例

String path="E:\\txtFile2\\sample.txt";
JavaRDD<String> stringJavaRDD = javaSparkContext.textFile(path);JavaRDD<String> zks = stringJavaRDD.filter(new Function<String, Boolean>() {@Overridepublic Boolean call(String s) throws Exception {//return s.indexOf("zks") > -1;//或return s.contains("zks");}});
System.out.println(zks.collect());

返回的结果

ff aa bb zks 
​​​​​​​ee zz zks

 


https://dhexx.cn/news/show-18489.html

相关文章

【Python】照片居然能变素描?不会画画但是咱会代码

文章目录前言一、准备二、下载预训练模型总结前言 Photo-Sketching 一个能将照片的轮廓识别出来并将其转化为“速写”型图像的开源模块。 比如&#xff0c;这只小狗&#xff1a; 经过模型的转化&#xff0c;会变成卡通版的小狗&#xff1a; 非常秀&#xff0c;这很人工智能…

html中伪类作用,在Html中,css伪类和伪元素到底有什么区别,怎么使用呢?

区别为了区分&#xff0c;我们可以把伪类比作太监&#xff0c;把伪元素比作皇帝。1、表示不同伪类是一个冒号&#xff0c;而伪元素是两个冒号&#xff0c;等于比伪类多了两个点。也就是说皇帝比太监要多了个不明物体&#xff01;2、数量不同。众所周知&#xff0c;一个朝代皇帝…

【转】预测编码

原文地址&#xff1a;http://wenku.baidu.com/view/8cd8e219a2161479171128f7.html 1.1 定义 预测编码是数据压缩理论的一个重要分支。根据离散信号之间存在一定相关性特点&#xff0c;利用前面的一个或多个信号对下一个信号进行预测&#xff0c;然后对实际值和预值的差&#x…

selectKey返回最近插入的id

SelectKey返回最近插入的id一、第一种使用实体类对象1.sql获取2.测试数据3.结果截图二、第二种使用Map2.测试数据3.结果截图一、第一种使用实体类对象 1.sql获取 <insert id"addUser" >insert into user (username,password,name,create_time,sex,phone,depar…

2005年江苏专转本计算机解析,2005-2012年江苏专转本计算机基础历年真题__附答案...

2005-2012年江苏专转本计算机基础历年真题__附答案 (72页)本资源提供全文预览&#xff0c;点击全文预览即可全文预览,如果喜欢文档就下载吧&#xff0c;查找使用更方便哦&#xff01;19.90 积分2005-2012年江苏专转本计算机基础历年真题目录2005年“专转本”计算机应用基础统一…

将html转换为word文档的几种方式

1 基于wps直接将页面信息下载成word文档 1 public void test()2 {3 4 WPS.Application wps null;5 try6 {7 wps new WPS.Application();8 }9 catch (Exception ex) 10 { …

xp系统打印机服务器不可用,WinXP系统添加打印机操作无法完成如何解决?

最近有WinXP系统用户反映&#xff0c;添加打印机的时候&#xff0c;出现提示“操作无法完成。打印后台程序服务没有运行”&#xff0c;导致打印机添加失败&#xff0c;用户并不知道这是怎么回事&#xff0c;也不知道该如何解决&#xff0c;为此非常苦恼。下面&#xff0c;针对这…

SpringBoot整合SpringSecurity+Redis权限控制

SpringBoot整合SpringSecurityRedis权限控制1、认识SpringSecurity2、效果截图2.1、登录接口2.2、注册接口2.3、管理员权限接口2.4、普通用户权限接口2.5、公共接口接口2.6、Redis缓存效果3、前期准备工作3.1、导入相关依赖3.2、创建数据库4、核心逻辑5、项目结构6、代码6.1、E…

unturned服务器消息设置,unturned服务器怎么设置

unturned服务器怎么设置 内容精选换一换企业主机安全通过云审计服务(Cloud Trace Service&#xff0c;CTS)为用户提供云服务资源的操作记录&#xff0c;记录内容包括用户从管理控制台或者开放API发起的云服务资源操作请求以及每次请求的结果&#xff0c;供用户查询、审计和回溯…

XSS与字符编码的那些事儿

目录 0x00:基本介绍 0x01:html实体编码 0x02:新增的实体编码 实体编码变异以及浏览器的某些工作原理&#xff01; 0x03:javascript编码 0x04:base64编码 0x05:闲扯0x00基本介绍 提起XSS 想到的就是插入字符字符编码与各种解析了&#xff01; 这也就是各种xss编码插件跟工具出世…