Add fileModifiedTime in DeltaLakeSplit Object methods

trinodb · Oct 18, 2023 · 619718b · 619718b
1 parent aa26d24
commit 619718b
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeSplit.java b/plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeSplit.java
@@ -186,6 +186,7 @@ public String toString()
                 .add("length", length)
                 .add("fileSize", fileSize)
                 .add("rowCount", fileRowCount)
+                .add("fileModifiedTime", fileModifiedTime)
                 .add("deletionVector", deletionVector)
                 .add("statisticsPredicate", statisticsPredicate)
                 .add("partitionKeys", partitionKeys)
@@ -205,6 +206,7 @@ public boolean equals(Object o)
         return start == that.start &&
                 length == that.length &&
                 fileSize == that.fileSize &&
+                fileModifiedTime == that.fileModifiedTime &&
                 path.equals(that.path) &&
                 fileRowCount.equals(that.fileRowCount) &&
                 deletionVector.equals(that.deletionVector) &&
@@ -215,6 +217,6 @@ public boolean equals(Object o)
     @Override
     public int hashCode()
     {
-        return Objects.hash(path, start, length, fileSize, fileRowCount, deletionVector, statisticsPredicate, partitionKeys);
+        return Objects.hash(path, start, length, fileSize, fileRowCount, fileModifiedTime, deletionVector, statisticsPredicate, partitionKeys);
     }
 }