delta-io/delta

Unable to write metadata to delta table using scala api

Closed

#857 opened on Dec 7, 2021

 (15 comments) (9 reactions) (2 assignees)Scala (2,159 forks)batch import
enhancementgood first issuestale

Repository metrics

Stars
 (8,950 stars)
PR merge metrics
 (PR metrics pending)

Description

Extension to #321

When using an api like the one below, the only supported method to write metadata is through the use of the sparkSession which works until a single spark session is performing multiple writes simultaneously. In this case, manipulating the spark session still doesn't provide the ability to pass accurate metadata to the table. Could we find a way to ensure metadata writes are possible at the writer level even when using the following syntax? Thanks

cc @zsxwing

DeltaTable.forPath(target.tableLocation).alias("target")
  .merge(updatesDF, mergeCondition)
  .whenMatched
  .updateAll()
  .whenNotMatched
  .insertAll()
  .execute()

Thank you

Contributor guide