英文:
Filter a RDD in java to split into 2 new RDD
问题
我正试图筛选我的RDD,以便我可以创建2个新的RDD。
我的RDD包含数字和1个字符串。这个字符串有两个可能的值 - Yes
和 No
,是我想要筛选RDD的方式。
我知道在Python中我可以这样做:
rdd.filter(lambda x: x in ['Yes', 'No'])
但我想在Java中做到这一点,这可能吗?
英文:
I'm trying to filter my RDD so I can create 2 new RDDs
My RDD contains numbers and 1 string. This String has 2 possible values - Yes
and No
, is how i want to filter my RDD.
I know in python I can do this:
rdd.filter(rdd.contains(_))
but I want to do this in Java, is this possible ?
专注分享java语言的经验与见解,让所有开发者获益!
评论