@@ -21,19 +21,19 @@ public class InMemoryMaterializationRepoExample implements MaterializationReposi
2121 * @return A map containing the key and a default MaterializationInfo object.
2222 */
2323 private static Map <String , MaterializationInfo > createEmptyMap (String key ) {
24- MaterializationInfo emptyInfo = new MaterializationInfo (false , new HashMap <>());
25- Map <String , MaterializationInfo > map = new HashMap <>();
24+ final MaterializationInfo emptyInfo = new MaterializationInfo (false , new HashMap <>());
25+ final Map <String , MaterializationInfo > map = new HashMap <>();
2626 map .put (key , emptyInfo );
2727 return map ;
2828 }
2929
3030 @ Override
3131 public CompletableFuture <Map <String , MaterializationInfo >> loadMaterializedAssignmentsForUnit (
3232 String unit , String materialization ) {
33- Map <String , MaterializationInfo > unitAssignments = storage .get (unit );
33+ final Map <String , MaterializationInfo > unitAssignments = storage .get (unit );
3434 if (unitAssignments != null ) {
3535 if (unitAssignments .containsKey (materialization )) {
36- Map <String , MaterializationInfo > result = new HashMap <>();
36+ final Map <String , MaterializationInfo > result = new HashMap <>();
3737 result .put (materialization , unitAssignments .get (materialization ));
3838 logger .debug ("Cache hit for unit: {}, materialization: {}" , unit , materialization );
3939 return CompletableFuture .supplyAsync (() -> result );
@@ -67,15 +67,15 @@ public CompletableFuture<Void> storeAssignment(
6767 } else {
6868 // If an entry exists, merge the new assignments into it.
6969 // This is equivalent to Kotlin's 'existingEntry.plus(assignments ?: emptyMap())'.
70- Map <String , MaterializationInfo > newEntry = new HashMap <>(existingEntry );
70+ final Map <String , MaterializationInfo > newEntry = new HashMap <>(existingEntry );
7171 if (assignments != null ) {
7272 newEntry .putAll (assignments );
7373 }
7474 return newEntry ;
7575 }
7676 });
7777
78- int assignmentCount = (assignments != null ) ? assignments .size () : 0 ;
78+ final int assignmentCount = (assignments != null ) ? assignments .size () : 0 ;
7979 logger .debug ("Stored {} assignments for unit: {}" , assignmentCount , unit );
8080
8181 return CompletableFuture .completedFuture (null );
0 commit comments