@Override
  public CompletableFuture<Void> addOperation(Operation<K, V, U> operation) {
    Preconditions.checkNotNull(operation);
    operations.add(operation);
    if (size() >= maxBatchSize) {
      close();
    }
    return completableFuture;
  }
All operations will be buffered without any compaction.
samza-core/src/main/java/org/apache/samza/table/batching/CompleteBatch.java