[incubator-iotdb] branch kyy2 updated: executor

[yu...@apache.org]

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

yuyuankang pushed a commit to branch kyy2
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/kyy2 by this push:
     new 82ef86e  executor
82ef86e is described below

commit 82ef86eaf7937ed0319b77642d6d6e2dc543cc4a
Author: Ring-k <yu...@hotmail.com>
AuthorDate: Mon Jul 6 20:05:52 2020 +0800

    executor
---
 .../org/apache/iotdb/cluster/query/ClusterPlanExecutor.java  | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanExecutor.java b/cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanExecutor.java
index 9695807..4d62eec 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanExecutor.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterPlanExecutor.java
@@ -61,6 +61,7 @@ import org.apache.iotdb.db.metadata.mnode.StorageGroupMNode;
 import org.apache.iotdb.db.qp.executor.PlanExecutor;
 import org.apache.iotdb.db.qp.physical.PhysicalPlan;
 import org.apache.iotdb.db.qp.physical.crud.AlignByDevicePlan;
+import org.apache.iotdb.db.qp.physical.crud.DeletePlan;
 import org.apache.iotdb.db.qp.physical.crud.InsertPlan;
 import org.apache.iotdb.db.qp.physical.crud.QueryPlan;
 import org.apache.iotdb.db.qp.physical.sys.AuthorPlan;
@@ -697,6 +698,17 @@ public class ClusterPlanExecutor extends PlanExecutor {
   }
 
   @Override
+  public void delete(DeletePlan deletePlan) throws QueryProcessException {
+    if (deletePlan.getPaths().isEmpty()) {
+      logger.info("TimeSeries list to be deleted is empty.");
+      return;
+    }
+    for (Path path : deletePlan.getPaths()) {
+      delete(path, deletePlan.getDeleteTime());
+    }
+  }
+
+  @Override
   public void delete(Path path, long timestamp) throws QueryProcessException {
     String deviceId = path.getDevice();
     String measurementId = path.getMeasurement();