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)")
這是工作的兩個數據幀的.. 我的代碼是這樣的: VAL joinedDF = nonFinalPE.join(suppId,nonFinalPE( 「supp_id」)=== suppId(「supp_id」),「inner」) – Avijit