From 619718b163bf91ebfc64dba3a7d68a744856dc1a Mon Sep 17 00:00:00 2001 From: Jonas Irgens Kylling Date: Tue, 17 Oct 2023 16:57:12 +0200 Subject: [PATCH] Add fileModifiedTime in DeltaLakeSplit Object methods --- .../main/java/io/trino/plugin/deltalake/DeltaLakeSplit.java | 4 +++- 1 file changed, 3 insertions(+), 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 index d750bd371f7f..245c7e07a173 100644 --- 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); } }