Shira Bodenstein
02/14/2023, 12:40 PMDeltaTable.forPath(sparkSession, hdfsPath)
.alias("oldData")
.merge(data.alias("newData"), deltaMergeQuery)
.whenMatched()
.updateAll()
.whenNotMatched()
.insertAll()
.execute();
The deletion will be in a similar way.
Now to the question:
Since there are no partitions on the fields on the query, does it mean that Spark will have
to open and read all files?
Thanks in advance!JosephK (exDatabricks)
02/14/2023, 1:10 PMShira Bodenstein
02/15/2023, 6:05 AM