在spark中利用filter过滤掉第二个字母不是e的单词
时间: 2024-05-02 08:21:42 浏览: 75
假设有一个RDD包含单词,可以使用filter操作符来过滤掉第二个字母不是e的单词,示例代码如下:
```
val wordsRDD = sc.parallelize(Seq("hello", "world", "apple", "pear", "eye"))
val filteredWordsRDD = wordsRDD.filter(word => word.length > 1 && word.charAt(1) == 'e')
filteredWordsRDD.foreach(println)
```
输出结果为:
```
hello
eye
```
在上面的代码中,首先创建一个包含单词的RDD。然后,使用filter操作符过滤掉长度小于等于1的单词以及第二个字母不是e的单词。最后,使用foreach操作符打印过滤后的单词。
阅读全文