ajothomas commented on a change in pull request #1560:
URL: https://github.com/apache/samza/pull/1560#discussion_r761410249
##########
File path:
samza-api/src/main/java/org/apache/samza/table/AsyncReadWriteTable.java
##########
@@ -90,6 +91,27 @@
*/
CompletableFuture<Void> putAllAsync(List<Entry<K, V>> entries, Object ...
args);
+ /**
+ * Asynchronously updates an existing record for a given key with the
specified update.
+ *
+ * @param key the key with which the specified {@code value} is to be
associated.
+ * @param update the update applied to the record associated with a given
{@code key}.
+ * @param args additional arguments
+ * @throws NullPointerException if the specified {@code key} is {@code null}.
+ * @return CompletableFuture for the operation
+ */
+ CompletableFuture<Void> updateAsync(K key, U update, Object ... args);
+
+ /**
+ * Asynchronously updates the existing records for the given keys with their
corresponding updates.
+ *
+ * @param updates the key and update mappings.
+ * @param args additional arguments
+ * @throws NullPointerException if any of the specified {@code entries} has
{@code null} as key.
+ * @return CompletableFuture for the operation
+ */
+ CompletableFuture<Void> updateAllAsync(List<Entry<K, U>> updates, Object ...
args);
Review comment:
Hey, I used `CompletableFuture` just to be in line with the existing
code (putAsync, getAsync, etc.).
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
