Fix docs and use Map#computeIfAbsent with a lambda.

apache · Nov 13, 2024 · 94af14f · 94af14f
1 parent 262b6df
commit 94af14f
Show file tree

Hide file tree

Showing 2 changed files with 4 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/sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/write/AddShardKeyDoFn.java b/sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/write/AddShardKeyDoFn.java
@@ -23,8 +23,9 @@
 import org.apache.beam.sdk.values.KV;
 
 /**
- * This class a pseudo-key with a given cardinality. The downstream steps will use state {@literal
- * &} 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
+ * {@literal &} timers to distribute the data and control for the number of parallel workers used
+ * for writing.
  */
 @Internal
 public class AddShardKeyDoFn extends DoFn<Solace.Record, KV<Integer, Solace.Record>> {