Hi all,
So I Have two dataframes, with two columns: DATE and VALUE.
Performing this:
data = data.join(cur_data, data("DATE") === cur_data("DATE"), "outer")
returns
Exception in thread "main" org.apache.spark.sql.AnalysisException: Reference
'DATE' is ambiguous, could be: DATE#0, DATE#3.;
But
Saif,
Might be you can rename one of the dataframe to different name first, then
do an outer join and a select like this:
val cur_d = cur_data.toDF("Date_1", "Value_1")
val r = data.join(cur_d, data("DATE" === cur_d("Date_1",
"outer").select($"DATE", $"VALUE", $"Value_1")
Thanks,
Terry
On Tue,
