[proxima-beam-core] fix sonar

je-ik · je-ik · commit 1f0ce7e3971a · 2025-05-14T14:32:44.000+02:00
diff --git a/beam/core/src/main/java/cz/o2/proxima/beam/core/transforms/retract/RetractJoin.java b/beam/core/src/main/java/cz/o2/proxima/beam/core/transforms/retract/RetractJoin.java
@@ -335,7 +335,7 @@ private <PK, SK, PV, SV> void processSecondaryElement(
           retractConsumer.apply(
               primaryKey,
               secondaryKey,
-              oldPrimaryValue.getValue().getValue(),
+              Objects.requireNonNull(oldPrimaryValue, "oldPrimaryValue").getValue().getValue(),
               secondaryValue.getValue().getValue(),
               max(thisInstant, secondaryValue.getKey()));
         }

Original file line number	Diff line number	Diff line change
`@@ -335,7 +335,7 @@ private <PK, SK, PV, SV> void processSecondaryElement(`
`335`	`335`	`retractConsumer.apply(`
`336`	`336`	`primaryKey,`
`337`	`337`	`secondaryKey,`
`338`		`- oldPrimaryValue.getValue().getValue(),`
	`338`	`+ Objects.requireNonNull(oldPrimaryValue, "oldPrimaryValue").getValue().getValue(),`
`339`	`339`	`secondaryValue.getValue().getValue(),`
`340`	`340`	`max(thisInstant, secondaryValue.getKey()));`
`341`	`341`	`}`