79291268

Date: 2024-12-18 13:37:45
Score: 3.5
Natty:
Report link

Did the previous proposed answer work? I've got similar issue and only seems to work with one condition not two:

import delta Factevents = delta.DeltaTable.forPath(spark, 'abfss://*******************.dfs.core.windows.net/silver/C365/events/')

Merge new data

( Factevents.alias('events') .merge( dfNewData.alias('New'), "events.uprn = New.uprn AND events.id = New.id" ) .whenMatchedUpdateAll() .whenNotMatchedInsertAll() .execute() )

Reasons:
  • No code block (0.5):
  • Contains question mark (0.5):
  • Unregistered user (0.5):
  • Starts with a question (0.5): Did the
  • Filler text (0.5): *******************
  • Low reputation (1):
Posted by: Anthony Carroll