This is an automated email from the ASF dual-hosted git repository. leirui pushed a commit to branch research/M4-visualization in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit bf06145984beee6a75b38ffa19ee0334cd6be4a6 Author: Lei Rui <[email protected]> AuthorDate: Mon Jun 12 15:11:19 2023 +0800 add log info for plan type --- server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java index cbd4f75eafa..6d7db03c876 100644 --- a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java +++ b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java @@ -524,12 +524,14 @@ public class PlanExecutor implements IPlanExecutor { // no time series are selected, return EmptyDataSet return new EmptyDataSet(); } else if (queryPlan instanceof UDTFPlan) { + logger.info("UDTFPlan"); UDTFPlan udtfPlan = (UDTFPlan) queryPlan; queryDataSet = queryRouter.udtfQuery(udtfPlan, context); } else if (queryPlan instanceof GroupByTimeFillPlan) { GroupByTimeFillPlan groupByFillPlan = (GroupByTimeFillPlan) queryPlan; queryDataSet = queryRouter.groupByFill(groupByFillPlan, context); } else if (queryPlan instanceof GroupByTimePlan) { + logger.info("GroupByTimePlan"); GroupByTimePlan groupByTimePlan = (GroupByTimePlan) queryPlan; queryDataSet = queryRouter.groupBy(groupByTimePlan, context); } else if (queryPlan instanceof QueryIndexPlan) { @@ -543,6 +545,7 @@ public class PlanExecutor implements IPlanExecutor { } else if (queryPlan instanceof LastQueryPlan) { queryDataSet = queryRouter.lastQuery((LastQueryPlan) queryPlan, context); } else { + logger.info("RawDataQueryPlan"); queryDataSet = queryRouter.rawDataQuery((RawDataQueryPlan) queryPlan, context); } }
