org.apache.spark.sql.AnalysisException: Ссылка 'dattim' неоднозначна, может быть: dattim # 6, event_dattim # 55 .;

Question

У меня есть соединенные фреймы данных с предложением 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) 

это все еще не принимает это. какие-либо предложения?

Answer 1

Похоже, у вас одинаковое имя столбца в обоих фреймах. Просто используйте псевдоним для одного из столбцов.