加入Dataframes在星火

Question

我在火花使用下面的代码连接的两个Dataframes -

Dataframes是：expDataFrame，为accountList

val expDetails = expDataFrame.as("fex").join(accountList.as("acctlist"),$"fex.acct_id" === $"acctlist.acct_id", "inner") 

现在我试图同时显示ACCT_ID从两个数据帧。

我在下面的代码做 -

expDetails.select($"fex.acct_id",$"acct_id.acct_id").show 

，但得到相同的列名的两倍ACCT_ID

我想两个独特的列名像fex_acct_id，acctlist_acct_id识别塔，从数据帧。

Answer 1

您只需使用as or alias方法向列添加别名即可。这将完成这项工作：

expDetails.select(
    $"fex.acct_id".as("fex_acct_id"), 
    $"acct_id.acct_id".as("acctlist_acct_id") 
).show