From bd1117e2a446bd47456fb9fd8b37ec99248cd29a Mon Sep 17 00:00:00 2001
From: Hazmi <ialhazmim@gmail.com>
Date: Thu, 23 Jan 2025 14:10:22 +0300
Subject: [PATCH] Add support for delta timestamp_ntz datatype

Add support for TIMESTAMP_NTZ datatype columns in v3 delta tables.
---
 .../facebook/presto/delta/DeltaTypeUtils.java    |   3 ++-
 .../AbstractDeltaDistributedQueryTestBase.java   |   3 ++-
 .../presto/delta/TestDeltaIntegration.java       |  13 +++++++++++++
 ...e87-961c-e9e18a355eeb-c000.snappy.parquet.crc | Bin 0 -> 52 bytes
 .../_delta_log/.00000000000000000000.crc.crc     | Bin 0 -> 40 bytes
 .../_delta_log/.00000000000000000000.json.crc    | Bin 0 -> 40 bytes
 .../_delta_log/00000000000000000000.crc          |   1 +
 .../_delta_log/00000000000000000000.json         |   4 ++++
 ...b2-4e87-961c-e9e18a355eeb-c000.snappy.parquet | Bin 0 -> 5526 bytes
 ...2da-a737-4921ed7fc950-c000.snappy.parquet.crc | Bin 0 -> 52 bytes
 .../_delta_log/.00000000000000000000.crc.crc     | Bin 0 -> 40 bytes
 .../_delta_log/.00000000000000000000.json.crc    | Bin 0 -> 40 bytes
 .../_delta_log/00000000000000000000.crc          |   1 +
 .../_delta_log/00000000000000000000.json         |   4 ++++
 ...0d-42da-a737-4921ed7fc950-c000.snappy.parquet | Bin 0 -> 5526 bytes
 ...c94-a8bb-a437508996d7-c000.snappy.parquet.crc | Bin 0 -> 52 bytes
 .../_delta_log/.00000000000000000000.crc.crc     | Bin 0 -> 40 bytes
 .../_delta_log/.00000000000000000000.json.crc    | Bin 0 -> 40 bytes
 .../_delta_log/00000000000000000000.crc          |   1 +
 .../_delta_log/00000000000000000000.json         |   4 ++++
 ...a4-4c94-a8bb-a437508996d7-c000.snappy.parquet | Bin 0 -> 5521 bytes
 21 files changed, 32 insertions(+), 2 deletions(-)
 create mode 100644 presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/.part-00000-16ab4bfc-37b2-4e87-961c-e9e18a355eeb-c000.snappy.parquet.crc
 create mode 100644 presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/_delta_log/.00000000000000000000.crc.crc
 create mode 100644 presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/_delta_log/.00000000000000000000.json.crc
 create mode 100644 presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/_delta_log/00000000000000000000.crc
 create mode 100644 presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/_delta_log/00000000000000000000.json
 create mode 100644 presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/part-00000-16ab4bfc-37b2-4e87-961c-e9e18a355eeb-c000.snappy.parquet
 create mode 100644 presto-delta/src/test/resources/delta_v1/test-typing/.part-00000-4705e2d5-430d-42da-a737-4921ed7fc950-c000.snappy.parquet.crc
 create mode 100644 presto-delta/src/test/resources/delta_v1/test-typing/_delta_log/.00000000000000000000.crc.crc
 create mode 100644 presto-delta/src/test/resources/delta_v1/test-typing/_delta_log/.00000000000000000000.json.crc
 create mode 100644 presto-delta/src/test/resources/delta_v1/test-typing/_delta_log/00000000000000000000.crc
 create mode 100644 presto-delta/src/test/resources/delta_v1/test-typing/_delta_log/00000000000000000000.json
 create mode 100644 presto-delta/src/test/resources/delta_v1/test-typing/part-00000-4705e2d5-430d-42da-a737-4921ed7fc950-c000.snappy.parquet
 create mode 100644 presto-delta/src/test/resources/delta_v3/test-typing/.part-00000-994a8669-28a4-4c94-a8bb-a437508996d7-c000.snappy.parquet.crc
 create mode 100644 presto-delta/src/test/resources/delta_v3/test-typing/_delta_log/.00000000000000000000.crc.crc
 create mode 100644 presto-delta/src/test/resources/delta_v3/test-typing/_delta_log/.00000000000000000000.json.crc
 create mode 100644 presto-delta/src/test/resources/delta_v3/test-typing/_delta_log/00000000000000000000.crc
 create mode 100644 presto-delta/src/test/resources/delta_v3/test-typing/_delta_log/00000000000000000000.json
 create mode 100644 presto-delta/src/test/resources/delta_v3/test-typing/part-00000-994a8669-28a4-4c94-a8bb-a437508996d7-c000.snappy.parquet

diff --git a/presto-delta/src/main/java/com/facebook/presto/delta/DeltaTypeUtils.java b/presto-delta/src/main/java/com/facebook/presto/delta/DeltaTypeUtils.java
index b8d63cbfcf57f..e3c8f1d139227 100644
--- a/presto-delta/src/main/java/com/facebook/presto/delta/DeltaTypeUtils.java
+++ b/presto-delta/src/main/java/com/facebook/presto/delta/DeltaTypeUtils.java
@@ -41,6 +41,7 @@
 import io.delta.kernel.types.ShortType;
 import io.delta.kernel.types.StringType;
 import io.delta.kernel.types.StructType;
+import io.delta.kernel.types.TimestampNTZType;
 import io.delta.kernel.types.TimestampType;
 
 import java.math.BigDecimal;
