This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch pipe-api
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/pipe-api by this push:
new 69b8d19a4c4 collect-tablet
69b8d19a4c4 is described below
commit 69b8d19a4c459c3c144890328bd3b08ace0ecf8f
Author: Caideyipi <[email protected]>
AuthorDate: Fri Dec 19 11:30:16 2025 +0800
collect-tablet
---
.../pipe/event/TsFileInsertionEventParserTest.java | 25 +++++++++++++++-------
1 file changed, 17 insertions(+), 8 deletions(-)
diff --git
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/TsFileInsertionEventParserTest.java
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/TsFileInsertionEventParserTest.java
index 7bfde3b158d..c7fef3cb5b0 100644
---
a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/TsFileInsertionEventParserTest.java
+++
b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/TsFileInsertionEventParserTest.java
@@ -617,18 +617,15 @@ public class TsFileInsertionEventParserTest {
})
.forEach(
tabletInsertionEvent2 ->
- tabletInsertionEvent2.processTablet(
- (tablet, rowCollector) ->
- new
PipeRawTabletInsertionEvent(tablet, false)
- .processRowByRow(
- (row, collector) -> {
+
tabletInsertionEvent2.processTabletWithCollect(
+ (tablet, collector) -> {
try {
-
rowCollector.collectRow(row);
-
count3.addAndGet(getNonNullSize(row));
+
collector.collectTablet(tablet);
+
count3.addAndGet(getNonNullSize(tablet));
} catch (final
IOException e) {
throw new
RuntimeException(e);
}
- })))));
+ }))));
Assert.assertEquals(expectedCount, count1.get());
Assert.assertEquals(expectedCount, count2.get());
@@ -648,4 +645,16 @@ public class TsFileInsertionEventParserTest {
}
return count;
}
+
+ private int getNonNullSize(final Tablet tablet) {
+ int count = 0;
+ for (int i=0; i<tablet.getRowSize(); ++i) {
+ for (int j=0; j<tablet.getSchemas().size(); ++j) {
+ if (!tablet.isNull(i, j)) {
+ ++count;
+ }
+ }
+ }
+ return count;
+ }
}
