You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/03/29 10:27:34 UTC
[iotdb] 01/01: add sout
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch yanshi
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c92595bafbe371e80e7e4418b6c61311faca6429
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Tue Mar 29 14:29:13 2022 +0800
add sout
---
.../java/org/apache/iotdb/db/mpp/operator/LimitOperatorTest.java | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/server/src/test/java/org/apache/iotdb/db/mpp/operator/LimitOperatorTest.java b/server/src/test/java/org/apache/iotdb/db/mpp/operator/LimitOperatorTest.java
index 14cbeec..66d8fea 100644
--- a/server/src/test/java/org/apache/iotdb/db/mpp/operator/LimitOperatorTest.java
+++ b/server/src/test/java/org/apache/iotdb/db/mpp/operator/LimitOperatorTest.java
@@ -133,6 +133,7 @@ public class LimitOperatorTest {
new LimitOperator(
fragmentInstanceContext.getOperatorContexts().get(3), 250, timeJoinOperator);
int count = 0;
+ System.out.println("Time sensor0 sensor1");
while (limitOperator.hasNext()) {
TsBlock tsBlock = limitOperator.next();
assertEquals(2, tsBlock.getValueColumnCount());
@@ -145,6 +146,12 @@ public class LimitOperatorTest {
}
for (int i = 0; i < tsBlock.getPositionCount(); i++) {
long expectedTime = i + 20L * count;
+ System.out.println(
+ expectedTime
+ + " \t "
+ + tsBlock.getColumn(0).getInt(i)
+ + " \t "
+ + tsBlock.getColumn(1).getInt(i));
assertEquals(expectedTime, tsBlock.getTimeByIndex(i));
if (expectedTime < 200) {
assertEquals(20000 + expectedTime, tsBlock.getColumn(0).getInt(i));