-
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 for writer version 7 in Delta Lake #18423
Conversation
8e63e0b
to
c6c4cad
Compare
517a340
to
0557cbe
Compare
aa8b88d
to
47e20fc
Compare
47e20fc
to
8585ab9
Compare
Build is 🔴
|
8585ab9
to
525d238
Compare
1b11c0a
to
70b9faa
Compare
...rc/main/java/io/trino/tests/product/deltalake/TestDeltaLakeCheckConstraintCompatibility.java
Show resolved
Hide resolved
Addressed comments. |
fef0872
to
4f28fed
Compare
Rebased on master to resolve conflicts. |
plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeMetadata.java
Show resolved
Hide resolved
plugin/trino-delta-lake/src/test/resources/databricks/invariants_writer_feature/README.md
Outdated
Show resolved
Hide resolved
...rc/main/java/io/trino/tests/product/deltalake/TestDeltaLakeCheckConstraintCompatibility.java
Outdated
Show resolved
Hide resolved
...uct-tests/src/main/java/io/trino/tests/product/deltalake/TestDeltaLakeColumnMappingMode.java
Outdated
Show resolved
Hide resolved
...t-tests/src/main/java/io/trino/tests/product/deltalake/TestDeltaLakeDeleteCompatibility.java
Show resolved
Hide resolved
...rc/main/java/io/trino/tests/product/deltalake/TestDeltaLakeWriteDatabricksCompatibility.java
Show resolved
Hide resolved
...n/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/transactionlog/TableSnapshot.java
Outdated
Show resolved
Hide resolved
...lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakeMinioAndHmsConnectorSmokeTest.java
Outdated
Show resolved
Hide resolved
Addressed comments. |
a40eb59
to
47b3bb9
Compare
47b3bb9
to
fc24a16
Compare
26f18f4
to
0b81e20
Compare
@findepi @alexjo2144 Could you take another look when you have time? |
@@ -501,7 +502,7 @@ public LocatedTableHandle getTableHandle(ConnectorSession session, SchemaTableNa | |||
LOG.debug("Skip %s because the table contains unsupported reader features: %s", tableName, unsupportedReaderFeatures); | |||
return null; | |||
} | |||
verifySupportedColumnMapping(getColumnMappingMode(metadataEntry)); | |||
verifySupportedColumnMapping(getColumnMappingMode(metadataEntry, protocolEntry)); |
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.
Can this change go as a separate prep commit?
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.
Even if we separate a commit, the preparatory commit will contain almost all changes except for tests.
plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakePageSinkProvider.java
Outdated
Show resolved
Hide resolved
0b81e20
to
ee96b79
Compare
Rebased on master to resolve conflicts and added another commit to handle deletion vectors feature in protocol entry. |
Support the following writer features: * appendOnly * invariants * checkConstraints * changeDataFeed * columnMapping
ee96b79
to
dd46758
Compare
session, | ||
ImmutableSet.of(METADATA), | ||
ImmutableSet.of(METADATA, PROTOCOL), |
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.
This change likely breaks the checkpoint reading optimizations added in 06e1339
We should probably adopt the optimization to support or-ing multiple tuple domains.
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.
Please file an issue to https://github.com/trinodb/trino/issues/new
Description
Fixes #15873
Release notes
(x) Release notes are required, with the following suggested text: