У меня есть следующие два RDD:
JavaPairRDD<Tuple2<String, String>, Long>
, который представляет (State, City) -> Average Price of Home in City
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>>
для выполнения вышеприведенного.
Какую серию преобразований я должен выполнить, чтобы получить желаемый результат?