File tree Expand file tree Collapse file tree
common/src/main/java/com/bakdata/dedupe/fusion Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -51,12 +51,12 @@ public class ConflictResolutionFusion<R> implements Fusion<R> {
5151 * #getSources()}.
5252 */
5353 @ NonNull
54- Function <R , String > sourceExtractor ;
54+ Function <@ NonNull R , String > sourceExtractor ;
5555 /**
5656 * A function that extract the last modification timestamp of a record. Useful for time-based resolutions.
5757 */
5858 @ NonNull
59- Function <R , LocalDateTime > lastModifiedExtractor ;
59+ Function <@ NonNull R , @ NonNull LocalDateTime > lastModifiedExtractor ;
6060 /**
6161 * The list of possible sources. Superfluous sources are ignored.
6262 */
@@ -68,7 +68,8 @@ public class ConflictResolutionFusion<R> implements Fusion<R> {
6868 @ NonNull ConflictResolution <R , R > rootResolution ;
6969
7070 @ Getter (value = AccessLevel .PRIVATE , lazy = true )
71- @ NonNull Map <@ NonNull String , @ NonNull Source > sourceByName =
71+ @ NonNull
72+ Map <String , Source > sourceByName =
7273 this .sources .stream ().collect (Collectors .toMap (Source ::getName , s -> s ));
7374
7475 @ Override
You can’t perform that action at this time.
0 commit comments