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 <[email protected]> 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() {} }
