1.
准备文本文件
从文件创建RDD lines=sc.textFile()
筛选出含某个单词的行 lines.filter()
lambda 参数：条件表达式
2.
生成单词的列表
从列表创建RDD words=sc.parallelize()
筛选出长度大于2 的单词 words.filter()
相关文章
- 10-07RDD编程 下（Spark自学四）
- 10-07在SPARK中实现RDD编程
- 10-07spark教程(四)-python基础编程
- 10-07spark RDD编程，scala版本
- 10-071.7编程基础之字符串03:基因相关性
- 10-07大数据学习day20-----spark03-----RDD编程实战案例（1 计算订单分类成交金额，2 将订单信息关联分类信息，并将这些数据存入Hbase中，3 使用Spark读取日志文件，根据Ip地址，查询地址对应的位置信息
- 10-07Spark基础脚本入门实践3:Pair RDD开发
- 10-07前端开发工程师 - 03.DOM编程艺术 - 第1章.基础篇(下)
- 10-07【原创】大数据基础之Spark（6）Spark Rdd Sort实现原理
- 10-07Spark RDD/Core 编程 API入门系列 之rdd案例（map、filter、flatMap、groupByKey、reduceByKey、join、cogroupy等）（四）