You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2021/06/07 09:56:39 UTC
[iotdb] branch master updated (dc3fc32 -> f059700)
This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from dc3fc32 move pull schema methods from CMManagercode to MetaPuller (#3325)
add f059700 [IOTDB-1396] Restructure logical query operator (#3267)
No new revisions were added by this update.
Summary of changes:
.../query/ClusterPhysicalGeneratorTest.java | 20 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 2 -
.../exception/query/LogicalOptimizeException.java | 7 +-
.../main/java/org/apache/iotdb/db/qp/Planner.java | 8 +-
.../iotdb/db/qp/constant/FilterConstant.java | 95 ++++++
.../apache/iotdb/db/qp/constant/SQLConstant.java | 60 +---
.../org/apache/iotdb/db/qp/logical/Operator.java | 15 +-
.../apache/iotdb/db/qp/logical/RootOperator.java | 30 --
.../qp/logical/crud/AggregationQueryOperator.java | 55 ++++
.../db/qp/logical/crud/BasicFunctionOperator.java | 26 +-
.../db/qp/logical/crud/BasicOperatorType.java | 24 +-
.../crud/FillClauseComponent.java} | 15 +-
.../{FromOperator.java => FillQueryOperator.java} | 33 +-
.../iotdb/db/qp/logical/crud/FilterOperator.java | 81 +++--
.../crud/{FromOperator.java => FromComponent.java} | 12 +-
.../iotdb/db/qp/logical/crud/FunctionOperator.java | 7 +-
.../crud/GroupByClauseComponent.java} | 63 ++--
.../crud/GroupByFillClauseComponent.java} | 15 +-
.../qp/logical/crud/GroupByFillQueryOperator.java | 4 +-
.../db/qp/logical/crud/GroupByQueryOperator.java | 4 +-
.../iotdb/db/qp/logical/crud/InOperator.java | 16 +-
.../db/qp/logical/crud/LastQueryOperator.java | 50 +++
.../iotdb/db/qp/logical/crud/QueryOperator.java | 309 ++++---------------
.../{SelectOperator.java => SelectComponent.java} | 17 +-
.../db/qp/logical/crud/SpecialClauseComponent.java | 129 ++++++++
.../iotdb/db/qp/logical/crud/UDFQueryOperator.java | 12 +-
.../iotdb/db/qp/logical/crud/WhereComponent.java | 23 +-
.../db/qp/logical/sys/AlterTimeSeriesOperator.java | 4 +-
.../iotdb/db/qp/logical/sys/AuthorOperator.java | 4 +-
.../db/qp/logical/sys/ClearCacheOperator.java | 4 +-
.../db/qp/logical/sys/CreateFunctionOperator.java | 4 +-
.../db/qp/logical/sys/CreateSnapshotOperator.java | 4 +-
.../qp/logical/sys/CreateTimeSeriesOperator.java | 4 +-
.../db/qp/logical/sys/CreateTriggerOperator.java | 4 +-
.../iotdb/db/qp/logical/sys/DataAuthOperator.java | 4 +-
.../db/qp/logical/sys/DeletePartitionOperator.java | 4 +-
.../qp/logical/sys/DeleteStorageGroupOperator.java | 4 +-
.../qp/logical/sys/DeleteTimeSeriesOperator.java | 4 +-
.../db/qp/logical/sys/DropFunctionOperator.java | 4 +-
.../db/qp/logical/sys/DropTriggerOperator.java | 4 +-
.../iotdb/db/qp/logical/sys/FlushOperator.java | 4 +-
.../iotdb/db/qp/logical/sys/KillQueryOperator.java | 4 +-
.../qp/logical/sys/LoadConfigurationOperator.java | 4 +-
.../iotdb/db/qp/logical/sys/LoadDataOperator.java | 4 +-
.../iotdb/db/qp/logical/sys/LoadFilesOperator.java | 4 +-
.../iotdb/db/qp/logical/sys/MergeOperator.java | 4 +-
.../iotdb/db/qp/logical/sys/MoveFileOperator.java | 4 +-
.../db/qp/logical/sys/RemoveFileOperator.java | 4 +-
.../db/qp/logical/sys/SetStorageGroupOperator.java | 4 +-
.../iotdb/db/qp/logical/sys/SetTTLOperator.java | 4 +-
.../db/qp/logical/sys/ShowMergeStatusOperator.java | 4 +-
.../iotdb/db/qp/logical/sys/ShowOperator.java | 4 +-
.../db/qp/logical/sys/StartTriggerOperator.java | 4 +-
.../db/qp/logical/sys/StopTriggerOperator.java | 4 +-
.../iotdb/db/qp/logical/sys/TracingOperator.java | 4 +-
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 8 -
.../iotdb/db/qp/physical/crud/FillQueryPlan.java | 9 -
.../iotdb/db/qp/physical/crud/GroupByTimePlan.java | 2 -
.../iotdb/db/qp/physical/crud/QueryPlan.java | 3 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 336 +++++++++++++--------
.../iotdb/db/qp/strategy/LogicalChecker.java | 80 +----
.../iotdb/db/qp/strategy/LogicalGenerator.java | 41 +--
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 112 ++++---
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 38 +--
.../qp/strategy/optimizer/DnfFilterOptimizer.java | 22 +-
.../optimizer/MergeSingleFilterOptimizer.java | 4 +-
.../qp/strategy/optimizer/RemoveNotOptimizer.java | 21 +-
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 28 +-
.../iotdb/db/integration/IOTDBGroupByIT.java | 4 +-
.../iotdb/db/integration/IoTDBDisableAlignIT.java | 19 +-
.../iotdb/db/integration/IoTDBGroupByFillIT.java | 6 +-
.../aggregation/IoTDBAggregationByLevelIT.java | 4 +-
.../iotdb/db/qp/logical/IndexLogicalPlanTest.java | 14 +-
.../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 121 ++++----
74 files changed, 1064 insertions(+), 1052 deletions(-)
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/constant/FilterConstant.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/RootOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/AggregationQueryOperator.java
copy server/src/main/java/org/apache/iotdb/db/qp/{physical/crud/GroupByTimeFillPlan.java => logical/crud/FillClauseComponent.java} (74%)
copy server/src/main/java/org/apache/iotdb/db/qp/logical/crud/{FromOperator.java => FillQueryOperator.java} (57%)
rename server/src/main/java/org/apache/iotdb/db/qp/logical/crud/{FromOperator.java => FromComponent.java} (81%)
copy server/src/main/java/org/apache/iotdb/db/qp/{physical/crud/GroupByTimePlan.java => logical/crud/GroupByClauseComponent.java} (72%)
copy server/src/main/java/org/apache/iotdb/db/qp/{physical/crud/GroupByTimeFillPlan.java => logical/crud/GroupByFillClauseComponent.java} (74%)
copy cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServerMBean.java => server/src/main/java/org/apache/iotdb/db/qp/logical/crud/GroupByFillQueryOperator.java (87%)
copy cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServerMBean.java => server/src/main/java/org/apache/iotdb/db/qp/logical/crud/GroupByQueryOperator.java (87%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/LastQueryOperator.java
rename server/src/main/java/org/apache/iotdb/db/qp/logical/crud/{SelectOperator.java => SelectComponent.java} (90%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/logical/crud/SpecialClauseComponent.java
copy cluster/src/main/java/org/apache/iotdb/cluster/exception/ReaderNotFoundException.java => server/src/main/java/org/apache/iotdb/db/qp/logical/crud/UDFQueryOperator.java (78%)
copy hive-connector/src/main/java/org/apache/iotdb/hive/TsFileSerDeException.java => server/src/main/java/org/apache/iotdb/db/qp/logical/crud/WhereComponent.java (66%)