2424import org .apache .iotdb .commons .pipe .datastructure .pattern .IoTDBTreePattern ;
2525import org .apache .iotdb .commons .pipe .datastructure .pattern .PrefixTreePattern ;
2626import org .apache .iotdb .commons .pipe .datastructure .pattern .TreePattern ;
27- import org .apache .iotdb .db .pipe .event .common .tablet .PipeRawTabletInsertionEvent ;
2827import org .apache .iotdb .db .pipe .event .common .tsfile .PipeTsFileInsertionEvent ;
2928import org .apache .iotdb .db .pipe .event .common .tsfile .parser .TsFileInsertionEventParser ;
3029import org .apache .iotdb .db .pipe .event .common .tsfile .parser .query .TsFileInsertionEventQueryParser ;
@@ -619,13 +618,13 @@ private void testTsFilePointNum(
619618 tabletInsertionEvent2 ->
620619 tabletInsertionEvent2 .processTabletWithCollect (
621620 (tablet , collector ) -> {
622- try {
623- collector .collectTablet (tablet );
624- count3 .addAndGet (getNonNullSize (tablet ));
625- } catch (final IOException e ) {
626- throw new RuntimeException (e );
627- }
628- }))));
621+ try {
622+ collector .collectTablet (tablet );
623+ count3 .addAndGet (getNonNullSize (tablet ));
624+ } catch (final IOException e ) {
625+ throw new RuntimeException (e );
626+ }
627+ }))));
629628
630629 Assert .assertEquals (expectedCount , count1 .get ());
631630 Assert .assertEquals (expectedCount , count2 .get ());
@@ -648,8 +647,8 @@ private int getNonNullSize(final Row row) {
648647
649648 private int getNonNullSize (final Tablet tablet ) {
650649 int count = 0 ;
651- for (int i = 0 ; i < tablet .getRowSize (); ++i ) {
652- for (int j = 0 ; j < tablet .getSchemas ().size (); ++j ) {
650+ for (int i = 0 ; i < tablet .getRowSize (); ++i ) {
651+ for (int j = 0 ; j < tablet .getSchemas ().size (); ++j ) {
653652 if (!tablet .isNull (i , j )) {
654653 ++count ;
655654 }
0 commit comments