diff --git a/ice/src/main/java/com/altinity/ice/cli/internal/iceberg/Partitioning.java b/ice/src/main/java/com/altinity/ice/cli/internal/iceberg/Partitioning.java
index 3a8e826..d65abc4 100644
--- a/ice/src/main/java/com/altinity/ice/cli/internal/iceberg/Partitioning.java
+++ b/ice/src/main/java/com/altinity/ice/cli/internal/iceberg/Partitioning.java
@@ -281,6 +281,13 @@ public static Map<PartitionKey, List<org.apache.iceberg.data.Record>> partition(
             continue;
           }
           String transformName = transform.toString();
+
+          if (transformName.startsWith("bucket[") || transformName.startsWith("truncate[")) {
+            partitionRecord.setField(
+                sourceFieldName, toGenericRecordFieldValue(value, fieldSpec.type()));
+            continue;
+          }
+
           switch (transformName) {
             case "hour", "day", "month", "year":
               if (fieldSpec.type().typeId() != Type.TypeID.DATE) {