org.apache.spark.sql.AnalysisException:引用'dattim'不明确,可能是:dattim#6,event_dattim#55。;

问题描述 投票:1回答:1

我有一个带有where子句的连接数据帧,dataStampe在一个范围内:

val startTime = new 
Timestamp(NewDate.atStartOfDay.toEpochSecond(ZoneOffset.UTC) * 1000)
val endTime = new 
Timestamp(NewDate.plusDays(1).atStartOfDay.toEpochSecond(ZoneOffset.UTC) * 
1000)

val joinedTable = table1.join(table2,
table1("date") === table1("key")
&& ....).where(table1("dattim") >= startTimestamp && table1("dattim") < endTimestamp)

它抱怨参考'dattim'含糊不清,我试图使用范围:

table1("tattim") === (startTime to endTime) 

它仍然没有接受它。有什么建议?

scala apache-spark hadoop
1个回答
0
投票

好像在两个数据框中都有相同的列名。只需使用其中一个列的别名。

© www.soinside.com 2019 - 2024. All rights reserved.