scaladevspark commented on issue #4628:
URL: https://github.com/apache/iceberg/issues/4628#issuecomment-1109773271
thanks, this approach works, you just have to move the partitionedBy to the
create part, otherwise you cannot continue with append. So this works:
` val df = dfToWrite
.orderBy(TIME_KEY_COL)
.coalesce(1)
.writeTo(s"iceberg_catalog.$db.$table")
try {
df
.partitionedBy(col(TIME_KEY_COL))
.tableProperty("location", "somewhere").create()
} catchTableExists {
df.append()
}`
thanks again for helping me.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
