From f7e1a476a2bf00aa358cc6c06f561e2fe1f8b59c Mon Sep 17 00:00:00 2001 From: Philipp Schirmer Date: Wed, 22 Jan 2025 10:28:54 +0100 Subject: [PATCH] Upgrade to Gradle 8.4 --- .../bakdata/dedupe/fusion/ConflictResolutionFusion.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/common/src/main/java/com/bakdata/dedupe/fusion/ConflictResolutionFusion.java b/common/src/main/java/com/bakdata/dedupe/fusion/ConflictResolutionFusion.java index 0bbb2a5..7041056 100644 --- a/common/src/main/java/com/bakdata/dedupe/fusion/ConflictResolutionFusion.java +++ b/common/src/main/java/com/bakdata/dedupe/fusion/ConflictResolutionFusion.java @@ -51,12 +51,12 @@ public class ConflictResolutionFusion implements Fusion { * #getSources()}. */ @NonNull - Function sourceExtractor; + Function<@NonNull R, String> sourceExtractor; /** * A function that extract the last modification timestamp of a record. Useful for time-based resolutions. */ @NonNull - Function lastModifiedExtractor; + Function<@NonNull R, @NonNull LocalDateTime> lastModifiedExtractor; /** * The list of possible sources. Superfluous sources are ignored. */ @@ -68,7 +68,8 @@ public class ConflictResolutionFusion implements Fusion { @NonNull ConflictResolution rootResolution; @Getter(value = AccessLevel.PRIVATE, lazy = true) - @NonNull Map<@NonNull String, @NonNull Source> sourceByName = + @NonNull + Map sourceByName = this.sources.stream().collect(Collectors.toMap(Source::getName, s -> s)); @Override