You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2024/09/30 14:55:42 UTC
(iotdb) branch pipe-table-model-3 updated (c7e5678d29b -> ba244dfe336)
This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch pipe-table-model-3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c7e5678d29b Update IoTDBDataRegionTableModelExtractor.java
new 4afa04ce29a Update IoTDBDataRegionTableModelExtractor.java
new ba244dfe336 Create PipeTableModelPattern.java
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../pattern/PipeTableModelPattern.java} | 40 ++++++++++++----------
.../IoTDBDataRegionTableModelExtractor.java | 4 ++-
2 files changed, 25 insertions(+), 19 deletions(-)
copy iotdb-core/{consensus/src/test/java/org/apache/iotdb/consensus/EmptyStateMachine.java => datanode/src/main/java/org/apache/iotdb/db/pipe/table/datastructure/pattern/PipeTableModelPattern.java} (52%)
(iotdb) 02/02: Create PipeTableModelPattern.java
Posted by ro...@apache.org.
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
commit ba244dfe3368243d37fe8dcceff69955c3ebecf3
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Sun Sep 29 15:13:19 2024 +0800
Create PipeTableModelPattern.java
---
.../pattern/PipeTableModelPattern.java | 62 ++++++++++++++++++++++
1 file changed, 62 insertions(+)
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/table/datastructure/pattern/PipeTableModelPattern.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/table/datastructure/pattern/PipeTableModelPattern.java
new file mode 100644
index 00000000000..c00a9d3e3b4
--- /dev/null
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/table/datastructure/pattern/PipeTableModelPattern.java
@@ -0,0 +1,62 @@
+/*
+ * 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.datastructure.pattern;
+
+import org.apache.iotdb.commons.pipe.datastructure.pattern.PipePattern;
+import org.apache.tsfile.file.metadata.IDeviceID;
+
+// TODO: refactor the inheritance hierarchy of PipePattern
+// TODO: refactor the name of each class in the inheritance hierarchy of PipePattern
+public class PipeTableModelPattern extends PipePattern {
+
+ protected PipeTableModelPattern(String pattern) {
+ super(pattern);
+ }
+
+ @Override
+ public String getDefaultPattern() {
+ return "";
+ }
+
+ @Override
+ public boolean isLegal() {
+ return false;
+ }
+
+ @Override
+ public boolean coversDb(String db) {
+ return false;
+ }
+
+ @Override
+ public boolean coversDevice(IDeviceID device) {
+ return false;
+ }
+
+ @Override
+ public boolean mayOverlapWithDevice(IDeviceID device) {
+ return false;
+ }
+
+ @Override
+ public boolean matchesMeasurement(IDeviceID device, String measurement) {
+ return false;
+ }
+}
(iotdb) 01/02: Update IoTDBDataRegionTableModelExtractor.java
Posted by ro...@apache.org.
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
commit 4afa04ce29a7e83c2ec3281f729cf2827068c7a0
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Fri Sep 27 12:29:53 2024 +0800
Update IoTDBDataRegionTableModelExtractor.java
---
.../extractor/dataregion/IoTDBDataRegionTableModelExtractor.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
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
index 8bee9a23be5..05c6fd51c6c 100644
--- 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
@@ -122,8 +122,10 @@ public class IoTDBDataRegionTableModelExtractor extends IoTDBDataRegionExtractor
throw new PipeException(
"The pipe cannot transfer data when data region is using ratis consensus.");
}
+ // TODO: Support deletion listening
if (insertionDeletionListeningOptionPair.getRight().equals(true)) {
- throw new PipeException("Table model extractor does not support deletion listening.");
+ throw new PipeException(
+ "Table model extractor currently does not support deletion listening.");
}
// TODO: SQL matcher construction and validation