Как преобразовать:Scala Map [(String, String), Int] построить соответствующую MAP [String, String]
(Map(UserLang -> en, UserName -> a),1)
(Map(UserLang -> jp, UserName -> b),1)
в
(UserLang -> en, UserName -> a)
(UserLang -> jp, UserName -> b)
Как это сделать с помощью функционального программирования
Я делаю это в искры, используя scala, ваш пример дал мне идею по крайней мере, как туда поступить, спасибо :) – Anand
Если вы расширите свой вопрос, я также могу добавить более подробные сведения к моему ответу :) Тогда мы также можем помочь люди, которые могут столкнуться с этой проблемой в будущем! –
http://stackoverflow.com/questions/38333479/exception-org-apache-spark-rdd-rddscala-collection-immutable-mapstring-any после получения указателя, я могу разделить желаемую карту, используя нижеприведенный код : topCounts60.foreachRDD (РДД => { для (п <- rdd.keys.collect() ToArray) { Println (пункт); } .}) – Anand