Fix docs and use Map#computeIfAbsent with a lambda.

apache · Nov 13, 2024 · c009143 · c009143
1 parent d4cd6d8
commit c009143
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...olace/src/main/java/org/apache/beam/sdk/io/solace/broker/SempBasicAuthClientExecutor.java b/...olace/src/main/java/org/apache/beam/sdk/io/solace/broker/SempBasicAuthClientExecutor.java
@@ -84,7 +84,7 @@ public SempBasicAuthClientExecutor(
     this.password = password;
     this.requestFactory = httpRequestFactory;
     this.cookieManagerKey = new CookieManagerKey(this.baseUrl, this.username);
-    COOKIE_MANAGER_MAP.putIfAbsent(this.cookieManagerKey, new CookieManager());
+    COOKIE_MANAGER_MAP.computeIfAbsent(this.cookieManagerKey, key -> new CookieManager());
   }
 
   public boolean isQueueNonExclusive(String queueName) throws IOException {

diff --git a/...va/io/solace/src/main/java/org/apache/beam/sdk/io/solace/write/UnboundedSolaceWriter.java b/...va/io/solace/src/main/java/org/apache/beam/sdk/io/solace/write/UnboundedSolaceWriter.java
@@ -352,8 +352,8 @@ public void output(
   }
 
   /**
-   * This class a pseudo-key with a given cardinality. The downstream steps will use state & timers
-   * to distribute the data and control for the number of parallel workers used for writing.
+   * This class adds pseudo-key with a given cardinality. The downstream steps will use state &
+   * timers to distribute the data and control for the number of parallel workers used for writing.
    */
   @Internal
   public static class AddShardKeyDoFn extends DoFn<Solace.Record, KV<Integer, Solace.Record>> {