2016-07-13 22 views
1

我使用下面的代碼獲得suppId數據幀的數據幀的列值。如何添加其中使用火花另一個數據幀的第斯卡拉

val suppId = sqlContext.sql("SELECT supp_id FROM supplier") 

DataFrame返回單個或多個值。

現在我想創建一個使用從suppId數據框中supp_id值的數據幀。但不明白,如何寫這個。

我已經寫了下面的代碼。但代碼不起作用。

val nonFinalPE = sqlContext.sql("select * from pmt_expr) 
nonFinalPE.where("supp_id in suppId(supp_id)") 

回答

1

我花了我一秒的時間來弄清楚你想要做什麼。但是,它看起來像是來自nonFinalPe中的行也在suppId中。你會做一個內得到這個加入哪個看起來像下面

val suppId = sqlContext.sql("SELECT supp_id FROM supplier") 
val nonFinalPE = sqlContext.sql("select * from pmt_expr") 

val joinedDF = nonFinalPE.join(suppId, nonFinalPE("???") === suppId("supp_id"), "inner") 
+0

這是工作的兩個數據幀的.. 我的代碼是這樣的: VAL joinedDF = nonFinalPE.join(suppId,nonFinalPE( 「supp_id」)=== suppId(「supp_id」),「inner」) – Avijit

相關問題