(iotdb) branch pipe-table-model-3 updated: IoTDBDataRegionTableModelExtractor

[rong]

This is an automated email from the ASF dual-hosted git repository.

rong pushed a commit to branch pipe-table-model-3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/pipe-table-model-3 by this 
push:
     new 5f7b86eb35c IoTDBDataRegionTableModelExtractor
5f7b86eb35c is described below

commit 5f7b86eb35cbf4c8dbf577cc5594da5cfe46922e
Author: Steve Yurong Su <r...@apache.org>
AuthorDate: Wed Sep 25 20:01:12 2024 +0800

    IoTDBDataRegionTableModelExtractor
---
 .../impl/pipe/task/CreatePipeProcedureV2.java      |  3 +--
 .../IoTDBDataRegionTableModelExtractor.java        | 24 ++++++++++++++++++++++
 2 files changed, 25 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/CreatePipeProcedureV2.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/CreatePipeProcedureV2.java
index b8c712fdc16..b744ef50d6f 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/CreatePipeProcedureV2.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/CreatePipeProcedureV2.java
@@ -196,8 +196,7 @@ public class CreatePipeProcedureV2 extends 
AbstractOperatePipeProcedureV2 {
       // config region
       consensusGroupIdToTaskMetaMap.put(
           // 0 is the consensus group id of the config region, but data region 
id and schema region
-          // id
-          // also start from 0, so we use Integer.MIN_VALUE to represent the 
config region
+          // id also start from 0, so we use Integer.MIN_VALUE to represent 
the config region
           Integer.MIN_VALUE,
           new PipeTaskMeta(
               MinimumProgressIndex.INSTANCE,
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/table/extractor/dataregion/IoTDBDataRegionTableModelExtractor.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/table/extractor/dataregion/IoTDBDataRegionTableModelExtractor.java
new file mode 100644
index 00000000000..a8c35b78333
--- /dev/null
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/table/extractor/dataregion/IoTDBDataRegionTableModelExtractor.java
@@ -0,0 +1,24 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.iotdb.db.pipe.table.extractor.dataregion;
+
+import org.apache.iotdb.db.pipe.extractor.dataregion.IoTDBDataRegionExtractor;
+
+public class IoTDBDataRegionTableModelExtractor extends 
IoTDBDataRegionExtractor {}