[IOTDB-3562] Support Deactivate Template in cluster

antlr/src/main/antlr4/org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4

@@ -39,7 +39,7 @@ ddlStatement
     : setStorageGroup | createStorageGroup | createTimeseries
     | createSchemaTemplate | createTimeseriesOfSchemaTemplate
     | createFunction | createTrigger | createContinuousQuery
-    | alterTimeseries | deleteStorageGroup | deleteTimeseries | deletePartition
+    | alterTimeseries | deleteStorageGroup | deleteTimeseries | deletePartition | deleteTimeseriesOfSchemaTemplate
     | dropFunction | dropTrigger | dropContinuousQuery | dropSchemaTemplate
     | setTTL | unsetTTL | startTrigger | stopTrigger | setSchemaTemplate | unsetSchemaTemplate
     | showStorageGroup | showDevices | showTimeseries | showChildPaths | showChildNodes
@@ -206,6 +206,11 @@ deletePartition
     : DELETE PARTITION prefixPath INTEGER_LITERAL(COMMA INTEGER_LITERAL)*
     ;
 
+// Delete Timeseries of Schema Template
+deleteTimeseriesOfSchemaTemplate
+    : (DELETE TIMESERIES OF | DEACTIVATE) SCHEMA? TEMPLATE (templateName=identifier) ? FROM prefixPath (COMMA prefixPath)*
+    ;
+
 // Drop Function
 dropFunction
     : DROP FUNCTION udfName=identifier
@@ -361,7 +366,7 @@ showPathsSetSchemaTemplate
 
 // Show Paths Using Schema Template
 showPathsUsingSchemaTemplate
-    : SHOW PATHS USING SCHEMA? TEMPLATE templateName=identifier
+    : SHOW PATHS prefixPath? USING SCHEMA? TEMPLATE templateName=identifier
     ;
 
 // Count Storage Group

antlr/src/main/antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4

@@ -162,6 +162,10 @@ DATANODES
     : D A T A N O D E S
     ;
 
+DEACTIVATE
+    : D E A C T I V A T E
+    ;
+
 DEBUG
     : D E B U G
     ;

confignode/src/main/java/org/apache/iotdb/confignode/client/DataNodeRequestType.java

@@ -75,6 +75,10 @@ public enum DataNodeRequestType {
   ROLLBACK_SCHEMA_BLACK_LIST,
   FETCH_SCHEMA_BLACK_LIST,
   INVALIDATE_MATCHED_SCHEMA_CACHE,
-  DELETE_DATA_FOR_DELETE_TIMESERIES,
-  DELETE_TIMESERIES
+  DELETE_DATA_FOR_DELETE_SCHEMA,
+  DELETE_TIMESERIES,
+
+  CONSTRUCT_SCHEMA_BLACK_LIST_WITH_TEMPLATE,
+  ROLLBACK_SCHEMA_BLACK_LIST_WITH_TEMPLATE,
+  DEACTIVATE_TEMPLATE
 }

confignode/src/main/java/org/apache/iotdb/confignode/client/async/AsyncDataNodeClientPool.java

@@ -28,16 +28,18 @@
 import org.apache.iotdb.confignode.client.DataNodeRequestType;
 import org.apache.iotdb.confignode.client.async.handlers.AsyncClientHandler;
 import org.apache.iotdb.confignode.client.async.handlers.rpc.AsyncTSStatusRPCHandler;
-import org.apache.iotdb.confignode.client.async.handlers.rpc.DeleteTimeSeriesRPCHandler;
+import org.apache.iotdb.confignode.client.async.handlers.rpc.DeleteSchemaRPCHandler;
 import org.apache.iotdb.confignode.client.async.handlers.rpc.FetchSchemaBlackListRPCHandler;
 import org.apache.iotdb.mpp.rpc.thrift.TActiveTriggerInstanceReq;
 import org.apache.iotdb.mpp.rpc.thrift.TConstructSchemaBlackListReq;
+import org.apache.iotdb.mpp.rpc.thrift.TConstructSchemaBlackListWithTemplateReq;
 import org.apache.iotdb.mpp.rpc.thrift.TCreateDataRegionReq;
 import org.apache.iotdb.mpp.rpc.thrift.TCreateFunctionRequest;
 import org.apache.iotdb.mpp.rpc.thrift.TCreatePipeOnDataNodeReq;
 import org.apache.iotdb.mpp.rpc.thrift.TCreateSchemaRegionReq;
 import org.apache.iotdb.mpp.rpc.thrift.TCreateTriggerInstanceReq;
