加入Dataframes在星火
问题描述:
我在火花使用下面的代码连接的两个Dataframes -加入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识别塔,从数据帧。
答
您只需使用as
or alias
方法向列添加别名即可。这将完成这项工作:
expDetails.select(
$"fex.acct_id".as("fex_acct_id"),
$"acct_id.acct_id".as("acctlist_acct_id")
).show
它的工作正常。 – Avijit