在java中过滤一个rdd,将其拆分为两个新的rdd

xoshrz7s  于 2021-05-29  发布在  Spark
关注(0)|答案(0)|浏览(284)

我正在尝试筛选我的rdd,以便可以创建2个新的rdd
我的rdd包含数字和一个字符串。此字符串有2个可能的值- Yes 以及 No ,这是我要如何过滤我的rdd。
我知道用python我可以做到:

rdd.filter(rdd.contains(_))

但是我想用java来实现,这可能吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题