-
Notifications
You must be signed in to change notification settings - Fork 3k
Core: Add data sequence number as derived column to files metadata table #9813
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
flink/v1.16/flink/src/test/java/org/apache/iceberg/flink/source/TestFlinkMetaDataTable.java
Show resolved
Hide resolved
|
@szehon-ho @aokolnychyi if you want to take a look? |
szehon-ho
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks @dramaticlly for the work! I left some comments to see if we can make the code cleaner.
|
Let me take a quick look today as well. |
| @Override | ||
| public Schema schema() { | ||
| StructType partitionType = Partitioning.partitionType(table()); | ||
| // avoid returning an empty struct, which is not always supported. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I am a bit lost with all the schemas here. Let me see if we can simplify this block.
|
closed in favor of #10203 |
This PR add data_sequence_number as derived/virtual column on all files metadata table, enables query like
without change the avro schema for files.