@@ -230,7 +231,7 @@ else if (deltaType instanceof ShortType) {
         else if (deltaType instanceof StringType) {
             return createUnboundedVarcharType();
         }
-        else if (deltaType instanceof TimestampType) {
+        else if (deltaType instanceof TimestampType || deltaType instanceof TimestampNTZType) {
             return TIMESTAMP;
         }
 
diff --git a/presto-delta/src/test/java/com/facebook/presto/delta/AbstractDeltaDistributedQueryTestBase.java b/presto-delta/src/test/java/com/facebook/presto/delta/AbstractDeltaDistributedQueryTestBase.java
index ec77098e36312..efb81b24cd801 100644
--- a/presto-delta/src/test/java/com/facebook/presto/delta/AbstractDeltaDistributedQueryTestBase.java
+++ b/presto-delta/src/test/java/com/facebook/presto/delta/AbstractDeltaDistributedQueryTestBase.java
@@ -61,7 +61,8 @@ public abstract class AbstractDeltaDistributedQueryTestBase
             "test-lowercase",
             "test-partitions-lowercase",
             "test-uppercase",
-            "test-partitions-uppercase"
+            "test-partitions-uppercase",
+            "test-typing"
     };
 
     /**
diff --git a/presto-delta/src/test/java/com/facebook/presto/delta/TestDeltaIntegration.java b/presto-delta/src/test/java/com/facebook/presto/delta/TestDeltaIntegration.java
index 156b6fd06ee61..09cfedf3c4ce9 100644
--- a/presto-delta/src/test/java/com/facebook/presto/delta/TestDeltaIntegration.java
+++ b/presto-delta/src/test/java/com/facebook/presto/delta/TestDeltaIntegration.java
@@ -13,6 +13,7 @@
  */
 package com.facebook.presto.delta;
 
+import com.facebook.presto.Session;
 import com.google.common.base.Joiner;
 import org.testng.annotations.Test;
 
@@ -24,6 +25,7 @@
 import java.util.List;
 import java.util.concurrent.TimeUnit;
 
+import static com.facebook.presto.common.type.TimeZoneKey.UTC_KEY;
 import static java.lang.String.format;
 
 /**
@@ -247,6 +249,17 @@ public void readPartitionedTableAllDataTypes(String version)
         assertQuery(testQuery, expResultsQuery);
     }
 
+    @Test(dataProvider = "deltaReaderVersions")
+    public void testDeltaTimezoneTypeSupport(String version)
+    {
+        Session session = Session.builder(getSession())
+                .setTimeZoneKey(UTC_KEY)
+                .build();
+        String testQuery = format("SELECT tpep_dropoff_datetime FROM \"%s\".\"%s\"",
+                PATH_SCHEMA, goldenTablePathWithPrefix(version, "test-typing"));
+
+        assertQuery(session, testQuery, "SELECT CAST('2021-12-31 16:53:29' AS TIMESTAMP)");
+    }
     /**
      * Expected results for table "data-reader-primitives"
      */
diff --git a/presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/.part-00000-16ab4bfc-37b2-4e87-961c-e9e18a355eeb-c000.snappy.parquet.crc b/presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/.part-00000-16ab4bfc-37b2-4e87-961c-e9e18a355eeb-c000.snappy.parquet.crc
new file mode 100644
index 0000000000000000000000000000000000000000..83724aa6906689d7af90dee92a1341df3288db4a
GIT binary patch
literal 52
zcmV-40L%Yla$^7h00IDGu?#Gv=d7Xr>}0Zvan)ZOsDv&RyiV4_9CRzN&#V>+!B%+c
KpmQA5T2Jvq?HASn

literal 0
HcmV?d00001

diff --git a/presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/_delta_log/.00000000000000000000.crc.crc b/presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/_delta_log/.00000000000000000000.crc.crc
new file mode 100644
index 0000000000000000000000000000000000000000..c29a2e2a1cf34f26b6da449997793ed9856d6c61
GIT binary patch
literal 40
wcmYc;N@ieSU}9)2Pg}3PBl(3`r;l&5Dbt+19|w*ET@(My{@GY{U$-MO04XmJ1poj5

literal 0
HcmV?d00001

diff --git a/presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/_delta_log/.00000000000000000000.json.crc b/presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/_delta_log/.00000000000000000000.json.crc
new file mode 100644
index 0000000000000000000000000000000000000000..1c308c0155d14bb94b53a30bcd7901086c2bb6f2
GIT binary patch
literal 40
ycmV+@0N4Lxa$^7h00IEMz&nKg$r~<ikh~rV=-mQV(B|J8%30SwM&2?KYwOoVJ`w`}

literal 0
HcmV?d00001

diff --git a/presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/_delta_log/00000000000000000000.crc b/presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/_delta_log/00000000000000000000.crc
new file mode 100644
index 0000000000000..4ae3f7a3665fc
--- /dev/null
+++ b/presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/_delta_log/00000000000000000000.crc
@@ -0,0 +1 @@
+{"txnId":"1dc8f519-a27a-4e10-8cba-b676268f8757","tableSizeBytes":5526,"numFiles":1,"numMetadata":1,"numProtocol":1,"setTransactions":[],"domainMetadata":[],"metadata":{"id":"3b76f6bb-def8-40b9-acfc-f0c1fd74ff91","format":{"provider":"parquet","options":{}},"schemaString":"{\"type\":\"struct\",\"fields\":[{\"name\":\"VendorID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tpep_pickup_datetime\",\"type\":\"timestamp\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tpep_dropoff_datetime\",\"type\":\"timestamp\",\"nullable\":true,\"metadata\":{}},{\"name\":\"passenger_count\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"trip_distance\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"RatecodeID\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"store_and_fwd_flag\",\"type\":\"string\",\"nullable\":true,\"metadata\":{}},{\"name\":\"PULocationID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"DOLocationID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"payment_type\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"fare_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"extra\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"mta_tax\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tip_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tolls_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"improvement_surcharge\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"total_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"congestion_surcharge\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"airport_fee\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}}]}","partitionColumns":[],"configuration":{},"createdTime":1738058626356},"protocol":{"minReaderVersion":1,"minWriterVersion":2},"allFiles":[{"path":"part-00000-16ab4bfc-37b2-4e87-961c-e9e18a355eeb-c000.snappy.parquet","partitionValues":{},"size":5526,"modificationTime":1738058627336,"dataChange":false,"stats":"{\"numRecords\":1,\"minValues\":{\"VendorID\":1,\"tpep_pickup_datetime\":\"2022-01-01T00:35:40.000+03:00\",\"tpep_dropoff_datetime\":\"2022-01-01T00:53:29.000+03:00\",\"passenger_count\":2.0,\"trip_distance\":3.8,\"RatecodeID\":1.0,\"store_and_fwd_flag\":\"N\",\"PULocationID\":142,\"DOLocationID\":236,\"payment_type\":1,\"fare_amount\":14.5,\"extra\":3.0,\"mta_tax\":0.5,\"tip_amount\":3.65,\"tolls_amount\":0.0,\"improvement_surcharge\":0.3,\"total_amount\":21.95,\"congestion_surcharge\":2.5,\"airport_fee\":0.0},\"maxValues\":{\"VendorID\":1,\"tpep_pickup_datetime\":\"2022-01-01T00:35:40.000+03:00\",\"tpep_dropoff_datetime\":\"2022-01-01T00:53:29.000+03:00\",\"passenger_count\":2.0,\"trip_distance\":3.8,\"RatecodeID\":1.0,\"store_and_fwd_flag\":\"N\",\"PULocationID\":142,\"DOLocationID\":236,\"payment_type\":1,\"fare_amount\":14.5,\"extra\":3.0,\"mta_tax\":0.5,\"tip_amount\":3.65,\"tolls_amount\":0.0,\"improvement_surcharge\":0.3,\"total_amount\":21.95,\"congestion_surcharge\":2.5,\"airport_fee\":0.0},\"nullCount\":{\"VendorID\":0,\"tpep_pickup_datetime\":0,\"tpep_dropoff_datetime\":0,\"passenger_count\":0,\"trip_distance\":0,\"RatecodeID\":0,\"store_and_fwd_flag\":0,\"PULocationID\":0,\"DOLocationID\":0,\"payment_type\":0,\"fare_amount\":0,\"extra\":0,\"mta_tax\":0,\"tip_amount\":0,\"tolls_amount\":0,\"improvement_surcharge\":0,\"total_amount\":0,\"congestion_surcharge\":0,\"airport_fee\":0}}"}]}
diff --git a/presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/_delta_log/00000000000000000000.json b/presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/_delta_log/00000000000000000000.json
new file mode 100644
index 0000000000000..f9aa0a0ef36fd
--- /dev/null
+++ b/presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/_delta_log/00000000000000000000.json
@@ -0,0 +1,4 @@
+{"commitInfo":{"timestamp":1738058627380,"operation":"WRITE","operationParameters":{"mode":"ErrorIfExists","partitionBy":"[]"},"isolationLevel":"Serializable","isBlindAppend":true,"operationMetrics":{"numFiles":"1","numOutputRows":"1","numOutputBytes":"5526"},"engineInfo":"Apache-Spark/3.5.4 Delta-Lake/3.3.0","txnId":"1dc8f519-a27a-4e10-8cba-b676268f8757"}}
+{"metaData":{"id":"3b76f6bb-def8-40b9-acfc-f0c1fd74ff91","format":{"provider":"parquet","options":{}},"schemaString":"{\"type\":\"struct\",\"fields\":[{\"name\":\"VendorID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tpep_pickup_datetime\",\"type\":\"timestamp\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tpep_dropoff_datetime\",\"type\":\"timestamp\",\"nullable\":true,\"metadata\":{}},{\"name\":\"passenger_count\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"trip_distance\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"RatecodeID\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"store_and_fwd_flag\",\"type\":\"string\",\"nullable\":true,\"metadata\":{}},{\"name\":\"PULocationID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"DOLocationID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"payment_type\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"fare_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"extra\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"mta_tax\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tip_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tolls_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"improvement_surcharge\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"total_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"congestion_surcharge\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"airport_fee\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}}]}","partitionColumns":[],"configuration":{},"createdTime":1738058626356}}
+{"protocol":{"minReaderVersion":1,"minWriterVersion":2}}
+{"add":{"path":"part-00000-16ab4bfc-37b2-4e87-961c-e9e18a355eeb-c000.snappy.parquet","partitionValues":{},"size":5526,"modificationTime":1738058627336,"dataChange":true,"stats":"{\"numRecords\":1,\"minValues\":{\"VendorID\":1,\"tpep_pickup_datetime\":\"2022-01-01T00:35:40.000+03:00\",\"tpep_dropoff_datetime\":\"2022-01-01T00:53:29.000+03:00\",\"passenger_count\":2.0,\"trip_distance\":3.8,\"RatecodeID\":1.0,\"store_and_fwd_flag\":\"N\",\"PULocationID\":142,\"DOLocationID\":236,\"payment_type\":1,\"fare_amount\":14.5,\"extra\":3.0,\"mta_tax\":0.5,\"tip_amount\":3.65,\"tolls_amount\":0.0,\"improvement_surcharge\":0.3,\"total_amount\":21.95,\"congestion_surcharge\":2.5,\"airport_fee\":0.0},\"maxValues\":{\"VendorID\":1,\"tpep_pickup_datetime\":\"2022-01-01T00:35:40.000+03:00\",\"tpep_dropoff_datetime\":\"2022-01-01T00:53:29.000+03:00\",\"passenger_count\":2.0,\"trip_distance\":3.8,\"RatecodeID\":1.0,\"store_and_fwd_flag\":\"N\",\"PULocationID\":142,\"DOLocationID\":236,\"payment_type\":1,\"fare_amount\":14.5,\"extra\":3.0,\"mta_tax\":0.5,\"tip_amount\":3.65,\"tolls_amount\":0.0,\"improvement_surcharge\":0.3,\"total_amount\":21.95,\"congestion_surcharge\":2.5,\"airport_fee\":0.0},\"nullCount\":{\"VendorID\":0,\"tpep_pickup_datetime\":0,\"tpep_dropoff_datetime\":0,\"passenger_count\":0,\"trip_distance\":0,\"RatecodeID\":0,\"store_and_fwd_flag\":0,\"PULocationID\":0,\"DOLocationID\":0,\"payment_type\":0,\"fare_amount\":0,\"extra\":0,\"mta_tax\":0,\"tip_amount\":0,\"tolls_amount\":0,\"improvement_surcharge\":0,\"total_amount\":0,\"congestion_surcharge\":0,\"airport_fee\":0}}"}}
diff --git a/presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/part-00000-16ab4bfc-37b2-4e87-961c-e9e18a355eeb-c000.snappy.parquet b/presto-delta/src/test/resources/delta_v1/snapshot-data3/test-typing1/part-00000-16ab4bfc-37b2-4e87-961c-e9e18a355eeb-c000.snappy.parquet
new file mode 100644
index 0000000000000000000000000000000000000000..b9df9a77b19b4863edbbfa995312e24b86b85a6b
GIT binary patch
literal 5526
zcmbtYZ)jUp6u)^*+bm7n{mFeMk`E=Yut6Id+PbX_+l?`GNF4+BMI^i?FI`xYm%Y5~
zk8?0o6b2TNDWi1zFa*b}wK^TcO_8Z39|}$;B4dnFbd)irZaQmMtLMJ=?w>TTZp}j1
zo}6>;?|06*=iPhWc5c}f!w83P3tlK)Io}Y%5`3-09)y}YC4^9o%LTv52fJ|q9M6oM
zJ0)!fH#b7QR&)Vx`E)x%m)=;5VBt#a$9Fz>>!T)u<F;@-Aqxl9*a)SYL%-K>gziG*
z!>1k=!3y={xs$)uID~2iihAvg?k$X7baG3XpC;;ddG^Qe>y|{D=>aquKaSs=9ezph
zYFNk1(`OU@dh70Vt>8mTIA{lEyPZ1r_eGC`+wF3<2X2T}jIV$C?smNcng!NIv%K^3
z=&)04mYavVO@2K7PxF#!lcX4=S?2$`c+2PD)?t1cDcTpG{rhU8gPWZwveE9JDE;D8
z5DV=pCH?dCxA&a(({#JrMM>Xz|Nfb!Q*cwa2gMd#B?SW>+WmrvrJ#(EWwsOP1v3>z
zGwn1mQ&BWqOJ;i5YG^hN?&=E$Tz!JVL;DE)sVJIh|A3i_qWPgxY2&Ft>+oRg^gP@Q
zEmL8h<f%Zb2xi(B5E>Olvt7HRtPpVARII*Az*$QyHpBi?Gie3EY=OIZ<j?{YX5_#f
zl0CQ&wi*RP@(CB-YKy}X6K_b&VWftMb6hOB@pgOJU@ddF&c(BJOgqcP@p`5`&SRM3
z;@Ar2u)xI$FVhY+Fmc)zA?bPl)4oDp(f7s+i9Kpo!4Wvt*Gd7;ZZ((G^k=rg*$-d+
zMqbUw^XbIiVm_W!4An?yRm+4;Q&QLRS}G;jys)e}uM`SuZa~%J39Xnj5GLA2Lr()r
zx?m`|1fUR|cNc&rw4_QHeV|xfFf?6_E4gGmbpZZll!3MA*$~v;jL*08`De9+Vx+Yk
zSwTYfZF{all~)dB)tnJG4&`m4hLl2Jvpk$y^`N0ERv7hJLx~&8K|3e|;uKwdhL*_`
z%2YU=&Fk8J)ubsD^~4@UAF#Q=-B2=R?*4=Z<tUK2<BPl-l(e4LbR(WpRU}KnP;h=t
z1P(!WunT$Wpq1&CU`dwb9dcj9vzZ@9T$0f`c1Uq8v@D#h@DL#+U+`nUeBOtjM3ED&
z5UvY$xe0;eCYxk0%dfe>HL^Pt@QD|E`8Oc`A1eyB!gcS403ZtT2gwtDEThP<#6xgy
zCLY7E6uIUiK?pNK`8P9&C9MuYOqoI4fFQhfp%-^8tM?5F3T~fFy<8#%uhfbKp9K#2
z53}GSa9>fP@&|#@jMM-Py&bqjXezZL%^(JvPa4U-&IvTav&A^(2!|E)Ob?fMDxy~8
zc#m+*m>eZ{2>a}sIXtc=*H(FZq~zWV*B1N$y7^bc`<&p7HsLUe48k-*o4xG$W>F8;
zLe%u4;}VIwQY*4tAuLy#NM){zEaH*DSgsQmdS7yhuvBVAmYalSu$i!&h53=?BA!Bw
z<!l|W&>NUbgr!m|vdj~f36o_OSZFhe2OA@qB_!51x3P|G>m?+WT9M>!8Ay(;B&m$U
zEJ;bMvy#D&*E4tzgZBvVqE>`IL*Pp${BbzqC_FuW8NqRK#95I}vNoOU;qi-Fk>E>0
z@cJqe|CB)B<tIAhm?9i>2H_InsMLxaKM;;@OpdV?Jc+VPg0YOPV3{C9bAmIF?S!Zm
zS#A-QS5}iu76caOdxz025IQ;<afv5&70OBNBHhu)fbJ`kZo*rZ6u-(C%Y>J*z=UPv
zfy7wKv?9y9gk`~G8G=_#y8n*1BV!wCU?p_3ZgUIWCTc~t5yEz94JqNYz$RX}jAWXV
zh&%G&eY#9Y<_L*=twEL|9(mN~he@$D5YY62sFGJ;z>1o)R&>9r7hnPi)OJL>qMazP
zzQUuhFB65aY+q3|qPlh<npF)2<}M{L<vkoG(@eNKTrl)v!U(s9Q)xAmEQGsXI2_I?
zSz@B20vK)Q49p$yEmzEBl>Q9(z+$yEOmV~AhmRa-W$T^BJ&r|&KN#M!`DFqw9ugl3
zanWeWv65PmB>3>TiqmNIFnoZm9;0&R<yf%W>E&#pI3RPB<+Xu$Jywe$UVhbL2s1l}
zSnfWXV}A9^?Kgw!0r=JP2pGcqNA)O<uPoKWiEla8qd2`7RgWgTODz}V#Um)N!#;c4
zvU-bsShvKYv5si0WnF(Uok_MN`#WPBJ7Vpdl3o29Iy%)v*QSp4<i-u{iKL>&o`|WP
b?HiNHeq}wp#lc%^bwB8IGeSGze`NmyP(6>E

