christianknoepfle opened a new issue, #13500:
URL: https://github.com/apache/iceberg/issues/13500
### Query engine
Spark
### Question
Hi,
in Delta I have an API for Delete/Update/Merge in Spark. So I can write
``mytable.delete(col("foo") === lit(2))`` (using Spark Expressions/Functions)
instead of doing it with pure SQL (String) ``DELETE FROM MYTABLE WHERE foo =
2`. Same for update and merge
([here](https://docs.delta.io/latest/delta-update.html#language-scala))
In Iceberg I only find SQL (String) examples and wondering whether there is
an API available where I can write my transformations using Spark functions.
The reason: In our app all transformations are based on Spark functions,
giving us the benefit of compile time checking for typos, separating
transformations easily into smaller functions that we can then weave together
etc. Would be great if we can avoid breaking this approach when dealing with
Iceberg tables.
Are there plans to offer something like that or am I just missing something
here?
Thanks a lot
Christian
--
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]
