Pipe: Add TsFile parsing with Mods function

integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/IoTDBPipeTsFileDecompositionWithModsIT.java → integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/basic/IoTDBPipeTsFileDecompositionWithModsIT.java

@@ -17,13 +17,14 @@
  * under the License.
  */
 
-package org.apache.iotdb.pipe.it.dual.tablemodel.manual;
+package org.apache.iotdb.pipe.it.dual.tablemodel.manual.basic;
 
 import org.apache.iotdb.db.it.utils.TestUtils;
 import org.apache.iotdb.isession.SessionConfig;
 import org.apache.iotdb.it.framework.IoTDBTestRunner;
 import org.apache.iotdb.itbase.category.MultiClusterIT2DualTableManualBasic;
 import org.apache.iotdb.pipe.it.dual.tablemodel.TableModelUtils;
+import org.apache.iotdb.pipe.it.dual.tablemodel.manual.AbstractPipeTableModelDualManualIT;
 
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
@@ -38,6 +39,24 @@
 @Category({MultiClusterIT2DualTableManualBasic.class})
 public class IoTDBPipeTsFileDecompositionWithModsIT extends AbstractPipeTableModelDualManualIT {
 
+  /**
+   * Test IoTDB pipe handling TsFile decomposition with Mods (modification operations) in table
+   * model
+   *
+   * <p>Test scenario: 1. Create two storage groups sg1 and sg2, each containing table1 2. Insert
+   * small amount of data in sg1 (1-6 rows), insert large amount of data in sg2 (110 batches, 100
+   * rows per batch) 3. Execute FLUSH operation to persist data to TsFile 4. Execute multiple DELETE
+   * operations on sg1, deleting data in time ranges 2-4 and 3-5 5. Execute multiple DELETE
+   * operations on sg2, deleting data matching specific conditions (s0-s3 field values) 6. Execute
+   * FLUSH operation again 7. Create pipe with mods enabled, synchronize data to receiver 8. Verify
+   * correctness of receiver data: - sg1 only retains time=1 data, time=2-4 data is correctly
+   * deleted - sg2 DELETE operation results meet expectations (t10 retains 1000 rows, t11 all
+   * deleted, t12 retains 5900 rows, etc.)
+   *
+   * <p>Test purpose: Verify that IoTDB pipe can correctly handle Mods (modification operations) in
+   * TsFile, ensuring DELETE operations can be correctly synchronized to the receiver and data
+   * consistency is guaranteed.
+   */
   @Test
   public void testTsFileDecompositionWithMods() {
     TableModelUtils.createDataBaseAndTable(senderEnv, "table1", "sg1");
@@ -149,13 +168,6 @@ public void testTsFileDecompositionWithMods() {
         Collections.singleton("0,"),
         "sg2");
 
-    TestUtils.assertDataEventuallyOnEnv(
-        receiverEnv,
-        "SELECT COUNT(*) as count FROM table1 WHERE s0 ='t11' AND s1='t11' AND s2='t11' AND s3='t11'",
-        "count,",
-        Collections.singleton("0,"),
-        "sg2");
-
     TestUtils.assertDataEventuallyOnEnv(
         receiverEnv,
         "SELECT COUNT(*) as count FROM table1 WHERE s0 ='t12' AND s1='t12' AND s2='t12' AND s3='t12'",