From b46ddcc6cf9261a8f50490006973bd5485356bfe Mon Sep 17 00:00:00 2001 From: "Charles P. Wright" Date: Tue, 27 Feb 2024 13:31:36 -0500 Subject: [PATCH] test changes 1. --- .../io/deephaven/engine/util/TestWindowCheck.java | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/engine/table/src/test/java/io/deephaven/engine/util/TestWindowCheck.java b/engine/table/src/test/java/io/deephaven/engine/util/TestWindowCheck.java index dca5acc5e2a..1adab78cdc4 100644 --- a/engine/table/src/test/java/io/deephaven/engine/util/TestWindowCheck.java +++ b/engine/table/src/test/java/io/deephaven/engine/util/TestWindowCheck.java @@ -80,7 +80,7 @@ private void testWindowCheckIterative(int seed, boolean withShifts) { final Random combinedRandom = new Random(seed); final ColumnInfo[] columnInfo; - final int size = 10; + final int size = 100; final Instant startTime = DateTimeUtils.parseInstant("2018-02-23T09:30:00 NY"); final Instant endTime; if (SHORT_TESTS) { @@ -146,7 +146,7 @@ private void testWindowCheckIterative(int seed, boolean withShifts) { } } - private void advanceTime(TestClock clock, WindowEvalNugget[] en, long nanosToAdvance) { + private void advanceTime(final TestClock clock, final WindowEvalNugget[] en, final long nanosToAdvance) { clock.now += nanosToAdvance; if (RefreshingTableTestCase.printTableUpdates) { System.out.println("Ticking time to " + DateTimeUtils.epochNanosToInstant(clock.now)); @@ -394,6 +394,7 @@ public void validate(String msg) { @Override public void show() { TableTools.showWithRowSet(windowed.first); + windowed.second.dumpQueue(); } } @@ -479,10 +480,10 @@ public void testSequentialRangesAddOnly() throws IOException { final TrackingWritableRowSet inputRowSet = RowSetFactory.fromRange(0, 9999).toTracking(); inputRowSet.insertRange(regionSize, regionSize + 9_999); - final QueryTable indexTable = TstUtils.testRefreshingTable(inputRowSet); + final QueryTable rowsetTable = TstUtils.testRefreshingTable(inputRowSet); // each chunk of 10_000 rows should account for one minute, or 60_000_000_000 / 10_000 = 6_000_000 nanos per row // we start 3 minutes behind the start, so everything is in the five-minute window - final Table inputTable = indexTable.updateView("Timestamp = startTime + ((k % regionSize) * 6_000_000)") + final Table inputTable = rowsetTable.updateView("Timestamp = startTime + ((k % regionSize) * 6_000_000)") .withAttributes(Collections.singletonMap(Table.ADD_ONLY_TABLE_ATTRIBUTE, true)); final ControlledUpdateGraph updateGraph = ExecutionContext.getContext().getUpdateGraph().cast(); @@ -505,8 +506,8 @@ public void testSequentialRangesAddOnly() throws IOException { final TrackingWritableRowSet added = RowSetFactory.fromRange(fstep * 10_000, fstep * 10_000 + 9_999).toTracking(); added.insertRange(fstep * 10_000 + regionSize, fstep * 10_000 + 9_999 + regionSize); - indexTable.getRowSet().writableCast().insert(added); - indexTable.notifyListeners(added, i(), i()); + rowsetTable.getRowSet().writableCast().insert(added); + rowsetTable.notifyListeners(added, i(), i()); advanceTime(timeProvider, en, fstep * DateTimeUtils.MINUTE); }); TstUtils.validate("Step " + step, en);