(iotdb) branch pipe-api updated: Update TsFileInsertionEventParserTest.java

[justinchen]

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 774dfdb2dd0 Update TsFileInsertionEventParserTest.java
774dfdb2dd0 is described below

commit 774dfdb2dd08a68d750ae192d314da229eb8a372
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Fri Dec 19 11:30:37 2025 +0800

    Update TsFileInsertionEventParserTest.java
---
 .../db/pipe/event/TsFileInsertionEventParserTest.java | 19 +++++++++----------
 1 file changed, 9 insertions(+), 10 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 c7fef3cb5b0..f80ac8952a3 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
@@ -24,7 +24,6 @@ import org.apache.iotdb.commons.path.PartialPath;
 import org.apache.iotdb.commons.pipe.datastructure.pattern.IoTDBTreePattern;
 import org.apache.iotdb.commons.pipe.datastructure.pattern.PrefixTreePattern;
 import org.apache.iotdb.commons.pipe.datastructure.pattern.TreePattern;
-import 
org.apache.iotdb.db.pipe.event.common.tablet.PipeRawTabletInsertionEvent;
 import org.apache.iotdb.db.pipe.event.common.tsfile.PipeTsFileInsertionEvent;
 import 
org.apache.iotdb.db.pipe.event.common.tsfile.parser.TsFileInsertionEventParser;
 import 
org.apache.iotdb.db.pipe.event.common.tsfile.parser.query.TsFileInsertionEventQueryParser;
@@ -619,13 +618,13 @@ public class TsFileInsertionEventParserTest {
                                       tabletInsertionEvent2 ->
                                           
tabletInsertionEvent2.processTabletWithCollect(
                                               (tablet, collector) -> {
-                                                            try {
-                                                              
collector.collectTablet(tablet);
-                                                              
count3.addAndGet(getNonNullSize(tablet));
-                                                            } catch (final 
IOException e) {
-                                                              throw new 
RuntimeException(e);
-                                                            }
-                                                          }))));
+                                                try {
+                                                  
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,8 +647,8 @@ public class TsFileInsertionEventParserTest {
 
   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) {
+    for (int i = 0; i < tablet.getRowSize(); ++i) {
+      for (int j = 0; j < tablet.getSchemas().size(); ++j) {
         if (!tablet.isNull(i, j)) {
           ++count;
         }