Skip to content

Commit 3a67a0a

Browse files
groupcache4321raunaqmorarka
authored andcommitted
Add product test case for predicate on recreated Iceberg column
1 parent a1fc0bb commit 3a67a0a

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

testing/trino-product-tests/src/main/java/io/trino/tests/product/iceberg/TestIcebergSparkCompatibility.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -806,6 +806,8 @@ public void testIdBasedFieldMapping(StorageFormat storageFormat, int specVersion
806806
.addField("added", null)
807807
.build(),
808808
1001L));
809+
// make sure predicates are also ID based
810+
assertThat(onTrino().executeQuery(format("SELECT keep_col FROM %s WHERE drop_and_add_col IS NULL", trinoTableName))).containsOnly(row(3L));
809811

810812
// smoke test for dereference
811813
assertThat(onTrino().executeQuery(format("SELECT a_struct.renamed FROM %s", trinoTableName))).containsOnly(row(11L));
@@ -818,6 +820,7 @@ public void testIdBasedFieldMapping(StorageFormat storageFormat, int specVersion
818820
assertThat(onTrino().executeQuery(format("SELECT keep_col FROM %s WHERE a_struct.renamed = 11", trinoTableName))).containsOnly(row(3L));
819821
assertThat(onTrino().executeQuery(format("SELECT keep_col FROM %s WHERE a_struct.keep = 12", trinoTableName))).containsOnly(row(3L));
820822
assertThat(onTrino().executeQuery(format("SELECT keep_col FROM %s WHERE a_struct.casesensitive = 14", trinoTableName))).containsOnly(row(3L));
823+
// make sure predicates are also ID based
821824
assertThat(onTrino().executeQuery(format("SELECT keep_col FROM %s WHERE a_struct.drop_and_add IS NULL", trinoTableName))).containsOnly(row(3L));
822825
assertThat(onTrino().executeQuery(format("SELECT keep_col FROM %s WHERE a_struct.added IS NULL", trinoTableName))).containsOnly(row(3L));
823826

0 commit comments

Comments
 (0)