PR feedback

airbytehq · Jun 21, 2022 · ef81d69 · ef81d69
1 parent 12dd14c
commit ef81d69
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...nal-db/src/main/java/io/airbyte/integrations/source/relationaldb/state/CursorManager.java b/...nal-db/src/main/java/io/airbyte/integrations/source/relationaldb/state/CursorManager.java
@@ -92,9 +92,9 @@ protected Map<AirbyteStreamNameNamespacePair, CursorInfo> createCursorInfoMap(
     final Map<AirbyteStreamNameNamespacePair, CursorInfo> localMap = new HashMap<>();
     final Map<AirbyteStreamNameNamespacePair, S> pairToState = streamSupplier.get()
         .stream()
-        .collect(Collectors.toMap(namespacePairFunction, a -> a));
+        .collect(Collectors.toMap(namespacePairFunction,Function.identity()));
     final Map<AirbyteStreamNameNamespacePair, ConfiguredAirbyteStream> pairToConfiguredAirbyteStream = catalog.getStreams().stream()
-        .collect(Collectors.toMap(AirbyteStreamNameNamespacePair::fromConfiguredAirbyteSteam, s -> s));
+        .collect(Collectors.toMap(AirbyteStreamNameNamespacePair::fromConfiguredAirbyteSteam, Function.identity()));
 
     for (final AirbyteStreamNameNamespacePair pair : allStreamNames) {
       final Optional<S> stateOptional = Optional.ofNullable(pairToState.get(pair));