Scala Spark ürününde şunlar yer almaz:

Question

"içerir" ifadelerini kullanarak, bir RDD içindeki tupl'leri filtreleyebilirsiniz. Ama "içermiyor" kullanarak bir RDD'yi filtrelemeye ne dersiniz?

val rdd2 = rdd1.filter(x => x._1 contains ".") 

Bunun için sözdizimini bulamıyorum. Mümkün ve DataFrame s kullanmıyorum varsayarak. Düzenli ve/veya filtre örnekleri ile nasıl yapılacağını göremiyorum.

Answer 1

O contains filtre yüklemi sadece olumsuzluk var:

val rdd2 = rdd1.filter(x => !(x._1 contains "."))