[iotdb] 02/07: implement analyzer

[hu...@apache.org]

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

hui pushed a commit to branch ml/windowSet
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit b17a2188867a6e34725bca90e1e7e85311c58c2f
Author: Minghui Liu <li...@foxmail.com>
AuthorDate: Tue Nov 1 10:27:13 2022 +0800

    implement analyzer
---
 .../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java  | 39 ++++++++++++++++++++++
 .../db/mpp/plan/statement/StatementVisitor.java    |  5 +++
 .../statement/crud/FetchWindowSetStatement.java    |  8 +++++
 3 files changed, 52 insertions(+)

diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java
index 493b6814ca..1f29d600c7 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java
@@ -68,6 +68,7 @@ import org.apache.iotdb.db.mpp.plan.statement.component.SortItem;
 import org.apache.iotdb.db.mpp.plan.statement.component.SortKey;
 import org.apache.iotdb.db.mpp.plan.statement.component.WhereCondition;
 import org.apache.iotdb.db.mpp.plan.statement.crud.DeleteDataStatement;
+import org.apache.iotdb.db.mpp.plan.statement.crud.FetchWindowSetStatement;
 import org.apache.iotdb.db.mpp.plan.statement.crud.InsertMultiTabletsStatement;
 import org.apache.iotdb.db.mpp.plan.statement.crud.InsertRowStatement;
 import org.apache.iotdb.db.mpp.plan.statement.crud.InsertRowsOfOneDeviceStatement;
@@ -1206,6 +1207,44 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext>
     }
   }
 
+  @Override
+  public Analysis visitFetchWindowSet(
+      FetchWindowSetStatement fetchWindowSetStatement, MPPQueryContext context) {
+    Analysis analysis = new Analysis();
+    analysis.setStatement(fetchWindowSetStatement);
+
+    // check for semantic errors
+    fetchWindowSetStatement.semanticCheck();
+
+    // concat path and construct path pattern tree
+    PathPatternTree patternTree = new PathPatternTree();
+    for (PartialPath path : fetchWindowSetStatement.getQueryPaths()) {
+      patternTree.appendFullPath(path);
+    }
+
+    // request schema fetch API
+    logger.info("[StartFetchSchema]");
+    ISchemaTree schemaTree = schemaFetcher.fetchSchema(patternTree);
+    logger.info("[EndFetchSchema]");
+
+    // set source
+    List<MeasurementPath> measurementPaths = schemaTree.getAllMeasurement();
+    Set<Expression> sourceExpressions =
+        measurementPaths.stream().map(TimeSeriesOperand::new).collect(Collectors.toSet());
+    analysis.setSourceExpressions(sourceExpressions);
+
+    // set output
+    List<ColumnHeader> columnHeaders =
+        measurementPaths.stream()
+            .map(
+                measurementPath ->
+                    new ColumnHeader(measurementPath.toString(), measurementPath.getSeriesType()))
+            .collect(Collectors.toList());
+    analysis.setRespDatasetHeader(new DatasetHeader(columnHeaders, false));
+
+    return analysis;
+  }
+
   @Override
   public Analysis visitInsert(InsertStatement insertStatement, MPPQueryContext context) {
     context.setQueryType(QueryType.WRITE);
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/StatementVisitor.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/StatementVisitor.java
index bd1d02330a..be03262f80 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/StatementVisitor.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/StatementVisitor.java
@@ -20,6 +20,7 @@
 package org.apache.iotdb.db.mpp.plan.statement;
 
 import org.apache.iotdb.db.mpp.plan.statement.crud.DeleteDataStatement;
+import org.apache.iotdb.db.mpp.plan.statement.crud.FetchWindowSetStatement;
 import org.apache.iotdb.db.mpp.plan.statement.crud.InsertMultiTabletsStatement;
 import org.apache.iotdb.db.mpp.plan.statement.crud.InsertRowStatement;
 import org.apache.iotdb.db.mpp.plan.statement.crud.InsertRowsOfOneDeviceStatement;
@@ -207,6 +208,10 @@ public abstract class StatementVisitor<R, C> {
     return visitStatement(queryStatement, context);
   }
 
+  public R visitFetchWindowSet(FetchWindowSetStatement fetchWindowSetStatement, C context) {
+    return visitStatement(fetchWindowSetStatement, context);
+  }
+
   // Insert Statement
   public R visitInsert(InsertStatement insertStatement, C context) {
     return visitStatement(insertStatement, context);
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/FetchWindowSetStatement.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/FetchWindowSetStatement.java
index f7cb723474..fd9dc9a1e0 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/FetchWindowSetStatement.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/FetchWindowSetStatement.java
@@ -23,6 +23,7 @@ import org.apache.iotdb.commons.path.PartialPath;
 import org.apache.iotdb.db.mpp.plan.constant.StatementType;
 import org.apache.iotdb.db.mpp.plan.planner.plan.parameter.GroupByTimeParameter;
 import org.apache.iotdb.db.mpp.plan.statement.Statement;
+import org.apache.iotdb.db.mpp.plan.statement.StatementVisitor;
 
 import java.util.List;
 
@@ -74,4 +75,11 @@ public class FetchWindowSetStatement extends Statement {
   public List<? extends PartialPath> getPaths() {
     return queryPaths;
   }
+
+  @Override
+  public <R, C> R accept(StatementVisitor<R, C> visitor, C context) {
+    return visitor.visitFetchWindowSet(this, context);
+  }
+
+  public void semanticCheck() {}
 }