You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ge...@apache.org on 2020/07/14 12:09:18 UTC
[incubator-iotdb] branch optimize_path updated: add delete
storegroup
This is an automated email from the ASF dual-hosted git repository.
geniuspig pushed a commit to branch optimize_path
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/optimize_path by this push:
new 613c6b3 add delete storegroup
613c6b3 is described below
commit 613c6b3fc0314d80eef0388c063bb770f3421eb8
Author: zhutianci <zh...@gmail.com>
AuthorDate: Tue Jul 14 20:08:57 2020 +0800
add delete storegroup
---
.../java/org/apache/iotdb/db/qp/strategy/LogicalGenerator.java | 6 ++++--
.../src/main/java/org/apache/iotdb/tsfile/read/common/Path.java | 8 ++++++++
2 files changed, 12 insertions(+), 2 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/qp/strategy/LogicalGenerator.java b/server/src/main/java/org/apache/iotdb/db/qp/strategy/LogicalGenerator.java
index 24f4b1e..4c8967c 100644
--- a/server/src/main/java/org/apache/iotdb/db/qp/strategy/LogicalGenerator.java
+++ b/server/src/main/java/org/apache/iotdb/db/qp/strategy/LogicalGenerator.java
@@ -785,10 +785,12 @@ public class LogicalGenerator extends SqlBaseBaseListener {
@Override
public void enterDeleteStorageGroup(DeleteStorageGroupContext ctx) {
super.enterDeleteStorageGroup(ctx);
- List<String> deletePaths = new ArrayList<>();
+ List<Path> deletePaths = new ArrayList<>();
List<FullPathContext> fullPaths = ctx.fullPath();
for (FullPathContext fullPath : fullPaths) {
- deletePaths.add(fullPath.getText());
+ Path path = new Path();
+ path.setFullPath(fullPath.getText());
+ deletePaths.add(path);
}
DeleteStorageGroupOperator deleteStorageGroupOperator = new DeleteStorageGroupOperator(
SQLConstant.TOK_METADATA_DELETE_FILE_LEVEL);
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/Path.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/Path.java
index 8cef5d1..63b9bae 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/Path.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/Path.java
@@ -54,6 +54,10 @@ public class Path implements Serializable, Comparable<Path> {
init(pathSc);
}
+ public Path() {
+
+ }
+
public Path(List<String> nodes) {
this.nodes = nodes;
}
@@ -152,6 +156,10 @@ public class Path implements Serializable, Comparable<Path> {
return addPrefixPath(src, prefix.fullPath);
}
+ public void setFullPath(String fullPath) {
+ this.fullPath = fullPath;
+ }
+
public String getFullPath() {
return fullPath;
}