Я пытаюсь позвонить map
на PairRDD.Spark дает мне эту подпись:
map[U](f: (A,B) => U)
Я ожидал выполнить эту подпись с помощью:
pairRDD.map((k,v) => k) // minimalist example, I actually want something else
Это дает мне ошибку несоответствия типов, где Scala выводит все типы как"Ничего такого".Я не понимаю, почему это происходит.Когда я видел похожие подписи для других функций, таких как aggregate
, я смог использовать этот синтаксис.Почему этот синтаксис не работает в этом случае?