in iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/executor/ConfigPlanExecutor.java [286:384]
public DataSet executeQueryPlan(final ConfigPhysicalReadPlan req)
throws UnknownPhysicalPlanTypeException, AuthException {
switch (req.getType()) {
case GetDataNodeConfiguration:
return nodeInfo.getDataNodeConfiguration((GetDataNodeConfigurationPlan) req);
case GetAINodeConfiguration:
return nodeInfo.getAINodeConfiguration((GetAINodeConfigurationPlan) req);
case CountDatabase:
return clusterSchemaInfo.countMatchedDatabases((CountDatabasePlan) req);
case GetDatabase:
return clusterSchemaInfo.getMatchedDatabaseSchemas((GetDatabasePlan) req);
case GetDataPartition:
case GetOrCreateDataPartition:
return partitionInfo.getDataPartition((GetDataPartitionPlan) req);
case GetSchemaPartition:
case GetOrCreateSchemaPartition:
return partitionInfo.getSchemaPartition((GetSchemaPartitionPlan) req);
case ListUser:
case RListUser:
return authorInfo.executeListUsers((AuthorPlan) req);
case ListRole:
case RListRole:
return authorInfo.executeListRoles((AuthorPlan) req);
case ListUserPrivilege:
case RListUserPrivilege:
return authorInfo.executeListUserPrivileges((AuthorPlan) req);
case ListRolePrivilege:
case RListRolePrivilege:
return authorInfo.executeListRolePrivileges((AuthorPlan) req);
case GetNodePathsPartition:
return getSchemaNodeManagementPartition(req);
case GetRegionInfoList:
return getRegionInfoList(req);
case GetAllSchemaTemplate:
return clusterSchemaInfo.getAllTemplates();
case GetSchemaTemplate:
return clusterSchemaInfo.getTemplate((GetSchemaTemplatePlan) req);
case CheckTemplateSettable:
return clusterSchemaInfo.checkTemplateSettable((CheckTemplateSettablePlan) req);
case GetPathsSetTemplate:
return clusterSchemaInfo.getPathsSetTemplate((GetPathsSetTemplatePlan) req);
case GetAllTemplateSetInfo:
return clusterSchemaInfo.getAllTemplateSetInfo();
case GetTemplateSetInfo:
return clusterSchemaInfo.getTemplateSetInfo((GetTemplateSetInfoPlan) req);
case ShowTable:
return clusterSchemaInfo.showTables((ShowTablePlan) req);
case ShowTable4InformationSchema:
return clusterSchemaInfo.showTables4InformationSchema();
case FetchTable:
return clusterSchemaInfo.fetchTables((FetchTablePlan) req);
case DescTable:
return clusterSchemaInfo.descTable((DescTablePlan) req);
case DescTable4InformationSchema:
return clusterSchemaInfo.descTable4InformationSchema();
case GetTriggerTable:
return triggerInfo.getTriggerTable((GetTriggerTablePlan) req);
case GetTriggerLocation:
return triggerInfo.getTriggerLocation((GetTriggerLocationPlan) req);
case GetTriggerJar:
return triggerInfo.getTriggerJar((GetTriggerJarPlan) req);
case GetTransferringTriggers:
return triggerInfo.getTransferringTriggers();
case GetRegionId:
return partitionInfo.getRegionId((GetRegionIdPlan) req);
case GetTimeSlotList:
return partitionInfo.getTimeSlotList((GetTimeSlotListPlan) req);
case CountTimeSlotList:
return partitionInfo.countTimeSlotList((CountTimeSlotListPlan) req);
case GetSeriesSlotList:
return partitionInfo.getSeriesSlotList((GetSeriesSlotListPlan) req);
case SHOW_CQ:
return cqInfo.showCQ();
case GetFunctionTable:
return udfInfo.getUDFTable((GetFunctionTablePlan) req);
case GetFunctionJar:
return udfInfo.getUDFJar((GetUDFJarPlan) req);
case GetAllFunctionTable:
return udfInfo.getAllUDFTable();
case ShowModel:
return modelInfo.showModel((ShowModelPlan) req);
case GetModelInfo:
return modelInfo.getModelInfo((GetModelInfoPlan) req);
case GetPipePluginTable:
return pipeInfo.getPipePluginInfo().showPipePlugins();
case GetPipePluginJar:
return pipeInfo.getPipePluginInfo().getPipePluginJar((GetPipePluginJarPlan) req);
case ShowPipeV2:
return pipeInfo.getPipeTaskInfo().showPipes();
case ShowTTL:
return ttlInfo.showTTL((ShowTTLPlan) req);
case ShowTopic:
return subscriptionInfo.showTopics();
case ShowSubscription:
return subscriptionInfo.showSubscriptions();
default:
throw new UnknownPhysicalPlanTypeException(req.getType());
}
}