From c4d0f7a29f5eda2a6ae0703cc4afafbd66bb7d83 Mon Sep 17 00:00:00 2001 From: stanbrub Date: Thu, 20 Aug 2026 16:06:00 -0600 Subject: [PATCH 1/2] Added barrage client benchmarks --- .../standard/client/BarrageClientTest.java | 31 +++++++++++++++++++ 1 file changed, 31 insertions(+) create mode 100644 src/it/java/io/deephaven/benchmark/tests/standard/client/BarrageClientTest.java diff --git a/src/it/java/io/deephaven/benchmark/tests/standard/client/BarrageClientTest.java b/src/it/java/io/deephaven/benchmark/tests/standard/client/BarrageClientTest.java new file mode 100644 index 00000000..1cf859e6 --- /dev/null +++ b/src/it/java/io/deephaven/benchmark/tests/standard/client/BarrageClientTest.java @@ -0,0 +1,31 @@ +/* Copyright (c) 2026-2026 Deephaven Data Labs and Patent Pending */ +package io.deephaven.benchmark.tests.standard.client; + +import org.junit.jupiter.api.*; +import io.deephaven.benchmark.tests.standard.StandardTestRunner; + +/** + * Standard tests for the ascending sort table operation. Sorts rows of data from the source table according to the + * defined columns + */ +public class BarrageClientTest { + final StandardTestRunner runner = new StandardTestRunner(this); + + @BeforeEach + void setup() { + runner.tables("source"); + var q = """ + from deephaven.barrage import barrage_session + session = barrage_session("localhost", 10000, auth_type="Anonymous") + """; + runner.addSetupQuery(q); + } + + @Test + void snapshot() { + runner.setScaleFactors(6, 0); + var q = "result = session.snapshot(b's/source')"; + runner.test("Client- Barrage Snapshot", q, "key1", "num1"); + } + +} From a3f574585832beabee1c0b4b89c30505f8cfe0b2 Mon Sep 17 00:00:00 2001 From: Stan Brubaker Date: Thu, 20 Aug 2026 20:05:21 -0600 Subject: [PATCH 2/2] Potential fix for pull request finding Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com> --- .../benchmark/tests/standard/client/BarrageClientTest.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/it/java/io/deephaven/benchmark/tests/standard/client/BarrageClientTest.java b/src/it/java/io/deephaven/benchmark/tests/standard/client/BarrageClientTest.java index 1cf859e6..c76648e7 100644 --- a/src/it/java/io/deephaven/benchmark/tests/standard/client/BarrageClientTest.java +++ b/src/it/java/io/deephaven/benchmark/tests/standard/client/BarrageClientTest.java @@ -5,8 +5,7 @@ import io.deephaven.benchmark.tests.standard.StandardTestRunner; /** - * Standard tests for the ascending sort table operation. Sorts rows of data from the source table according to the - * defined columns + * Standard benchmark for Barrage client snapshot throughput. Snapshots a two-column table from the source server. */ public class BarrageClientTest { final StandardTestRunner runner = new StandardTestRunner(this);