+ * Note: This test must contain benchmarks and rev_ticks/fwd_ticks that are comparable to
+ * RollingFormulaTimeTest
+ */
+public class RollingFormulaTickTest {
+ final StandardTestRunner runner = new StandardTestRunner(this);
+
+ void setup(int rowFactor, int staticFactor, int incFactor) {
+ runner.setRowFactor(rowFactor);
+ runner.setScaleFactors(staticFactor, incFactor);
+ runner.tables("timed");
+ var s = """
+ from deephaven.updateby import rolling_formula_tick
+ """;
+ runner.addSetupQuery(s);
+ }
+
+ @Test
+ void rollingFormulaTick0Group3Ops() {
+ setup(1, 1, 1);
+ runner.addSetupQuery("""
+ contains = rolling_formula_tick(formula="avg(x)", formula_param="x", cols=["Contains=num1"],
+ rev_ticks=2000, fwd_ticks=3000)
+ """);
+ var q = "timed.update_by(ops=[contains])";
+ runner.test("RollingFormulaTick- No Groups 1 Col", q, "num1");
+ }
+
+ @Test
+ void rollingFormulaTick1Group3Ops() {
+ setup(3, 7, 2);
+ runner.addSetupQuery("""
+ contains = rolling_formula_tick(formula="avg(x)", formula_param="x", cols=["Contains=num1"],
+ rev_ticks=20, fwd_ticks=30)
+ """);
+ var q = "timed.update_by(ops=[contains], by=['key1'])";
+ runner.test("RollingFormulaTick- 1 Group 100 Unique Vals", q, "key1", "num1");
+ }
+
+ @Test
+ void rollingFormulaTick2Groups3Ops() {
+ setup(2, 3, 1);
+ runner.addSetupQuery("""
+ contains = rolling_formula_tick(formula="avg(x)", formula_param="x", cols=["Contains=num1"],
+ rev_ticks=20, fwd_ticks=30)
+ """);
+ var q = "timed.update_by(ops=[contains], by=['key1','key2'])";
+ runner.test("RollingFormulaTick- 2 Groups 10K Unique Combos", q, "key1", "key2", "num1");
+ }
+
+ @Test
+ void rollingFormulaTick3Groups3Ops() {
+ setup(1, 3, 1);
+ runner.addSetupQuery("""
+ contains = rolling_formula_tick(formula="avg(x)", formula_param="x", cols=["Contains=num1"],
+ rev_ticks=20, fwd_ticks=30)
+ """);
+ var q = "timed.update_by(ops=[contains], by=['key1','key2','key3'])";
+ runner.test("RollingFormulaTick- 3 Groups 100K Unique Combos", q, "key1", "key2", "key3", "num1");
+ }
+
+}
diff --git a/src/it/java/io/deephaven/benchmark/tests/standard/updateby/RollingFormulaTimeTest.java b/src/it/java/io/deephaven/benchmark/tests/standard/updateby/RollingFormulaTimeTest.java
new file mode 100644
index 00000000..2ad494cf
--- /dev/null
+++ b/src/it/java/io/deephaven/benchmark/tests/standard/updateby/RollingFormulaTimeTest.java
@@ -0,0 +1,72 @@
+/* Copyright (c) 2022-2025 Deephaven Data Labs and Patent Pending */
+package io.deephaven.benchmark.tests.standard.updateby;
+
+import org.junit.jupiter.api.*;
+import io.deephaven.benchmark.tests.standard.StandardTestRunner;
+
+/**
+ * Standard tests for the updateBy table operation. Defines a time-based rolling formula. The result table contains
+ * additional columns with windowed rolling formulas for each specified column in the source table.
+ *
+ * Note: This test must contain benchmarks and rev_time/fwd_time that are comparable to
+ * RollingFormulaTickTest
+ */
+public class RollingFormulaTimeTest {
+ final StandardTestRunner runner = new StandardTestRunner(this);
+ final Setup setup = new Setup(runner);
+
+ void setup(int rowFactor, int staticFactor, int incFactor) {
+ runner.setRowFactor(rowFactor);
+ runner.setScaleFactors(staticFactor, incFactor);
+ runner.tables("timed");
+ var s = """
+ from deephaven.updateby import rolling_formula_time
+ """;
+ runner.addSetupQuery(s);
+ }
+
+ @Test
+ void rollingFormulaTime0Group3Ops() {
+ setup(1, 1, 1);
+ runner.addSetupQuery("""
+ contains = rolling_formula_time(formula="avg(x)", formula_param="x", ts_col="timestamp",
+ cols=["Contains=num1"], rev_time="PT2S", fwd_time="PT3S")
+ """);
+ var q = "timed.update_by(ops=[contains])";
+ runner.test("RollingFormulaTime- No Groups 1 Col", q, "num1", "timestamp");
+ }
+
+ @Test
+ void rollingFormulaTime1Group3Ops() {
+ setup(3, 3, 1);
+ runner.addSetupQuery("""
+ contains = rolling_formula_time(formula="avg(x)", formula_param="x", ts_col="timestamp",
+ cols=["Contains=num1"], rev_time="PT2S", fwd_time="PT3S")
+ """);
+ var q = "timed.update_by(ops=[contains], by=['key1'])";
+ runner.test("RollingFormulaTime- 1 Group 100 Unique Vals", q, "key1", "num1", "timestamp");
+ }
+
+ @Test
+ void rollingFormulaTime2Groups3Ops() {
+ setup(2, 2, 1);
+ runner.addSetupQuery("""
+ contains = rolling_formula_time(formula="avg(x)", formula_param="x", ts_col="timestamp",
+ cols=["Contains=num1"], rev_time="PT4M", fwd_time="PT5M")
+ """);
+ var q = "timed.update_by(ops=[contains], by=['key1','key2'])";
+ runner.test("RollingFormulaTime- 2 Groups 10K Unique Combos", q, "key1", "key2", "num1", "timestamp");
+ }
+
+ @Test
+ void rollingFormulaTime3Groups3Ops() {
+ setup(1, 3, 1);
+ runner.addSetupQuery("""
+ contains = rolling_formula_time(formula="avg(x)", formula_param="x", ts_col="timestamp",
+ cols=["Contains=num1"], rev_time="PT40M", fwd_time="PT50M")
+ """);
+ var q = "timed.update_by(ops=[contains], by=['key1','key2','key3'])";
+ runner.test("RollingFormulaTime- 3 Groups 100K Unique Combos", q, "key1", "key2", "key3", "num1", "timestamp");
+ }
+
+}