Updated time and rolling_wavg to the new ways

deephaven · Sep 5, 2023 · 7352524 · 7352524
1 parent aabd1ed
commit 7352524
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 5 deletions.
diff --git a/...eephaven/benchmark/tests/internal/examples/stream/JoinTablesFromParquetAndStreamTest.java b/...eephaven/benchmark/tests/internal/examples/stream/JoinTablesFromParquetAndStreamTest.java
@@ -45,7 +45,6 @@ public void joinTwoTablesFromParquetViews() {
         api.setName("Join Two Tables Using Parquet File Views");
 
         var query = """
-        from deephaven.time import now
         from deephaven import agg
         from deephaven.parquet import read
 
@@ -98,7 +97,6 @@ public void joinTwoTablesFromParquetFileIncRelease() {
         api.setName("Join Two Tables Using Incremental Release of Parquet File Records");
 
         var query = """
-        from deephaven.time import now
         from deephaven import agg
         from deephaven.parquet import read
 

diff --git a/src/it/java/io/deephaven/benchmark/tests/standard/updateby/RollingWAvgTickTest.java b/src/it/java/io/deephaven/benchmark/tests/standard/updateby/RollingWAvgTickTest.java
@@ -50,9 +50,9 @@ public void rollingWAvgTime2Groups3OpsInt() {
     public void rollingWAvgTick2Groups3OpsFloat() {
         runner.setScaleFactors(2, 1);
         var setup = """
-        contains_row = rolling_wavg_tick(weight_col='int10', cols=["Contains = float5"], rev_ticks=1, fwd_ticks=1)
-        before_row = rolling_wavg_tick(weight_col='int10', cols=["Before = float5"], rev_ticks=3, fwd_ticks=-1)
-        after_row = rolling_wavg_tick(weight_col='int10', cols=["After = float5"], rev_ticks=-1, fwd_ticks=3)
+        contains_row = rolling_wavg_tick('int10', cols=["Contains = float5"], rev_ticks=1, fwd_ticks=1)
+        before_row = rolling_wavg_tick('int10', cols=["Before = float5"], rev_ticks=3, fwd_ticks=-1)
+        after_row = rolling_wavg_tick('int10', cols=["After = float5"], rev_ticks=-1, fwd_ticks=3)
         """;
         runner.addSetupQuery(setup);