private CompletableFuture<?> handleBatchUpdate(Collection<Operation<K, V, U>> operations) {
    Preconditions.checkNotNull(operations);

    final List<Entry<K, U>> updates = operations.stream()
        .map(op -> new Entry<>(op.getKey(), op.getUpdate()))
        .collect(Collectors.toList());
    if (updates.isEmpty()) {
      return CompletableFuture.completedFuture(Collections.EMPTY_MAP);
    }
    return table.updateAllAsync(updates);
  }
Defines how batch update should be done.

@param operations The batch update operations.
@return A CompletableFuture to represent the status of the batch update operation.
samza-core/src/main/java/org/apache/samza/table/batching/TableBatchHandler.java