literal 0
HcmV?d00001

diff --git a/presto-delta/src/test/resources/delta_v1/test-typing/.part-00000-4705e2d5-430d-42da-a737-4921ed7fc950-c000.snappy.parquet.crc b/presto-delta/src/test/resources/delta_v1/test-typing/.part-00000-4705e2d5-430d-42da-a737-4921ed7fc950-c000.snappy.parquet.crc
new file mode 100644
index 0000000000000000000000000000000000000000..2b3b1cafa5263e811502c0f182e2c5b92b04e398
GIT binary patch
literal 52
zcmV-40L%Yla$^7h00IC~c|g;o=d7Xr>}0Zvan)aE6((gByiV4_9CRzN&#V>+!B%+c
KpmQA5T2Jv$W*7MY

literal 0
HcmV?d00001

diff --git a/presto-delta/src/test/resources/delta_v1/test-typing/_delta_log/.00000000000000000000.crc.crc b/presto-delta/src/test/resources/delta_v1/test-typing/_delta_log/.00000000000000000000.crc.crc
new file mode 100644
index 0000000000000000000000000000000000000000..e8cf87488b4a0313c380b70f427ea7b45887114d
GIT binary patch
literal 40
wcmYc;N@ieSU}EUs*qy1qBl(3`r;qQ#{3y95xv-r(I#`U@KO3v=>vm)Y02+Y~T>t<8

literal 0
HcmV?d00001

diff --git a/presto-delta/src/test/resources/delta_v1/test-typing/_delta_log/.00000000000000000000.json.crc b/presto-delta/src/test/resources/delta_v1/test-typing/_delta_log/.00000000000000000000.json.crc
new file mode 100644
index 0000000000000000000000000000000000000000..3edb1af2ddc9a417e6783e2055c2a42b45396ce4
GIT binary patch
literal 40
wcmYc;N@ieSU}E?!@TlwGNol>j347!?U)*KV*fE9Spe|>zo!dPlq3qY!0WusA8vp<R

