來自SQL的PairRDD

Question

是否可以從下面的SQL查詢中獲得一對RDD？ （（item_id，flight_id），metric1）
item_id，flight_id是group by的組成部分。

SELECT 
    item_id, 
    flight_id, 
    SUM(metric1) AS metric1 
FROM mytable 
GROUP BY 
    item_id, 
    flight_id 

Answer 1

正如由eliasah提到你可以一個RDD簡單地映射在（與和查詢之間可選rddmap）如下：

sqlContext.sql(query).map{case Row(item_id: U, flight_id: V, metric1: T) => 
    ((item_id, flight_id), metric1)} 

凡T，U，V是類型的數據，sqlContext是一個SQLContext實例，查詢是在您的問題中提供的查詢。