Feature Request / Improvement
Motivation
Apache Flink supports CALL sql statements to call a stored procedure which can perform administrative tasks. I want to implement something similar to Paimon's procedures in Iceberg.
The idea is to make snapshot references easier to manage directly from Flink SQL.
Implemented procedures
create_tag
delete_tag
create_tag_from_timestamp
create_branch
delete_branch
rollback_to
rollback_to_timestamp
expire_snapshots
We can add more in the future, something like rename_tag or list_snapshots etc.
Example usage
CALL sys.create_tag('tableId', 'tagName', snapshotId, 'timeRetained')
This made branch/tag workflows much more convenient in Flink SQL.
Query engine
Flink
Willingness to contribute
Feature Request / Improvement
Motivation
Apache Flink supports CALL sql statements to call a stored procedure which can perform administrative tasks. I want to implement something similar to Paimon's procedures in Iceberg.
The idea is to make snapshot references easier to manage directly from Flink SQL.
Implemented procedures
create_tagdelete_tagcreate_tag_from_timestampcreate_branchdelete_branchrollback_torollback_to_timestampexpire_snapshotsWe can add more in the future, something like
rename_tagorlist_snapshotsetc.Example usage
CALL sys.create_tag('tableId', 'tagName', snapshotId, 'timeRetained')This made branch/tag workflows much more convenient in Flink SQL.
Query engine
Flink
Willingness to contribute