[COMMON] add size to perf log

opensource4you · Oct 26, 2024 · 2e35711 · 2e35711
1 parent 629bd2d
commit 2e35711
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/app/src/main/java/org/astraea/app/performance/Performance.java b/app/src/main/java/org/astraea/app/performance/Performance.java
@@ -130,6 +130,8 @@ public static List<String> execute(final Argument param) {
                           () -> producerThreads.stream().allMatch(AbstractThread::closed),
                           param.logInterval,
                           List.of(
+                              ReportFormat.CSVContentElement.create(
+                                  "size", () -> String.valueOf(sizes.get().sum())),
                               ReportFormat.CSVContentElement.create(
                                   "max size", () -> String.valueOf(sizes.get().max().getAsLong())),
                               ReportFormat.CSVContentElement.create(