[IOTDB-3656] basic mpp load implement (apache#6764)

yonyou-tsdb · Sep 16, 2022 · 2aea45b · 2aea45b
1 parent b1cf25b
commit 2aea45b
Show file tree

Hide file tree

Showing 38 changed files with 3,535 additions and 11 deletions.
diff --git a/integration-test/import-control.xml b/integration-test/import-control.xml
@@ -27,6 +27,7 @@
   <allow pkg="java.io"/>
   <allow pkg="java.math"/>
   <allow pkg="java.text"/>
+  <allow class="java.nio.file.Files"/>
   <allow pkg="org\.junit.*" regex="true"/>
   <allow pkg="org\.apache\.iotdb\.itbase" regex="true"/>
   <allow pkg="org\.apache\.iotdb\.it.*" regex="true"/>
@@ -43,4 +44,10 @@
   <allow pkg="org\.apache\.iotdb\.commons\.conf.*" regex="true"/>
   <allow pkg="org\.apache\.iotdb\.db\.qp\.logical\.sys.*" regex="true"/>
   <allow pkg="org\.apache\.iotdb\.db\.mpp\.common\.header.*" regex="true" />
+  <allow pkg="org\.apache\.iotdb\.tsfile\.exception\.write.*" regex="true" />
+  <allow pkg="org\.apache\.iotdb\.tsfile\.file\.metadata.*" regex="true" />
+  <allow pkg="org\.apache\.iotdb\.tsfile\.read.*" regex="true" />
+  <allow pkg="org\.apache\.iotdb\.tsfile\.utils.*" regex="true" />
+  <allow pkg="org\.apache\.iotdb\.tsfile\.write.*" regex="true" />
+  <allow pkg="org\.slf4j.*" regex="true" />
 </import-control>
diff --git a/integration-test/src/main/java/org/apache/iotdb/it/env/AbstractNodeWrapper.java b/integration-test/src/main/java/org/apache/iotdb/it/env/AbstractNodeWrapper.java
@@ -174,7 +174,9 @@ public void start() {
               "-Xms200m",
               "-Xmx200m",
               "-XX:MaxDirectMemorySize=200m",
-              "-Djdk.nio.maxCachedBufferSize=262144"));
+              "-Djdk.nio.maxCachedBufferSize=262144",
+              "-cp",
+              templateNodeLibPath));
       addStartCmdParams(startCmd);
       FileUtils.write(
           stdoutFile, String.join(" ", startCmd) + "\n\n", StandardCharsets.UTF_8, true);

diff --git a/integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseConfig.java b/integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseConfig.java
@@ -70,6 +70,10 @@ default BaseConfig setDataRegionNum(int dataRegionNum) {
     return this;
   }
 
+  default boolean isEnablePartition() {
+    return true;
+  }
+
   default BaseConfig setPartitionInterval(long partitionInterval) {
     return this;
   }