Add value transform to Iceberg ColumnTransform

`io.trino.spi.connector.BucketFunction` interface is currently per-position. Let `ColumnTransform` define both block-based and block,position-based transforms.
trinodb · Nov 4, 2021 · 863da2b · 863da2b
1 parent f709aae
commit 863da2b
Show file tree

Hide file tree

Showing 3 changed files with 193 additions and 53 deletions.
diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergPageSink.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergPageSink.java
@@ -397,7 +397,7 @@ private static List<PartitionColumn> toPartitionColumns(List<IcebergColumnHandle
                     checkArgument(channel != null, "partition field not found: %s", field);
                     Type inputType = handles.get(channel).getType();
                     ColumnTransform transform = getColumnTransform(field, inputType);
-                    return new PartitionColumn(field, channel, inputType, transform.getType(), transform.getTransform());
+                    return new PartitionColumn(field, channel, inputType, transform.getType(), transform.getBlockTransform());
                 })
                 .collect(toImmutableList());
     }