This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch ty/TableModelGrammar in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c3c833392b3a82f95fd1c5880f22f96f0f10eafe Merge: d0584cd8e69 bfa1336e75d Author: JackieTien97 <[email protected]> AuthorDate: Sun Apr 7 16:31:32 2024 +0800 resolve conflicts iotdb-core/datanode/pom.xml | 8 + .../relational/cost/CachingTableStatsProvider.java | 51 ++++ .../plan/relational/cost/ColumnStatistics.java | 156 +++++++++++ .../plan/relational/cost/DoubleRange.java | 104 +++++++ .../queryengine/plan/relational/cost/Estimate.java | 84 ++++++ .../plan/relational/cost/StatsUtil.java | 43 +++ .../plan/relational/cost/TableStatistics.java | 112 ++++++++ .../plan/relational/cost/TableStatsProvider.java | 20 ++ .../relational/metadata/TableMetadataImpl.java | 62 +++++ .../plan/relational/planner/Assignments.java | 231 +++++++++++++++ .../plan/relational/planner/LogicalPlanner.java | 114 ++++++++ .../plan/relational/planner/OrderingScheme.java | 89 ++++++ .../relational/planner/OrderingTranslator.java | 34 +++ .../plan/relational/planner/PlanBuilder.java | 90 ++++++ .../plan/relational/planner/QueryPlanner.java | 310 +++++++++++++++++++++ .../plan/relational/planner/RelationPlan.java | 78 ++++++ .../plan/relational/planner/RelationPlanner.java | 241 ++++++++++++++++ .../relational/planner/RelationalModelPlanner.java | 9 + .../plan/relational/planner/SortOrder.java | 44 +++ .../plan/relational/planner/SymbolAllocator.java | 124 +++++++++ .../plan/relational/planner/node/FilterNode.java | 36 +++ .../plan/relational/planner/node/LimitNode.java | 43 +++ .../plan/relational/planner/node/OffsetNode.java | 35 +++ .../plan/relational/planner/node/OutputNode.java | 43 +++ .../plan/relational/planner/node/ProjectNode.java | 36 +++ .../plan/relational/planner/node/SortNode.java | 38 +++ .../relational/planner/node/TableScanNode.java | 59 ++++ .../plan/relational/analyzer/AnalyzerTest.java | 46 ++- .../plan/relational/analyzer/TestMatadata.java | 109 ++++++++ 29 files changed, 2447 insertions(+), 2 deletions(-) diff --cc iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/TableMetadataImpl.java index 00000000000,00000000000..95fcfcaacbe new file mode 100644 --- /dev/null +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/TableMetadataImpl.java @@@ -1,0 -1,0 +1,62 @@@ ++/* ++ * 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.db.queryengine.plan.relational.metadata; ++ ++import org.apache.iotdb.db.queryengine.common.SessionInfo; ++import org.apache.iotdb.db.queryengine.plan.relational.function.OperatorType; ++import org.apache.iotdb.tsfile.read.common.type.Type; ++ ++import java.util.List; ++import java.util.Map; ++import java.util.Optional; ++ ++public class TableMetadataImpl implements Metadata { ++ @Override ++ public boolean tableExists(QualifiedObjectName name) { ++ return false; ++ } ++ ++ @Override ++ public TableSchema getTableSchema(SessionInfo session, TableHandle tableHandle) { ++ return null; ++ } ++ ++ @Override ++ public TableMetadata getTableMetadata(SessionInfo session, TableHandle tableHandle) { ++ return null; ++ } ++ ++ @Override ++ public Optional<TableHandle> getTableHandle(SessionInfo session, QualifiedObjectName name) { ++ return Optional.empty(); ++ } ++ ++ @Override ++ public Map<String, ColumnHandle> getColumnHandles(SessionInfo session, TableHandle tableHandle) { ++ return null; ++ } ++ ++ @Override ++ public ResolvedFunction resolveOperator( ++ OperatorType operatorType, List<? extends Type> argumentTypes) ++ throws OperatorNotFoundException { ++ return null; ++ } ++} diff --cc iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/RelationalModelPlanner.java index fc1cf051c98,1970fedc625..df6a4902e1a --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/RelationalModelPlanner.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/RelationalModelPlanner.java @@@ -21,12 -21,10 +21,13 @@@ package org.apache.iotdb.db.queryengine import org.apache.iotdb.common.rpc.thrift.TEndPoint; import org.apache.iotdb.common.rpc.thrift.TSStatus; +import org.apache.iotdb.commons.client.IClientManager; +import org.apache.iotdb.commons.client.async.AsyncDataNodeInternalServiceClient; +import org.apache.iotdb.commons.client.sync.SyncDataNodeInternalServiceClient; + import org.apache.iotdb.commons.exception.IoTDBException; import org.apache.iotdb.db.queryengine.common.MPPQueryContext; -import org.apache.iotdb.db.queryengine.common.SessionInfo; import org.apache.iotdb.db.queryengine.execution.QueryStateMachine; +import org.apache.iotdb.db.queryengine.execution.warnings.WarningCollector; import org.apache.iotdb.db.queryengine.plan.analyze.IAnalysis; import org.apache.iotdb.db.queryengine.plan.planner.IPlanner; import org.apache.iotdb.db.queryengine.plan.planner.plan.DistributedQueryPlan;
