Я могу печатать данные в двух RDD с помощью приведенного ниже кода.
usersRDD.foreach(println)
empRDD.foreach(println)
Мне нужно сравнить данные в двух СДР. Как я могу повторять и сравнивать данные поля в одном RDD с данными поля в другом RDD. Например: повторите записи и проверьте, имеют ли имя и возраст в userRDD
совпадающую запись в empRDD
, если они не помещены в отдельный RDD.
Я пробовал с userRDD.substract(empRDD)
, но он сравнивал все поля.