Pipe: Support 'format'='tsfile' option in table model data sync sinks (…

…#14108) Co-authored-by: Steve Yurong Su <[email protected]>
apache · Jan 7, 2025 · f007e8a · f007e8a
1 parent 2669666
commit f007e8a
Show file tree

Hide file tree

Showing 19 changed files with 2,289 additions and 543 deletions.
diff --git a/integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeDataSinkIT.java b/integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeDataSinkIT.java
diff --git a/integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeNullValueIT.java b/integration-test/src/test/java/org/apache/iotdb/pipe/it/tablemodel/IoTDBPipeNullValueIT.java
@@ -69,7 +69,7 @@ private void testInsertNullValueTemplate(
       TableModelUtils.createDataBaseAndTable(senderEnv, "test", "test");
 
       if (insertType == InsertType.SESSION_INSERT_TABLET) {
-        TableModelUtils.insertDataByTablet("test", "test", 0, 200, senderEnv, true);
+        TableModelUtils.insertTablet("test", "test", 0, 200, senderEnv, true);
       } else if (insertType == InsertType.SQL_INSERT) {
         TableModelUtils.insertData("test", "test", 0, 200, senderEnv, true);
       }
@@ -96,7 +96,7 @@ private void testInsertNullValueTemplate(
     }
 
     if (insertType == InsertType.SESSION_INSERT_TABLET) {
-      TableModelUtils.insertDataByTablet("test", "test", 200, 400, senderEnv, true);
+      TableModelUtils.insertTablet("test", "test", 200, 400, senderEnv, true);
     } else if (insertType == InsertType.SQL_INSERT) {
       TableModelUtils.insertData("test", "test", 200, 400, senderEnv, true);
     }