literal 0
HcmV?d00001

diff --git a/presto-delta/src/test/resources/delta_v1/test-typing/_delta_log/00000000000000000000.crc b/presto-delta/src/test/resources/delta_v1/test-typing/_delta_log/00000000000000000000.crc
new file mode 100644
index 0000000000000..741f73a9d85cb
--- /dev/null
+++ b/presto-delta/src/test/resources/delta_v1/test-typing/_delta_log/00000000000000000000.crc
@@ -0,0 +1 @@
+{"txnId":"f768aae4-300a-4cab-819f-949d69bf126f","tableSizeBytes":5526,"numFiles":1,"numMetadata":1,"numProtocol":1,"setTransactions":[],"domainMetadata":[],"metadata":{"id":"bf378016-c2bd-406a-b90c-59d260f8ff52","format":{"provider":"parquet","options":{}},"schemaString":"{\"type\":\"struct\",\"fields\":[{\"name\":\"VendorID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tpep_pickup_datetime\",\"type\":\"timestamp\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tpep_dropoff_datetime\",\"type\":\"timestamp\",\"nullable\":true,\"metadata\":{}},{\"name\":\"passenger_count\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"trip_distance\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"RatecodeID\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"store_and_fwd_flag\",\"type\":\"string\",\"nullable\":true,\"metadata\":{}},{\"name\":\"PULocationID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"DOLocationID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"payment_type\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"fare_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"extra\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"mta_tax\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tip_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tolls_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"improvement_surcharge\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"total_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"congestion_surcharge\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"airport_fee\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}}]}","partitionColumns":[],"configuration":{},"createdTime":1738136311793},"protocol":{"minReaderVersion":1,"minWriterVersion":2},"allFiles":[{"path":"part-00000-4705e2d5-430d-42da-a737-4921ed7fc950-c000.snappy.parquet","partitionValues":{},"size":5526,"modificationTime":1738136312747,"dataChange":false,"stats":"{\"numRecords\":1,\"minValues\":{\"VendorID\":1,\"tpep_pickup_datetime\":\"2021-12-31T19:35:40.000+03:00\",\"tpep_dropoff_datetime\":\"2021-12-31T19:53:29.000+03:00\",\"passenger_count\":2.0,\"trip_distance\":3.8,\"RatecodeID\":1.0,\"store_and_fwd_flag\":\"N\",\"PULocationID\":142,\"DOLocationID\":236,\"payment_type\":1,\"fare_amount\":14.5,\"extra\":3.0,\"mta_tax\":0.5,\"tip_amount\":3.65,\"tolls_amount\":0.0,\"improvement_surcharge\":0.3,\"total_amount\":21.95,\"congestion_surcharge\":2.5,\"airport_fee\":0.0},\"maxValues\":{\"VendorID\":1,\"tpep_pickup_datetime\":\"2021-12-31T19:35:40.000+03:00\",\"tpep_dropoff_datetime\":\"2021-12-31T19:53:29.000+03:00\",\"passenger_count\":2.0,\"trip_distance\":3.8,\"RatecodeID\":1.0,\"store_and_fwd_flag\":\"N\",\"PULocationID\":142,\"DOLocationID\":236,\"payment_type\":1,\"fare_amount\":14.5,\"extra\":3.0,\"mta_tax\":0.5,\"tip_amount\":3.65,\"tolls_amount\":0.0,\"improvement_surcharge\":0.3,\"total_amount\":21.95,\"congestion_surcharge\":2.5,\"airport_fee\":0.0},\"nullCount\":{\"VendorID\":0,\"tpep_pickup_datetime\":0,\"tpep_dropoff_datetime\":0,\"passenger_count\":0,\"trip_distance\":0,\"RatecodeID\":0,\"store_and_fwd_flag\":0,\"PULocationID\":0,\"DOLocationID\":0,\"payment_type\":0,\"fare_amount\":0,\"extra\":0,\"mta_tax\":0,\"tip_amount\":0,\"tolls_amount\":0,\"improvement_surcharge\":0,\"total_amount\":0,\"congestion_surcharge\":0,\"airport_fee\":0}}"}]}
diff --git a/presto-delta/src/test/resources/delta_v1/test-typing/_delta_log/00000000000000000000.json b/presto-delta/src/test/resources/delta_v1/test-typing/_delta_log/00000000000000000000.json
new file mode 100644
index 0000000000000..179c604aaa68f
--- /dev/null
+++ b/presto-delta/src/test/resources/delta_v1/test-typing/_delta_log/00000000000000000000.json
@@ -0,0 +1,4 @@
+{"commitInfo":{"timestamp":1738136312822,"operation":"WRITE","operationParameters":{"mode":"ErrorIfExists","partitionBy":"[]"},"isolationLevel":"Serializable","isBlindAppend":true,"operationMetrics":{"numFiles":"1","numOutputRows":"1","numOutputBytes":"5526"},"engineInfo":"Apache-Spark/3.5.4 Delta-Lake/3.3.0","txnId":"f768aae4-300a-4cab-819f-949d69bf126f"}}
+{"metaData":{"id":"bf378016-c2bd-406a-b90c-59d260f8ff52","format":{"provider":"parquet","options":{}},"schemaString":"{\"type\":\"struct\",\"fields\":[{\"name\":\"VendorID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tpep_pickup_datetime\",\"type\":\"timestamp\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tpep_dropoff_datetime\",\"type\":\"timestamp\",\"nullable\":true,\"metadata\":{}},{\"name\":\"passenger_count\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"trip_distance\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"RatecodeID\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"store_and_fwd_flag\",\"type\":\"string\",\"nullable\":true,\"metadata\":{}},{\"name\":\"PULocationID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"DOLocationID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"payment_type\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"fare_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"extra\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"mta_tax\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tip_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tolls_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"improvement_surcharge\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"total_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"congestion_surcharge\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"airport_fee\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}}]}","partitionColumns":[],"configuration":{},"createdTime":1738136311793}}
+{"protocol":{"minReaderVersion":1,"minWriterVersion":2}}
+{"add":{"path":"part-00000-4705e2d5-430d-42da-a737-4921ed7fc950-c000.snappy.parquet","partitionValues":{},"size":5526,"modificationTime":1738136312747,"dataChange":true,"stats":"{\"numRecords\":1,\"minValues\":{\"VendorID\":1,\"tpep_pickup_datetime\":\"2021-12-31T19:35:40.000+03:00\",\"tpep_dropoff_datetime\":\"2021-12-31T19:53:29.000+03:00\",\"passenger_count\":2.0,\"trip_distance\":3.8,\"RatecodeID\":1.0,\"store_and_fwd_flag\":\"N\",\"PULocationID\":142,\"DOLocationID\":236,\"payment_type\":1,\"fare_amount\":14.5,\"extra\":3.0,\"mta_tax\":0.5,\"tip_amount\":3.65,\"tolls_amount\":0.0,\"improvement_surcharge\":0.3,\"total_amount\":21.95,\"congestion_surcharge\":2.5,\"airport_fee\":0.0},\"maxValues\":{\"VendorID\":1,\"tpep_pickup_datetime\":\"2021-12-31T19:35:40.000+03:00\",\"tpep_dropoff_datetime\":\"2021-12-31T19:53:29.000+03:00\",\"passenger_count\":2.0,\"trip_distance\":3.8,\"RatecodeID\":1.0,\"store_and_fwd_flag\":\"N\",\"PULocationID\":142,\"DOLocationID\":236,\"payment_type\":1,\"fare_amount\":14.5,\"extra\":3.0,\"mta_tax\":0.5,\"tip_amount\":3.65,\"tolls_amount\":0.0,\"improvement_surcharge\":0.3,\"total_amount\":21.95,\"congestion_surcharge\":2.5,\"airport_fee\":0.0},\"nullCount\":{\"VendorID\":0,\"tpep_pickup_datetime\":0,\"tpep_dropoff_datetime\":0,\"passenger_count\":0,\"trip_distance\":0,\"RatecodeID\":0,\"store_and_fwd_flag\":0,\"PULocationID\":0,\"DOLocationID\":0,\"payment_type\":0,\"fare_amount\":0,\"extra\":0,\"mta_tax\":0,\"tip_amount\":0,\"tolls_amount\":0,\"improvement_surcharge\":0,\"total_amount\":0,\"congestion_surcharge\":0,\"airport_fee\":0}}"}}
diff --git a/presto-delta/src/test/resources/delta_v1/test-typing/part-00000-4705e2d5-430d-42da-a737-4921ed7fc950-c000.snappy.parquet b/presto-delta/src/test/resources/delta_v1/test-typing/part-00000-4705e2d5-430d-42da-a737-4921ed7fc950-c000.snappy.parquet
new file mode 100644
index 0000000000000000000000000000000000000000..5b9c94981a9f12ce936dbb19e88ea4f22af5ecda
GIT binary patch
literal 5526
zcmbtYeP~lx6u)_WZJ$Zn`jPjRNd71RgF+jcwe<^GI}zE$bt33LV}#e_wFZ;C`10cC
z1es$4VP%YNbW-<+3?{C0-Ns~0H-_6v|0v9%3=xr1<|yJu(am+Wc02dIcR$j+P8&mQ
zPtG~__dDm@^X@&*UC-~1%SaB(jq?21l?%SGEWp<qSwg73O+W}$c|7nNe`HY(g5$~l
z*=wFH;3gvEZ$bk{U)r-Cp-XSAL9lSS9FXsQ^3JFA7)P{mq_B;HsvLwzw?B9!GKAIF
zpY7W4qzHDXXTCV|N0m#ccA%)!$>_oS@I^Pb9_v$2+%C`j@^j6iXww~lrpT-1w`T^A
za$df*tUO%~;qQ0uPgQe1q=bD=V2;~|r~bJpxwzdeb$jfF*v0t%`cHRjUC?Z>W|HN-
zUxx?XVzb>O;x_Tw=%a>3(I#*)aI?()eesUp#jVx))Dg6AzWn!Oor{~3D00vq4vgJ)
zD~OGDm5}~*_QwZq`)Rq|ZzrVhef;p;;wgy4?QyY%RtTY>M7p07Wg(;>WSgBtI>Agt
z-b^|T%tYkP_LAuix*D2|fqS|_K~EQ_kVqeaKM{E|=^ro?kvBh4D$OhvXdM=elb*!P
z&@yG_36=`93TGyL0ih9*H#@aEK??!LP1)+J7@W4mLNn|?G2>R?%r>~lB8L_zGb0!7
zup-G_u+=CORt7xsR!1BZsCY}D4ntK`oMqyeC~tR`^;J`cn@l`kL$xzZ9Id6=eip+d
z6GxU&hj}KBd#U!ckBU={2uaTcUho(4s<A&&Nbb|JsvL!5eT@*5_G-D5ZoIe+&VKkB
zF!NeIkxwW07xRgfYHDUWtJx;mGNlYXulMwDHZLq|$g72dmh07wL{cy2OeAA%ooS>2
zC0#JpToO>Q&bu2xlX^<SjDAq8ESS2XCDdFh(Q^p?Wz^m^XlEE|Z^h@|wP&ZERL!)W
z!z*ye{%tRpsq*TPtd=tq=8?QZ<m*u}Y?g&ntsOQE)efUJYpMxTJ?sQ!LY%y--_$di
zLWxRFXY+=BP_t+XMI*USHF_N`a5vRViF+WaLpcgK?!*FbpPDxEx?v`IGz}?2C>)ww
z6@^1k47DSv23nbHi7Y6BvP0>LN?X`*#3Ti+rH2&LLd(M03J(!N%2xq7pj`0F&!Omm
zCoI>5+C@y@y2%#VYswoQaE<N_2mSm7U-}J*|Hq0#O>o_d5CBAh{~%>NAS)<3D6kOR
zn~B9RC`4~~a1h*#Q2NaZVo|G05R+CAw;%|wQ|N_VOY410fPy<GQzw&f!OOLL!DoO&
z`O_-+5ZqUUsPsXgG(%NDLv9BqVVZI+Ptzv@&F6J^UuQWQ?%ARovzWsUdb)#2EEQhM
zb9{t3rY(*!F)aI?nz=l#7S~o~dvr|P0@oJ&0J`;;$NL)N4cE&N6zzj)gfx4}^G&1f
ztA?n_MaLu@b-9*jxq?}))Z@zB<XQM5gR<PjEabjq5@spa@+`k$mc9neavtVKnhSpl
zQI_*Hz(Q_dCSjIxEzdHCS;j4v8DJsJ#2;*wWCoMi+uTe$wz(6NlxumCcNHKxwH&81
z3bQ03vCm2hKUz!SB?>Qb@Vu6XKZoJREckvn;s`uBeknmeKH}_1Cuo~abg=k&El=<*
zCU|oNj(?IP@Ujz~a!g_lGJ`M)bChd&j%%3X2a9858B3z%lAtUj%V;JDk(}TRq&vZD
zd6qkv<@J>~lX;HC{obK;^O%l|MoeN!U4?QIJ5P7w8KC>lq8s;?B*m^W$};XHEHGg?
zcpy=h5-rd2K4zJ>SWd$$CfR@2+mW)J_R$iGwA)0k+juR{HiX$Ot->Xo;@J2Lmy%2|
z5`IS>zfYGj$t)&OZuk@-Dk;PM08ENa!JuyR#?-tD16ItMwPFV~qW}{?u(~zY9&1Cv
zb!8rf1DP0%We19y88h@lv8-mQFn6iJN$;@;o@OGOBL&kaCe27wq$jOqQiaIoSB^z;
zY8IQwr~pRCIRkSCe9ILx8MQkDKCoD8iV)n$=3~c?H_`QO;~vAp!ygQ9+58d#7Y>O}
zg}7j}WLPP^h!cGBT={9Vau_ziR*q3V^D->h?etQ%kROm4%F^0^zaA^a;4i;QF}RtX
zK`eEjtuepy<<6Ty<pAvJc?t~f{iAXe*H@Ox;rO?l%2C{2j4DUt-ldib^6GIE+~J(P
z%~_+-IjkGwv3P4N-nh2An9igcQ{8Rxjji#PO{w<o4XtfjvVBu)OKRhWmSjrR;_KsD
cTg%2&s#{$LZ*lO}TG<ae+knt6_#fH-088_Z>Hq)$

literal 0
HcmV?d00001

diff --git a/presto-delta/src/test/resources/delta_v3/test-typing/.part-00000-994a8669-28a4-4c94-a8bb-a437508996d7-c000.snappy.parquet.crc b/presto-delta/src/test/resources/delta_v3/test-typing/.part-00000-994a8669-28a4-4c94-a8bb-a437508996d7-c000.snappy.parquet.crc
new file mode 100644
index 0000000000000000000000000000000000000000..21ef729a48a5f5ff9a1a5aa0388e9dd89ec7fc60
GIT binary patch
literal 52
zcmV-40L%Yla$^7h00IDMzK9{qGZIk|07hX$mh**cAOleO*~k_-yE8}Xs|RGe_L^xW
KsO_PCR8*<n0ToXG

literal 0
HcmV?d00001

diff --git a/presto-delta/src/test/resources/delta_v3/test-typing/_delta_log/.00000000000000000000.crc.crc b/presto-delta/src/test/resources/delta_v3/test-typing/_delta_log/.00000000000000000000.crc.crc
new file mode 100644
index 0000000000000000000000000000000000000000..c6a4be078e0ec6f0ed677c2c3c8227d110392edb
GIT binary patch
literal 40
wcmYc;N@ieSU}CrsbAapcq^+@H88;$Y_?An)Tz5cS`T5m4WuNk6w#+vr05ud4Pyhe`

literal 0
HcmV?d00001

diff --git a/presto-delta/src/test/resources/delta_v3/test-typing/_delta_log/.00000000000000000000.json.crc b/presto-delta/src/test/resources/delta_v3/test-typing/_delta_log/.00000000000000000000.json.crc
new file mode 100644
index 0000000000000000000000000000000000000000..6d33b4e46148a3eb34d45ddb7e5c48b130a2a754
GIT binary patch
literal 40
wcmYc;N@ieSU}Bhfu=pc?@~^C(DOE-OM=SeosT>dr++2Rw^-|2b<AD{G08JATKmY&$

literal 0
HcmV?d00001

diff --git a/presto-delta/src/test/resources/delta_v3/test-typing/_delta_log/00000000000000000000.crc b/presto-delta/src/test/resources/delta_v3/test-typing/_delta_log/00000000000000000000.crc
new file mode 100644
index 0000000000000..6d834d1b50143
--- /dev/null
+++ b/presto-delta/src/test/resources/delta_v3/test-typing/_delta_log/00000000000000000000.crc
@@ -0,0 +1 @@
+{"txnId":"c7efdcd9-93db-4ff1-b39f-13f429c718e5","tableSizeBytes":5521,"numFiles":1,"numMetadata":1,"numProtocol":1,"setTransactions":[],"domainMetadata":[],"metadata":{"id":"19eeeb6e-0857-4b50-97bc-41ef9d836887","format":{"provider":"parquet","options":{}},"schemaString":"{\"type\":\"struct\",\"fields\":[{\"name\":\"VendorID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tpep_pickup_datetime\",\"type\":\"timestamp_ntz\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tpep_dropoff_datetime\",\"type\":\"timestamp\",\"nullable\":true,\"metadata\":{}},{\"name\":\"passenger_count\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"trip_distance\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"RatecodeID\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"store_and_fwd_flag\",\"type\":\"string\",\"nullable\":true,\"metadata\":{}},{\"name\":\"PULocationID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"DOLocationID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"payment_type\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"fare_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"extra\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"mta_tax\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tip_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tolls_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"improvement_surcharge\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"total_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"congestion_surcharge\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"airport_fee\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}}]}","partitionColumns":[],"configuration":{},"createdTime":1738136249198},"protocol":{"minReaderVersion":3,"minWriterVersion":7,"readerFeatures":["timestampNtz"],"writerFeatures":["timestampNtz","appendOnly","invariants"]},"allFiles":[{"path":"part-00000-994a8669-28a4-4c94-a8bb-a437508996d7-c000.snappy.parquet","partitionValues":{},"size":5521,"modificationTime":1738136249854,"dataChange":false,"stats":"{\"numRecords\":1,\"minValues\":{\"VendorID\":1,\"tpep_pickup_datetime\":\"2022-01-01T00:35:40.000\",\"tpep_dropoff_datetime\":\"2021-12-31T19:53:29.000+03:00\",\"passenger_count\":2.0,\"trip_distance\":3.8,\"RatecodeID\":1.0,\"store_and_fwd_flag\":\"N\",\"PULocationID\":142,\"DOLocationID\":236,\"payment_type\":1,\"fare_amount\":14.5,\"extra\":3.0,\"mta_tax\":0.5,\"tip_amount\":3.65,\"tolls_amount\":0.0,\"improvement_surcharge\":0.3,\"total_amount\":21.95,\"congestion_surcharge\":2.5,\"airport_fee\":0.0},\"maxValues\":{\"VendorID\":1,\"tpep_pickup_datetime\":\"2022-01-01T00:35:40.000\",\"tpep_dropoff_datetime\":\"2021-12-31T19:53:29.000+03:00\",\"passenger_count\":2.0,\"trip_distance\":3.8,\"RatecodeID\":1.0,\"store_and_fwd_flag\":\"N\",\"PULocationID\":142,\"DOLocationID\":236,\"payment_type\":1,\"fare_amount\":14.5,\"extra\":3.0,\"mta_tax\":0.5,\"tip_amount\":3.65,\"tolls_amount\":0.0,\"improvement_surcharge\":0.3,\"total_amount\":21.95,\"congestion_surcharge\":2.5,\"airport_fee\":0.0},\"nullCount\":{\"VendorID\":0,\"tpep_pickup_datetime\":0,\"tpep_dropoff_datetime\":0,\"passenger_count\":0,\"trip_distance\":0,\"RatecodeID\":0,\"store_and_fwd_flag\":0,\"PULocationID\":0,\"DOLocationID\":0,\"payment_type\":0,\"fare_amount\":0,\"extra\":0,\"mta_tax\":0,\"tip_amount\":0,\"tolls_amount\":0,\"improvement_surcharge\":0,\"total_amount\":0,\"congestion_surcharge\":0,\"airport_fee\":0}}"}]}
diff --git a/presto-delta/src/test/resources/delta_v3/test-typing/_delta_log/00000000000000000000.json b/presto-delta/src/test/resources/delta_v3/test-typing/_delta_log/00000000000000000000.json
new file mode 100644
index 0000000000000..70bc1fcdc1505
--- /dev/null
+++ b/presto-delta/src/test/resources/delta_v3/test-typing/_delta_log/00000000000000000000.json
@@ -0,0 +1,4 @@
+{"commitInfo":{"timestamp":1738136249889,"operation":"WRITE","operationParameters":{"mode":"ErrorIfExists","partitionBy":"[]"},"isolationLevel":"Serializable","isBlindAppend":true,"operationMetrics":{"numFiles":"1","numOutputRows":"1","numOutputBytes":"5521"},"engineInfo":"Apache-Spark/3.5.4 Delta-Lake/3.3.0","txnId":"c7efdcd9-93db-4ff1-b39f-13f429c718e5"}}
+{"metaData":{"id":"19eeeb6e-0857-4b50-97bc-41ef9d836887","format":{"provider":"parquet","options":{}},"schemaString":"{\"type\":\"struct\",\"fields\":[{\"name\":\"VendorID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tpep_pickup_datetime\",\"type\":\"timestamp_ntz\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tpep_dropoff_datetime\",\"type\":\"timestamp\",\"nullable\":true,\"metadata\":{}},{\"name\":\"passenger_count\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"trip_distance\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"RatecodeID\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"store_and_fwd_flag\",\"type\":\"string\",\"nullable\":true,\"metadata\":{}},{\"name\":\"PULocationID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"DOLocationID\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"payment_type\",\"type\":\"long\",\"nullable\":true,\"metadata\":{}},{\"name\":\"fare_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"extra\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"mta_tax\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tip_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"tolls_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"improvement_surcharge\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"total_amount\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"congestion_surcharge\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}},{\"name\":\"airport_fee\",\"type\":\"double\",\"nullable\":true,\"metadata\":{}}]}","partitionColumns":[],"configuration":{},"createdTime":1738136249198}}
+{"protocol":{"minReaderVersion":3,"minWriterVersion":7,"readerFeatures":["timestampNtz"],"writerFeatures":["timestampNtz","appendOnly","invariants"]}}
+{"add":{"path":"part-00000-994a8669-28a4-4c94-a8bb-a437508996d7-c000.snappy.parquet","partitionValues":{},"size":5521,"modificationTime":1738136249854,"dataChange":true,"stats":"{\"numRecords\":1,\"minValues\":{\"VendorID\":1,\"tpep_pickup_datetime\":\"2022-01-01T00:35:40.000\",\"tpep_dropoff_datetime\":\"2021-12-31T19:53:29.000+03:00\",\"passenger_count\":2.0,\"trip_distance\":3.8,\"RatecodeID\":1.0,\"store_and_fwd_flag\":\"N\",\"PULocationID\":142,\"DOLocationID\":236,\"payment_type\":1,\"fare_amount\":14.5,\"extra\":3.0,\"mta_tax\":0.5,\"tip_amount\":3.65,\"tolls_amount\":0.0,\"improvement_surcharge\":0.3,\"total_amount\":21.95,\"congestion_surcharge\":2.5,\"airport_fee\":0.0},\"maxValues\":{\"VendorID\":1,\"tpep_pickup_datetime\":\"2022-01-01T00:35:40.000\",\"tpep_dropoff_datetime\":\"2021-12-31T19:53:29.000+03:00\",\"passenger_count\":2.0,\"trip_distance\":3.8,\"RatecodeID\":1.0,\"store_and_fwd_flag\":\"N\",\"PULocationID\":142,\"DOLocationID\":236,\"payment_type\":1,\"fare_amount\":14.5,\"extra\":3.0,\"mta_tax\":0.5,\"tip_amount\":3.65,\"tolls_amount\":0.0,\"improvement_surcharge\":0.3,\"total_amount\":21.95,\"congestion_surcharge\":2.5,\"airport_fee\":0.0},\"nullCount\":{\"VendorID\":0,\"tpep_pickup_datetime\":0,\"tpep_dropoff_datetime\":0,\"passenger_count\":0,\"trip_distance\":0,\"RatecodeID\":0,\"store_and_fwd_flag\":0,\"PULocationID\":0,\"DOLocationID\":0,\"payment_type\":0,\"fare_amount\":0,\"extra\":0,\"mta_tax\":0,\"tip_amount\":0,\"tolls_amount\":0,\"improvement_surcharge\":0,\"total_amount\":0,\"congestion_surcharge\":0,\"airport_fee\":0}}"}}
diff --git a/presto-delta/src/test/resources/delta_v3/test-typing/part-00000-994a8669-28a4-4c94-a8bb-a437508996d7-c000.snappy.parquet b/presto-delta/src/test/resources/delta_v3/test-typing/part-00000-994a8669-28a4-4c94-a8bb-a437508996d7-c000.snappy.parquet
new file mode 100644
index 0000000000000000000000000000000000000000..7becceba42d256ecf14e4b27f99fd138ace0a40d
GIT binary patch
literal 5521
zcmbuDe`r%z6vuDU*ES|;>yO;GMDj-oG$^!Lv$pdGvUVb}iF6{Y|BMk{lh+zd^5V;j
zKPQMA3bIKlTX948#~7|`qO4>7v2H`UZuF1A9Ez0vA^oEk5jTo<U8mLU-1px7k>)vV
z7OI|}d*1hR&%G!2p69NYcgHcpVcduxPh7q13u8C@T7x|Z)wjD5LRBso{7pV~*xc~w
zRkuSJdj8~r!`G`3mT(aC9^Lxzk+cQWB!v9UXzk<+-5U`4_GA;$S&0Mq-WLOx>WPkI
z;XGjrhpKGQxv$RsQRM`(rqgAI%|E_4>J-*ze(Gu1*usrpYo4e!+X-qiUW?ybID1%#
z@~z`*&}{>MzjOa~wGczs>9jR3x=tUT`g_#l5O%jT>={@6hsj^=);g$JVl6bwd(#)s
zI?c@r^U$!VFMoQ}@I<vKvKXWy7XKQ(<97&aGe31y?Ypo4dArUb%ubXp$ip)ex11Kl
zQoBZ>e}3}gywiS~VfQ;I^n=eH4nH{siH1FGZlP7~P|!n5TrjaaBqL-E)6#}vYL*OJ
ziFT1;+Z2asA;K^<#bN7-*-rK})FNlQx<f%%x8U&5GJ|+(io>+LV3?ZX@Y6CiXVbz{
zfy&~OvD5SLVW_CG;VGU9RFW`E%Lb-KO>x*>yJKu2;K(U^`Wg{u6|;00%7YG*N)d)F
zaf#0yDx_=}Ik3aB2X{jypio%uVb+WbZ?&DnZswim=6DtJ4oY~t9Xly8@A+zG&T(_B
zhIt2SnR%0&7x-)*aC2e>iyiVZbDEnYKFbR^F9u%m7xId}H&ICLQL_q;!jawN4tjdj
zTuRel-Ddq7F!E|XkxwW07W0XeVyH$st2PC8zPmcyY%V6QfrqdemD07m*4M|v5ca}Y
zLtZHq)Lg%+Cz4t*XIS1kLr;TXx?m`|q-y!RyFovxrBnj<!=tMUhNi0tC6`L{9e_U>
zrN0U73<KAks(;t(JGG=@q_rHKu7BHWWv;w(D68g-gmEZugM57ok<IeyRI3LKU9qN7
zn>Cb#p&Ya)WxzbeP`{yNGKCTsPG|GFwqG?dg`%F^qv-uM3&IU0QxYCXYOovyGVjEa
zXrGeS^O|lX`cxIk?oc?ixF!mxr4;Hwo*F1>x;xk{yX75nchs|mpIh9L(K>dTaW51v
z9O>|NLP)+6zybM~AHRg6JzU>$yBVtoSoGxM7GafpMb>q~`rc&CxWc$5)FF{%oU6v9
zy(Pcniq5#ApSr?9zt}aD{s!p(7)7CG=qe;g7jh>5Ao+Fx%P2Ywjf>Y_(WT|dk{x!F
zY^_fhx6EwIykfSGfgvxN+0F}~(u!x8d4i!A0=EdJ+$&<<$AI~!j%?sKT$D5);Y-9A
z<5et`*-o0uY$s1e^ooqn31h)z3`$|_x7W<!dug(^%G;xZ(iXU>;0M&re?`43MDKDv
zj-coy=+UY!`69DfPl6J=+qgw$O>aEz6)86eWwM^E%z5a77)3lA80CC5Q0NuOEkY^x
zij=#AGSomQb0S4NZWv{bQ0S%0EkY^xij?CrP_CPlG3Z<AE{i7^gN)U%ZEj%|+tNiK
zR>6v15psq=23L|)2B5p75bIE6@&mO@-oxZQg1qPz<u4NXtET)-L7two3~-YJrdXLy
z31upJMZh=#oL)ude*q3lI)5)ex*6jFIWKA3!7Z{z<zA8T8)5uxG9CzwlG}h$9uSIs
zb|7x?oj`(Dq|6e^snsNti4{B(=L?46CRVVduEE05zKAC!dPUrc=Kwch;)c8&S8``D
z%8-{*psBJcU@=OGSEQUJloM-6Qquy(@fu{bX+pD>P-4|43DqWgMcN3VjhnO)c#oyU
zAl|GDGU8(paYvrMPZI=kJOC-l!#>#^^~ejp05pfq!Jwx1$CSJRO;yb7uVVXEy#QBz
zu(~bQ5o<@m^<@!-eVG`vV*84!5!1B;v8-w+&}%8d8Sjw@X<H(jBLzb*CXGmQq%W;z
zQiaIoH;zPdN|p@Ko&W~z;0!bv@LR5!$tb-Uh=GUI<_Oh|Y(8@IXfu1>sm0@3q~U`u
zEt^l|jKj+mUD^>ks6M;ml0K4arL-bR^4aqhThGd6c(+=)MtOtFwP457%h^V;8|Es@
zD+Te2tW-n104voH8gwqP+<i8C`pO@-Ujr%^;MdRp&=6iWDpzrQKdD?!e5I*e#px}m
zay8+_X}KbA9!0?&_W9eA)f?>tyD=V%x5eU(>w1gnOsX-}+aBN87H{2@>ge6j)~+Ty
qHnp{;Hg0H5rW7^)Vq9%+-Iz-CD(m5u4PH?z`#~QyAhZkqGxlE(PmVPJ

literal 0
HcmV?d00001