如何使用減法鍵計算多個列

Question

我試圖計算兩個單獨列中每個鍵的總數。

我拉了兩列從卡桑德拉有：

val data = sc.cassandraTable("Meter","Measured_Value").where("\"Time_Key\" = 1601822").select("Power","Start_Frequency") 

從我試過映射兩列，並使用reduceByKey，但似乎無法得到正常的映射。

我想我需要映射以下，但似乎無法使其工作：

power:Float => power,1 
frequency:Double => frequency,1 

然後做一個.reduceByKey(_ + _)

但我猜。任何幫助的語法將不勝感激。

Answer 1

試試這個：

val data: RDD[(Float,Double)] = sc.cassandraTable("Meter","Measured_Value") 
      .where("\"Time_Key\" = 1601822") 
      .select("Power","Start_Frequency") 
      .as((_:Float,_:Double)) 

val reduced: RDD[(Float,Double)] = data.reduceByKey{ case(left, right) => left + right}