-
Notifications
You must be signed in to change notification settings - Fork 3k
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
Add support iceberg parquet predicate pushdown with iceberg column id #19066
Add support iceberg parquet predicate pushdown with iceberg column id #19066
Conversation
Do we have a test to check this problem? I found we don't have enough test about iceberg nested type and schema evolution. @findinpath |
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.
Change looks good but please add a test, for example to BaseIcebergConnectorTest
that actually checks the behaviour.
This pull request has gone a while without any activity. Tagging the Trino developer relations team: @bitsondatadev @colebow @mosabua |
👋 @Heltman @findinpath and @homar could you please collaborate on the test needs for this PR to move it forward. |
plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergPageSourceProvider.java
Show resolved
Hide resolved
@Heltman pls add a test for your changes / reuse the test I suggested and also rebase on Thank you very much for your contribution. |
plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergPageSourceProvider.java
Outdated
Show resolved
Hide resolved
plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergPageSourceProvider.java
Outdated
Show resolved
Hide resolved
plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergPageSourceProvider.java
Outdated
Show resolved
Hide resolved
2427995
to
4b7f6da
Compare
4b7f6da
to
05f81ee
Compare
Sorry I don't check email. I'm glad this issue is resolved. Thanks for @findinpath and all members. |
Awesome work on completing this together @findinpath @Heltman and @raunaqmorarka |
Description
Fixes #18855.
IcebergPageSourceProvider.getParquetTupleDomain
get domain by column name. When column renamed in iceberg, this result is empty. We should use iceberg column id to match parquet column instead.Additional context and related issues
Release notes
( ) This is not user-visible or is docs only, and no release notes are required.
( ) Release notes are required. Please propose a release note for me.
(x) Release notes are required, with the following suggested text: