|
65 | 65 | import java.util.concurrent.TimeUnit; |
66 | 66 |
|
67 | 67 | import static org.apache.iotdb.db.queryengine.execution.fragment.FragmentInstanceContext.createFragmentInstanceContext; |
68 | | -import static org.apache.iotdb.db.queryengine.execution.operator.OperatorTestUtils.isNullOrEmpty; |
69 | 68 | import static org.apache.iotdb.db.queryengine.execution.operator.OperatorTestUtils.nextNonNull; |
70 | 69 | import static org.junit.Assert.assertEquals; |
71 | 70 | import static org.junit.Assert.assertTrue; |
@@ -385,7 +384,13 @@ public void batchTest3() throws Exception { |
385 | 384 |
|
386 | 385 | while (offsetOperator.isBlocked().isDone() && offsetOperator.hasNext()) { |
387 | 386 | TsBlock tsBlock = offsetOperator.next(); |
388 | | - if (isNullOrEmpty(tsBlock)) { |
| 387 | + if (tsBlock == null) { |
| 388 | + continue; |
| 389 | + } |
| 390 | + assertEquals(2, tsBlock.getValueColumnCount()); |
| 391 | + assertTrue(tsBlock.getColumn(0) instanceof IntColumn); |
| 392 | + assertTrue(tsBlock.getColumn(1) instanceof IntColumn); |
| 393 | + if (tsBlock.getPositionCount() == 0) { |
389 | 394 | continue; |
390 | 395 | } |
391 | 396 | fail("Expected no data from offset operator"); |
@@ -477,7 +482,13 @@ public void batchTest4() throws Exception { |
477 | 482 |
|
478 | 483 | while (offsetOperator.isBlocked().isDone() && offsetOperator.hasNext()) { |
479 | 484 | TsBlock tsBlock = offsetOperator.next(); |
480 | | - if (isNullOrEmpty(tsBlock)) { |
| 485 | + if (tsBlock == null) { |
| 486 | + continue; |
| 487 | + } |
| 488 | + assertEquals(2, tsBlock.getValueColumnCount()); |
| 489 | + assertTrue(tsBlock.getColumn(0) instanceof IntColumn); |
| 490 | + assertTrue(tsBlock.getColumn(1) instanceof IntColumn); |
| 491 | + if (tsBlock.getPositionCount() == 0) { |
481 | 492 | continue; |
482 | 493 | } |
483 | 494 | fail("Expected no data from offset operator"); |
|
0 commit comments