Как присоединиться к этим СДР, если один ключ содержит другой?(кортежиэто первый ключ, А это второй ключ) - PullRequest
0 голосов
/ 25 октября 2018

У меня есть следующие два RDD:

  1. JavaPairRDD<Tuple2<String, String>, Long>, который представляет (State, City) -> Average Price of Home in City
  2. JavaPairRDD<String, Long>, который представляет State -> Average Price of Home in State

Я хотел бы получить в результате следующее:

City -> Average Price of Home in State of City, Average Price of Home in City

, чтобы потом я мог сопоставить значения с:

City -> (Average Price of Home in City - Average Price of Home in State of City).

Возвращаясь к типам, мне понадобится JavaPairRDD<String, Tuple2<Long, Long>> для выполнения вышеприведенного.

Какую серию преобразований я должен выполнить, чтобы получить желаемый результат?

...