From 85be1839e5ed0d69471080bd7d1c79162f390ee3 Mon Sep 17 00:00:00 2001 From: regadas Date: Thu, 25 Jan 2024 15:58:48 +0000 Subject: [PATCH] Simplify days since epoch --- .../org/apache/beam/sdk/extensions/smb/IcebergEncoder.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/IcebergEncoder.java b/scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/IcebergEncoder.java index fb0b11738d..9050d4e9cc 100644 --- a/scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/IcebergEncoder.java +++ b/scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/IcebergEncoder.java @@ -35,7 +35,6 @@ public final class IcebergEncoder implements BucketMetadata.Encoder { private static final OffsetDateTime EPOCH = Instant.ofEpochSecond(0).atOffset(ZoneOffset.UTC); - private static final LocalDate EPOCH_DAY = EPOCH.toLocalDate(); private byte[] encode(int value) { return encode((long) value); @@ -58,7 +57,7 @@ private byte[] encode(UUID value) { } private byte[] encode(LocalDate value) { - return encode(ChronoUnit.DAYS.between(EPOCH_DAY, value)); + return encode(value.toEpochDay()); } private byte[] encode(LocalTime value) {