-import org.apache.iotdb.mpp.rpc.thrift.TDeleteDataForDeleteTimeSeriesReq;
+import org.apache.iotdb.mpp.rpc.thrift.TDeactivateTemplateReq;
+import org.apache.iotdb.mpp.rpc.thrift.TDeleteDataForDeleteSchemaReq;
 import org.apache.iotdb.mpp.rpc.thrift.TDeleteTimeSeriesReq;
 import org.apache.iotdb.mpp.rpc.thrift.TDropFunctionRequest;
 import org.apache.iotdb.mpp.rpc.thrift.TDropTriggerInstanceReq;
@@ -47,6 +49,7 @@
 import org.apache.iotdb.mpp.rpc.thrift.TOperatePipeOnDataNodeReq;
 import org.apache.iotdb.mpp.rpc.thrift.TRegionRouteReq;
 import org.apache.iotdb.mpp.rpc.thrift.TRollbackSchemaBlackListReq;
+import org.apache.iotdb.mpp.rpc.thrift.TRollbackSchemaBlackListWithTemplateReq;
 import org.apache.iotdb.mpp.rpc.thrift.TUpdateConfigNodeGroupReq;
 import org.apache.iotdb.mpp.rpc.thrift.TUpdateTriggerLocationReq;
 
@@ -220,13 +223,13 @@ private void sendAsyncRequestToDataNode(
         case CONSTRUCT_SCHEMA_BLACK_LIST:
           client.constructSchemaBlackList(
               (TConstructSchemaBlackListReq) clientHandler.getRequest(requestId),
-              (DeleteTimeSeriesRPCHandler)
+              (DeleteSchemaRPCHandler)
                   clientHandler.createAsyncRPCHandler(requestId, targetDataNode));
           break;
         case ROLLBACK_SCHEMA_BLACK_LIST:
           client.rollbackSchemaBlackList(
               (TRollbackSchemaBlackListReq) clientHandler.getRequest(requestId),
-              (DeleteTimeSeriesRPCHandler)
+              (DeleteSchemaRPCHandler)
                   clientHandler.createAsyncRPCHandler(requestId, targetDataNode));
           break;
         case FETCH_SCHEMA_BLACK_LIST:
@@ -241,16 +244,16 @@ private void sendAsyncRequestToDataNode(
               (AsyncTSStatusRPCHandler)
                   clientHandler.createAsyncRPCHandler(requestId, targetDataNode));
           break;
-        case DELETE_DATA_FOR_DELETE_TIMESERIES:
-          client.deleteDataForDeleteTimeSeries(
-              (TDeleteDataForDeleteTimeSeriesReq) clientHandler.getRequest(requestId),
-              (DeleteTimeSeriesRPCHandler)
+        case DELETE_DATA_FOR_DELETE_SCHEMA:
+          client.deleteDataForDeleteSchema(
+              (TDeleteDataForDeleteSchemaReq) clientHandler.getRequest(requestId),
+              (DeleteSchemaRPCHandler)
                   clientHandler.createAsyncRPCHandler(requestId, targetDataNode));
           break;
         case DELETE_TIMESERIES:
           client.deleteTimeSeries(
               (TDeleteTimeSeriesReq) clientHandler.getRequest(requestId),
-              (DeleteTimeSeriesRPCHandler)
+              (DeleteSchemaRPCHandler)
                   clientHandler.createAsyncRPCHandler(requestId, targetDataNode));
           break;
         case PRE_CREATE_PIPE:
@@ -265,6 +268,23 @@ private void sendAsyncRequestToDataNode(
               (AsyncTSStatusRPCHandler)
                   clientHandler.createAsyncRPCHandler(requestId, targetDataNode));
           break;
+        case CONSTRUCT_SCHEMA_BLACK_LIST_WITH_TEMPLATE:
+          client.constructSchemaBlackListWithTemplate(
+              (TConstructSchemaBlackListWithTemplateReq) clientHandler.getRequest(requestId),
+              (DeleteSchemaRPCHandler)
+                  clientHandler.createAsyncRPCHandler(requestId, targetDataNode));
+          break;
+        case ROLLBACK_SCHEMA_BLACK_LIST_WITH_TEMPLATE:
+          client.rollbackSchemaBlackListWithTemplate(
+              (TRollbackSchemaBlackListWithTemplateReq) clientHandler.getRequest(requestId),
+              (DeleteSchemaRPCHandler)
+                  clientHandler.createAsyncRPCHandler(requestId, targetDataNode));
+          break;
+        case DEACTIVATE_TEMPLATE:
+          client.deactivateTemplate(
+              (TDeactivateTemplateReq) clientHandler.getRequest(requestId),
+              (DeleteSchemaRPCHandler)
+                  clientHandler.createAsyncRPCHandler(requestId, targetDataNode));
         default:
           LOGGER.error(
               "Unexpected DataNode Request Type: {} when sendAsyncRequestToDataNode",

confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/AsyncClientHandler.java

@@ -23,7 +23,7 @@
 import org.apache.iotdb.confignode.client.DataNodeRequestType;
 import org.apache.iotdb.confignode.client.async.handlers.rpc.AbstractAsyncRPCHandler;
 import org.apache.iotdb.confignode.client.async.handlers.rpc.AsyncTSStatusRPCHandler;
-import org.apache.iotdb.confignode.client.async.handlers.rpc.DeleteTimeSeriesRPCHandler;
+import org.apache.iotdb.confignode.client.async.handlers.rpc.DeleteSchemaRPCHandler;
 import org.apache.iotdb.confignode.client.async.handlers.rpc.FetchSchemaBlackListRPCHandler;
 import org.apache.iotdb.mpp.rpc.thrift.TFetchSchemaBlackListResp;
 
@@ -153,9 +153,12 @@ public AbstractAsyncRPCHandler<?> createAsyncRPCHandler(
     switch (requestType) {
       case CONSTRUCT_SCHEMA_BLACK_LIST:
       case ROLLBACK_SCHEMA_BLACK_LIST:
-      case DELETE_DATA_FOR_DELETE_TIMESERIES:
+      case DELETE_DATA_FOR_DELETE_SCHEMA:
       case DELETE_TIMESERIES:
-        return new DeleteTimeSeriesRPCHandler(
+      case CONSTRUCT_SCHEMA_BLACK_LIST_WITH_TEMPLATE:
+      case ROLLBACK_SCHEMA_BLACK_LIST_WITH_TEMPLATE:
+      case DEACTIVATE_TEMPLATE:
+        return new DeleteSchemaRPCHandler(
             requestType,
             requestId,
             targetDataNode,

confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/DeleteTimeSeriesRPCHandler.java → confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/DeleteSchemaRPCHandler.java

@@ -31,11 +31,11 @@
 import java.util.Map;
 import java.util.concurrent.CountDownLatch;
 
-public class DeleteTimeSeriesRPCHandler extends AsyncTSStatusRPCHandler {
+public class DeleteSchemaRPCHandler extends AsyncTSStatusRPCHandler {
 
-  private static final Logger LOGGER = LoggerFactory.getLogger(DeleteTimeSeriesRPCHandler.class);
+  private static final Logger LOGGER = LoggerFactory.getLogger(DeleteSchemaRPCHandler.class);
 
-  public DeleteTimeSeriesRPCHandler(
+  public DeleteSchemaRPCHandler(
       DataNodeRequestType requestType,
       int requestId,
       TDataNodeLocation targetDataNode,

confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlan.java

@@ -41,6 +41,7 @@
 import org.apache.iotdb.confignode.consensus.request.read.template.GetAllTemplateSetInfoPlan;
 import org.apache.iotdb.confignode.consensus.request.read.template.GetPathsSetTemplatePlan;
 import org.apache.iotdb.confignode.consensus.request.read.template.GetSchemaTemplatePlan;
+import org.apache.iotdb.confignode.consensus.request.read.template.GetTemplateSetInfoPlan;
 import org.apache.iotdb.confignode.consensus.request.write.confignode.ApplyConfigNodePlan;
 import org.apache.iotdb.confignode.consensus.request.write.confignode.RemoveConfigNodePlan;
 import org.apache.iotdb.confignode.consensus.request.write.datanode.RegisterDataNodePlan;
@@ -272,6 +273,9 @@ public static ConfigPhysicalPlan create(ByteBuffer buffer) throws IOException {
         case SetSchemaTemplate:
           req = new SetSchemaTemplatePlan();
           break;
+        case GetTemplateSetInfo:
+          req = new GetTemplateSetInfoPlan();
+          break;
         case GetNodePathsPartition:
           req = new GetNodePathsPartitionPlan();
           break;

confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanType.java

@@ -97,5 +97,6 @@ public enum ConfigPhysicalPlanType {
   UpdateTriggersOnTransferNodes,
   UpdateTriggerLocation,
   GetTransferringTriggers,
-  GetTriggerLocation
+  GetTriggerLocation,
+  GetTemplateSetInfo
 }

confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/template/GetTemplateSetInfoPlan.java

@@ -0,0 +1,68 @@
+/*
+ * 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.confignode.consensus.request.read.template;
+
+import org.apache.iotdb.commons.path.PartialPath;
+import org.apache.iotdb.commons.path.PathDeserializeUtil;
+import org.apache.iotdb.confignode.consensus.request.ConfigPhysicalPlan;
+import org.apache.iotdb.confignode.consensus.request.ConfigPhysicalPlanType;
+import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils;
+
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.nio.ByteBuffer;
+import java.util.ArrayList;
+import java.util.List;
+
+public class GetTemplateSetInfoPlan extends ConfigPhysicalPlan {
+
+  private List<PartialPath> patternList;
+
+  public GetTemplateSetInfoPlan() {
+    super(ConfigPhysicalPlanType.GetTemplateSetInfo);
+  }
+
+  public GetTemplateSetInfoPlan(List<PartialPath> patternList) {
+    super(ConfigPhysicalPlanType.GetTemplateSetInfo);
+    this.patternList = patternList;
+  }
+
+  public List<PartialPath> getPatternList() {
+    return patternList;
+  }
+
+  @Override
+  protected void serializeImpl(DataOutputStream stream) throws IOException {
+    ReadWriteIOUtils.write(ConfigPhysicalPlanType.GetTemplateSetInfo.ordinal(), stream);
+    ReadWriteIOUtils.write(patternList.size(), stream);
+    for (PartialPath pattern : patternList) {
+      pattern.serialize(stream);
+    }
+  }
+
+  @Override
+  protected void deserializeImpl(ByteBuffer buffer) throws IOException {
+    int size = ReadWriteIOUtils.readInt(buffer);
+    patternList = new ArrayList<>(size);
+    for (int i = 0; i < size; i++) {
+      patternList.add((PartialPath) PathDeserializeUtil.deserialize(buffer));
+    }
+  }
+}

confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TemplateSetInfoResp.java

@@ -0,0 +1,52 @@
+/*
+ * 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.confignode.consensus.response;
+
+import org.apache.iotdb.common.rpc.thrift.TSStatus;
+import org.apache.iotdb.commons.path.PartialPath;
+import org.apache.iotdb.consensus.common.DataSet;
+import org.apache.iotdb.db.metadata.template.Template;
+
+import java.util.List;
+import java.util.Map;
+
+public class TemplateSetInfoResp implements DataSet {
+
+  private TSStatus status;
+  private Map<PartialPath, List<Template>> patternTemplateMap;
+
+  public TemplateSetInfoResp() {}
+
+  public TSStatus getStatus() {
+    return status;
+  }
+
+  public void setStatus(TSStatus status) {
+    this.status = status;
+  }
+
+  public Map<PartialPath, List<Template>> getPatternTemplateMap() {
+    return patternTemplateMap;
+  }
+
+  public void setPatternTemplateMap(Map<PartialPath, List<Template>> patternTemplateMap) {
+    this.patternTemplateMap = patternTemplateMap;
+  }
+}

confignode/src/main/java/org/apache/iotdb/confignode/manager/ClusterSchemaManager.java

@@ -39,6 +39,7 @@
 import org.apache.iotdb.confignode.consensus.request.read.template.GetAllTemplateSetInfoPlan;
 import org.apache.iotdb.confignode.consensus.request.read.template.GetPathsSetTemplatePlan;
 import org.apache.iotdb.confignode.consensus.request.read.template.GetSchemaTemplatePlan;
+import org.apache.iotdb.confignode.consensus.request.read.template.GetTemplateSetInfoPlan;
 import org.apache.iotdb.confignode.consensus.request.write.storagegroup.AdjustMaxRegionGroupCountPlan;
 import org.apache.iotdb.confignode.consensus.request.write.storagegroup.DeleteStorageGroupPlan;
 import org.apache.iotdb.confignode.consensus.request.write.storagegroup.SetDataReplicationFactorPlan;
@@ -52,6 +53,7 @@
 import org.apache.iotdb.confignode.consensus.response.PathInfoResp;
 import org.apache.iotdb.confignode.consensus.response.StorageGroupSchemaResp;
 import org.apache.iotdb.confignode.consensus.response.TemplateInfoResp;
+import org.apache.iotdb.confignode.consensus.response.TemplateSetInfoResp;
 import org.apache.iotdb.confignode.exception.StorageGroupNotExistsException;
 import org.apache.iotdb.confignode.manager.node.NodeManager;
 import org.apache.iotdb.confignode.manager.partition.PartitionManager;
@@ -553,6 +555,11 @@ public byte[] getAllTemplateSetInfo() {
     return resp.getTemplateInfo();
   }
 
+  public TemplateSetInfoResp getTemplateSetInfo(List<PartialPath> patternList) {
+    return (TemplateSetInfoResp)
+        getConsensusManager().read(new GetTemplateSetInfoPlan(patternList)).getDataset();
+  }
+
   private NodeManager getNodeManager() {
     return configManager.getNodeManager();
   }