This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch TableModelGrammar0606
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 344301e9008 fit table model write process
add 411255134b1 Add support for StreamSortOperator
add 8c5ea36e758 Merge master0607 (#12689)
add 0fc81c642e7 [Table Model] Support Table Device Management in
SchemaRegion (#12694)
add 3bea488e014 Merge branch 'ty/TableModelGrammar' of
github.com:apache/iotdb into ty/TableModelGrammar
add eea9de150eb Add FilterScanCombine optimize rule
add cfb83e59d72 change some name typo and rename relational.sql.tree
package to relational.sql.ast to avoid confusing with tree model (#12697)
new e9583f870c9 Merge branch 'ty/TableModelGrammar' of
github.com:apache/iotdb into ty/TableModelGrammar
new c9899af7863 merge
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/cluster-it-1c1d.yml | 2 +-
.github/workflows/cluster-it-1c3d.yml | 2 +-
.github/workflows/pipe-it-2cluster.yml | 2 +-
.github/workflows/sonar-codecov.yml | 2 +-
.github/workflows/unit-test.yml | 2 +-
.gitignore | 1 +
.mvn/{gradle-enterprise.xml => develocity.xml} | 15 +-
.mvn/extensions.xml | 6 +-
code-coverage/pom.xml | 2 +-
distribution/pom.xml | 10 +-
example/client-cpp-example/pom.xml | 2 +-
example/jdbc/pom.xml | 2 +-
.../java/org/apache/iotdb/JDBCCharsetExample.java | 2 +-
example/mqtt-customize/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pipe-count-point-processor/pom.xml | 2 +-
example/pipe-opc-ua-sink/pom.xml | 2 +-
example/pom.xml | 2 +-
example/rest-java-example/pom.xml | 2 +-
example/schema/pom.xml | 2 +-
example/session/pom.xml | 2 +-
example/trigger/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
integration-test/pom.xml | 32 +-
.../org/apache/iotdb/db/it/IoTDBRepairDataIT.java | 3 +-
.../db/it/orderBy/IoTDBOrderByForDebugIT.java | 1406 ++++++++++++++++++++
.../db/it/regionscan/IoTDBActiveRegionScanIT.java | 23 +-
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 31 +
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 2 +-
.../iotdb/db/it/udaf/IoTDBUDAFOrderByIT.java | 5 +-
.../it/autocreate/IoTDBPipeAutoConflictIT.java | 9 +-
.../pipe/it/autocreate/IoTDBPipeAutoDropIT.java | 62 +-
.../pipe/it/autocreate/IoTDBPipeClusterIT.java | 44 +-
.../IoTDBPipeConnectorCompressionIT.java | 126 ++
.../pipe/it/autocreate/IoTDBPipeLifeCycleIT.java | 31 +-
.../it/manual/IoTDBPipeMetaLeaderChangeIT.java | 2 +-
.../pipe/it/manual/IoTDBPipeMetaRestartIT.java | 18 +-
.../it/dual/AbstractSubscriptionDualIT.java | 13 +-
.../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 9 +
.../it/dual/IoTDBSubscriptionTimePrecisionIT.java | 195 +++
.../it/dual/IoTDBSubscriptionTopicIT.java | 2 +-
.../it/local/IoTDBSubscriptionBasicIT.java | 118 +-
.../it/local/IoTDBSubscriptionRestartIT.java | 31 +-
.../apache/iotdb/tools/it/ExportDataTestIT.java | 12 +-
.../apache/iotdb/tools/it/ImportDataTestIT.java | 16 +-
iotdb-api/external-api/pom.xml | 2 +-
iotdb-api/pipe-api/pom.xml | 2 +-
iotdb-api/pom.xml | 2 +-
iotdb-api/trigger-api/pom.xml | 2 +-
iotdb-api/udf-api/pom.xml | 2 +-
.../org/apache/iotdb/udf/api/utils/RowImpl.java | 21 +
iotdb-client/cli/pom.xml | 18 +-
.../org/apache/iotdb/tool/AbstractDataTool.java | 33 +-
.../java/org/apache/iotdb/tool/ExportData.java | 14 +-
.../java/org/apache/iotdb/tool/ImportData.java | 8 +-
.../java/org/apache/iotdb/tool/ImportSchema.java | 62 +-
iotdb-client/client-cpp/pom.xml | 4 +-
iotdb-client/client-py/pom.xml | 4 +-
iotdb-client/client-py/requirements.txt | 4 +-
iotdb-client/client-py/resources/setup.py | 7 +-
iotdb-client/isession/pom.xml | 8 +-
iotdb-client/jdbc/pom.xml | 8 +-
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 12 +-
iotdb-client/pom.xml | 2 +-
iotdb-client/service-rpc/pom.xml | 6 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 8 +-
iotdb-client/session/pom.xml | 10 +-
iotdb-core/antlr/pom.xml | 2 +-
iotdb-core/confignode/pom.xml | 24 +-
.../metric/PipeConfigRegionExtractorMetrics.java | 4 +-
.../procedure/env/RegionMaintainHandler.java | 1 +
.../subscription/topic/CreateTopicProcedure.java | 6 +-
iotdb-core/consensus/pom.xml | 14 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 34 +-
.../apache/iotdb/consensus/iot/ReplicateTest.java | 111 +-
iotdb-core/datanode/pom.xml | 38 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 3 +
.../PipeTransferTabletBatchEventHandler.java | 28 +-
.../PipeTransferTabletInsertionEventHandler.java | 22 +-
.../PipeTransferTsFileInsertionEventHandler.java | 18 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 48 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 68 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 11 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 9 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 3 -
.../subtask/connector/PipeConnectorSubtask.java | 2 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 2 +-
.../db/queryengine/common/MPPQueryContext.java | 2 +-
...SortOperator.java => AbstractSortOperator.java} | 146 +-
.../process/ActiveRegionScanMergeOperator.java | 37 +-
.../execution/operator/process/SortOperator.java | 309 +----
.../operator/process/StreamSortOperator.java | 203 +++
.../AbstractRegionScanDataSourceOperator.java | 19 +-
.../source/ActiveDeviceRegionScanOperator.java | 40 +-
.../source/ActiveTimeSeriesRegionScanOperator.java | 34 +-
.../relational/ColumnTransformerBuilder.java | 66 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 24 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 23 +-
.../queryengine/plan/analyze/PredicateUtils.java | 6 +-
.../execution/config/TableConfigTaskVisitor.java | 26 +-
.../config/executor/ClusterConfigTaskExecutor.java | 16 +-
.../config/executor/IConfigTaskExecutor.java | 8 +-
.../config/metadata/relational/CreateDBTask.java | 2 +-
.../config/metadata/relational/DropDBTask.java | 2 +-
.../config/metadata/relational/ShowDBTask.java | 2 +-
.../config/metadata/relational/UseDBTask.java | 2 +-
.../plan/optimization/LimitOffsetPushDown.java | 3 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 8 +-
.../plan/planner/OperatorTreeGenerator.java | 10 +-
.../plan/planner/TableOperatorGenerator.java | 55 +-
.../plan/planner/distribution/SourceRewriter.java | 1 +
.../plan/planner/plan/TableModelTimePredicate.java | 2 +-
.../plan/planner/plan/TimePredicate.java | 2 +-
.../planner/plan/parameter/SeriesScanOptions.java | 32 +-
.../relational/analyzer/AggregationAnalyzer.java | 66 +-
.../plan/relational/analyzer/Analysis.java | 62 +-
.../plan/relational/analyzer/Analyzer.java | 6 +-
.../relational/analyzer/CanonicalizationAware.java | 4 +-
.../relational/analyzer/ExpressionAnalysis.java | 10 +-
.../relational/analyzer/ExpressionAnalyzer.java | 90 +-
.../relational/analyzer/ExpressionTreeUtils.java | 14 +-
.../plan/relational/analyzer/Field.java | 2 +-
.../plan/relational/analyzer/NodeRef.java | 2 +-
.../plan/relational/analyzer/RelationId.java | 2 +-
.../plan/relational/analyzer/RelationType.java | 2 +-
.../plan/relational/analyzer/Scope.java | 8 +-
.../analyzer/ScopeReferenceExtractor.java | 4 +-
.../relational/analyzer/StatementAnalyzer.java | 142 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 38 +-
.../ConvertPredicateToTimeFilterVisitor.java | 32 +-
.../PredicateCombineIntoTableScanChecker.java | 28 +-
.../PredicatePushIntoMetadataChecker.java | 30 +-
.../predicate/PredicatePushIntoScanChecker.java | 30 +-
.../analyzer/predicate/PredicateVisitor.java | 28 +-
.../plan/relational/metadata/Metadata.java | 2 +-
.../plan/relational/metadata/MetadataUtil.java | 4 +-
.../relational/metadata/TableMetadataImpl.java | 2 +-
.../plan/relational/planner/Assignments.java | 2 +-
.../plan/relational/planner/LogicalPlanner.java | 6 +-
.../relational/planner/OrderingTranslator.java | 2 +-
.../plan/relational/planner/PlanBuilder.java | 4 +-
.../plan/relational/planner/PredicateUtils.java | 22 +-
.../plan/relational/planner/QueryPlanner.java | 20 +-
.../plan/relational/planner/RelationPlanner.java | 26 +-
.../relational/planner/RelationalModelPlanner.java | 2 +-
.../plan/relational/planner/ScopeAware.java | 6 +-
.../plan/relational/planner/Symbol.java | 4 +-
.../distribute/TableDistributionPlanner.java | 2 +-
.../distribute/TableModelQueryFragmentPlanner.java | 4 +-
.../TableModelTypeProviderExtractor.java | 2 +-
.../planner/ir/DefaultTraversalVisitor.java | 32 +-
.../planner/ir/DeterminismEvaluator.java | 4 +-
.../relational/planner/ir/ExpressionRewriter.java | 32 +-
.../planner/ir/ExpressionTranslateVisitor.java | 32 +-
.../planner/ir/ExpressionTreeRewriter.java | 38 +-
.../ExtractCommonPredicatesExpressionRewriter.java | 6 +-
.../ir/GlobalTimePredicateExtractVisitor.java | 44 +-
.../plan/relational/planner/ir/IrUtils.java | 8 +-
.../plan/relational/planner/ir/IrVisitor.java | 34 +-
.../planner/ir/NormalizeOrExpressionRewriter.java | 12 +-
.../relational/planner/ir/RewritingVisitor.java | 32 +-
.../plan/relational/planner/node/FilterNode.java | 2 +-
.../plan/relational/planner/node/ProjectNode.java | 2 +-
.../relational/planner/node/TableScanNode.java | 2 +-
.../planner/optimizations/FilterScanCombine.java | 8 +-
.../planner/optimizations/IndexScan.java | 2 +-
.../planner/optimizations/PruneUnUsedColumns.java | 6 +-
.../planner/optimizations/SimplifyExpressions.java | 2 +-
.../relational/sql/{tree => ast}/AddColumn.java | 2 +-
.../sql/{tree => ast}/AliasedRelation.java | 2 +-
.../relational/sql/{tree => ast}/AllColumns.java | 2 +-
.../plan/relational/sql/{tree => ast}/AllRows.java | 2 +-
.../{tree => ast}/ArithmeticBinaryExpression.java | 2 +-
.../{tree => ast}/ArithmeticUnaryExpression.java | 2 +-
.../relational/sql/{tree => ast}/AstVisitor.java | 2 +-
.../sql/{tree => ast}/BetweenPredicate.java | 2 +-
.../sql/{tree => ast}/BinaryLiteral.java | 2 +-
.../sql/{tree => ast}/BooleanLiteral.java | 2 +-
.../plan/relational/sql/{tree => ast}/Cast.java | 2 +-
.../sql/{tree => ast}/CoalesceExpression.java | 2 +-
.../sql/{tree => ast}/ColumnDefinition.java | 2 +-
.../sql/{tree => ast}/ComparisonExpression.java | 2 +-
.../relational/sql/{tree => ast}/CreateDB.java | 2 +-
.../sql/{tree => ast}/CreateFunction.java | 2 +-
.../relational/sql/{tree => ast}/CreateIndex.java | 2 +-
.../relational/sql/{tree => ast}/CreateTable.java | 2 +-
.../sql/{tree => ast}/CurrentDatabase.java | 2 +-
.../relational/sql/{tree => ast}/CurrentTime.java | 2 +-
.../relational/sql/{tree => ast}/CurrentUser.java | 2 +-
.../relational/sql/{tree => ast}/DataType.java | 2 +-
.../sql/{tree => ast}/DataTypeParameter.java | 2 +-
.../sql/{tree => ast}/DecimalLiteral.java | 2 +-
.../DefaultExpressionTraversalVisitor.java | 2 +-
.../sql/{tree => ast}/DefaultTraversalVisitor.java | 2 +-
.../plan/relational/sql/{tree => ast}/Delete.java | 2 +-
.../sql/{tree => ast}/DereferenceExpression.java | 2 +-
.../sql/{tree => ast}/DescribeTable.java | 2 +-
.../sql/{tree => ast}/DoubleLiteral.java | 2 +-
.../relational/sql/{tree => ast}/DropColumn.java | 2 +-
.../plan/relational/sql/{tree => ast}/DropDB.java | 2 +-
.../relational/sql/{tree => ast}/DropFunction.java | 2 +-
.../relational/sql/{tree => ast}/DropIndex.java | 2 +-
.../relational/sql/{tree => ast}/DropTable.java | 2 +-
.../plan/relational/sql/{tree => ast}/Except.java | 2 +-
.../sql/{tree => ast}/ExistsPredicate.java | 2 +-
.../plan/relational/sql/{tree => ast}/Explain.java | 2 +-
.../sql/{tree => ast}/ExplainAnalyze.java | 2 +-
.../relational/sql/{tree => ast}/Expression.java | 2 +-
.../sql/{tree => ast}/FieldReference.java | 2 +-
.../relational/sql/{tree => ast}/FunctionCall.java | 2 +-
.../sql/{tree => ast}/GenericDataType.java | 2 +-
.../sql/{tree => ast}/GenericLiteral.java | 2 +-
.../plan/relational/sql/{tree => ast}/GroupBy.java | 2 +-
.../sql/{tree => ast}/GroupingElement.java | 2 +-
.../relational/sql/{tree => ast}/GroupingSets.java | 2 +-
.../relational/sql/{tree => ast}/Identifier.java | 2 +-
.../relational/sql/{tree => ast}/IfExpression.java | 2 +-
.../sql/{tree => ast}/InListExpression.java | 2 +-
.../relational/sql/{tree => ast}/InPredicate.java | 2 +-
.../plan/relational/sql/{tree => ast}/Insert.java | 2 +-
.../relational/sql/{tree => ast}/Intersect.java | 2 +-
.../sql/{tree => ast}/IsNotNullPredicate.java | 2 +-
.../sql/{tree => ast}/IsNullPredicate.java | 2 +-
.../plan/relational/sql/{tree => ast}/Join.java | 2 +-
.../relational/sql/{tree => ast}/JoinCriteria.java | 2 +-
.../plan/relational/sql/{tree => ast}/JoinOn.java | 2 +-
.../relational/sql/{tree => ast}/JoinUsing.java | 2 +-
.../sql/{tree => ast}/LikePredicate.java | 2 +-
.../plan/relational/sql/{tree => ast}/Limit.java | 2 +-
.../plan/relational/sql/{tree => ast}/Literal.java | 2 +-
.../sql/{tree => ast}/LogicalExpression.java | 2 +-
.../relational/sql/{tree => ast}/LongLiteral.java | 2 +-
.../relational/sql/{tree => ast}/NaturalJoin.java | 2 +-
.../plan/relational/sql/{tree => ast}/Node.java | 2 +-
.../relational/sql/{tree => ast}/NodeLocation.java | 2 +-
.../sql/{tree => ast}/NotExpression.java | 2 +-
.../sql/{tree => ast}/NullIfExpression.java | 2 +-
.../relational/sql/{tree => ast}/NullLiteral.java | 2 +-
.../sql/{tree => ast}/NumericParameter.java | 2 +-
.../plan/relational/sql/{tree => ast}/Offset.java | 2 +-
.../plan/relational/sql/{tree => ast}/OrderBy.java | 2 +-
.../relational/sql/{tree => ast}/Parameter.java | 2 +-
.../relational/sql/{tree => ast}/Property.java | 2 +-
.../sql/{tree => ast}/QualifiedName.java | 2 +-
.../QuantifiedComparisonExpression.java | 2 +-
.../plan/relational/sql/{tree => ast}/Query.java | 2 +-
.../relational/sql/{tree => ast}/QueryBody.java | 2 +-
.../sql/{tree => ast}/QuerySpecification.java | 2 +-
.../relational/sql/{tree => ast}/Relation.java | 2 +-
.../relational/sql/{tree => ast}/RenameColumn.java | 2 +-
.../relational/sql/{tree => ast}/RenameTable.java | 2 +-
.../plan/relational/sql/{tree => ast}/Row.java | 2 +-
.../sql/{tree => ast}/SearchedCaseExpression.java | 2 +-
.../plan/relational/sql/{tree => ast}/Select.java | 2 +-
.../relational/sql/{tree => ast}/SelectItem.java | 2 +-
.../relational/sql/{tree => ast}/SetOperation.java | 2 +-
.../sql/{tree => ast}/SetProperties.java | 2 +-
.../plan/relational/sql/{tree => ast}/ShowDB.java | 2 +-
.../sql/{tree => ast}/ShowFunctions.java | 2 +-
.../relational/sql/{tree => ast}/ShowIndex.java | 2 +-
.../relational/sql/{tree => ast}/ShowTables.java | 2 +-
.../sql/{tree => ast}/SimpleCaseExpression.java | 2 +-
.../sql/{tree => ast}/SimpleGroupBy.java | 2 +-
.../relational/sql/{tree => ast}/SingleColumn.java | 2 +-
.../relational/sql/{tree => ast}/SortItem.java | 2 +-
.../sql/{tree => ast}/StackableAstVisitor.java | 2 +-
.../relational/sql/{tree => ast}/Statement.java | 2 +-
.../sql/{tree => ast}/StringLiteral.java | 2 +-
.../sql/{tree => ast}/SubqueryExpression.java | 2 +-
.../sql/{tree => ast}/SymbolReference.java | 2 +-
.../plan/relational/sql/{tree => ast}/Table.java | 2 +-
.../sql/{tree => ast}/TableExpressionType.java | 2 +-
.../sql/{tree => ast}/TableSubquery.java | 2 +-
.../plan/relational/sql/{tree => ast}/Trim.java | 2 +-
.../sql/{tree => ast}/TypeParameter.java | 2 +-
.../plan/relational/sql/{tree => ast}/Union.java | 2 +-
.../plan/relational/sql/{tree => ast}/Update.java | 2 +-
.../sql/{tree => ast}/UpdateAssignment.java | 2 +-
.../plan/relational/sql/{tree => ast}/Use.java | 2 +-
.../plan/relational/sql/{tree => ast}/Values.java | 2 +-
.../relational/sql/{tree => ast}/WhenClause.java | 2 +-
.../plan/relational/sql/{tree => ast}/With.java | 2 +-
.../relational/sql/{tree => ast}/WithQuery.java | 2 +-
.../plan/relational/sql/parser/AstBuilder.java | 202 +--
.../relational/sql/parser/ParsingException.java | 2 +-
.../plan/relational/sql/parser/SqlParser.java | 10 +-
.../plan/relational/sql/util/AstUtil.java | 2 +-
.../relational/sql/util/ExpressionFormatter.java | 110 +-
.../plan/relational/sql/util/QueryUtil.java | 52 +-
.../relational/sql/util/ReservedIdentifiers.java | 2 +-
.../plan/relational/sql/util/SqlFormatter.java | 102 +-
.../relational/type/TypeSignatureTranslator.java | 12 +-
.../plan/relational/utils/NodeUtils.java | 4 +-
.../plan/scheduler/AsyncPlanNodeSender.java | 6 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 52 +-
.../dag/column/unary/InColumnTransformer.java | 10 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 20 +
.../attribute/DeviceAttributeStore.java | 177 +++
.../attribute/IDeviceAttributeStore.java} | 22 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 63 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 27 +
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 215 ++-
.../mtree/impl/mem/mnode/basic/BasicMNode.java | 3 +-
.../container/KeyNullableConcurrentHashMap.java | 175 +++
.../mem/mnode/container/MemMNodeContainer.java | 3 +-
.../mtree/impl/mem/mnode/info/BasicMNodeInfo.java | 2 +-
.../mtree/impl/mem/mnode/info/TableDeviceInfo.java | 119 ++
.../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 36 +-
.../read/req/impl/ShowTableDevicesPlan.java | 60 +
.../read/resp/info/IDeviceSchemaInfo.java | 4 +
.../read/resp/info/impl/ShowDevicesResult.java | 31 +
.../utils/filter/DeviceFilterVisitor.java | 19 +
.../execute/recover/CompactionRecoverManager.java | 2 +-
.../dataregion/tsfile/TsFileResource.java | 22 +-
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 16 +
.../dataregion/tsfile/timeindex/FileTimeIndex.java | 5 +
.../receiver/SubscriptionReceiverV1.java | 11 +-
.../apache/iotdb/db/utils/sort/DiskSpiller.java | 17 +-
.../iotdb/db/utils/sort/SortBufferManager.java | 33 +-
.../schemaRegion/SchemaRegionTableDeviceTest.java | 328 +++++
.../schemaRegion/SchemaRegionTestUtil.java | 67 +
.../execution/operator/SortOperatorTest.java | 47 +-
.../operator/process/StreamSortOperatorTest.java | 591 ++++++++
.../plan/optimization/LimitOffsetPushDownTest.java | 28 +
.../plan/relational/analyzer/AnalyzerTest.java | 4 +-
.../plan/relational/analyzer/TestMatadata.java | 2 +-
.../relational/planner/PredicateUtilsTest.java | 2 +-
.../apache/iotdb/db/utils/sort/SortUtilTest.java | 6 +-
iotdb-core/metrics/core/pom.xml | 4 +-
iotdb-core/metrics/interface/pom.xml | 8 +-
iotdb-core/metrics/pom.xml | 2 +-
iotdb-core/node-commons/pom.xml | 26 +-
.../resources/conf/iotdb-system.properties | 18 +
.../apache/iotdb/commons/conf/CommonConfig.java | 20 +
.../iotdb/commons/conf/CommonDescriptor.java | 16 +
.../org/apache/iotdb/commons/path/PartialPath.java | 5 +-
.../apache/iotdb/commons/path/PathPatternUtil.java | 3 +-
.../iotdb/commons/path/fa/nfa/SimpleNFA.java | 5 +-
.../config/constant/PipeConnectorConstant.java | 10 +
.../compressor/PipeCompressorConfig.java} | 23 +-
.../compressor/PipeCompressorFactory.java | 62 +-
.../connector/compressor/PipeZSTDCompressor.java | 17 +-
.../pipe/connector/protocol/IoTDBConnector.java | 25 +-
.../apache/iotdb/commons/schema/MemUsageUtil.java | 61 +
.../iotdb/commons/schema/SchemaConstant.java | 5 +
.../iotdb/commons/schema/filter/SchemaFilter.java | 9 +
.../commons/schema/filter/SchemaFilterType.java | 10 +
.../commons/schema/filter/SchemaFilterVisitor.java | 15 +
.../schema/filter/impl/DeviceAttributeFilter.java | 76 ++
.../schema/filter/impl/DeviceFilterUtil.java | 68 +
.../commons/schema/filter/impl/DeviceIdFilter.java | 79 ++
.../iotdb/commons/schema/filter/impl/OrFilter.java | 74 ++
.../commons/schema/tree/AbstractTreeVisitor.java | 4 +-
.../service/metric/PerformanceOverviewMetrics.java | 21 +
.../commons/subscription/meta/topic/TopicMeta.java | 2 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 22 +-
iotdb-core/pom.xml | 2 +-
iotdb-core/relational-grammar/pom.xml | 2 +-
iotdb-protocol/openapi/pom.xml | 2 +-
iotdb-protocol/pom.xml | 2 +-
iotdb-protocol/thrift-commons/pom.xml | 2 +-
iotdb-protocol/thrift-confignode/pom.xml | 4 +-
iotdb-protocol/thrift-consensus/pom.xml | 4 +-
iotdb-protocol/thrift-datanode/pom.xml | 4 +-
library-udf/pom.xml | 4 +-
pom.xml | 2 +-
366 files changed, 6677 insertions(+), 2029 deletions(-)
rename .mvn/{gradle-enterprise.xml => develocity.xml} (69%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/orderBy/IoTDBOrderByForDebugIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/IoTDBSubscriptionTimePrecisionIT.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/{relational/StreamSortOperator.java
=> AbstractSortOperator.java} (77%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/StreamSortOperator.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/AddColumn.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/AliasedRelation.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/AllColumns.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/AllRows.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/ArithmeticBinaryExpression.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/ArithmeticUnaryExpression.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/AstVisitor.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/BetweenPredicate.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/BinaryLiteral.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/BooleanLiteral.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Cast.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/CoalesceExpression.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/ColumnDefinition.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/ComparisonExpression.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/CreateDB.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/CreateFunction.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/CreateIndex.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/CreateTable.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/CurrentDatabase.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/CurrentTime.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/CurrentUser.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/DataType.java (93%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/DataTypeParameter.java (94%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/DecimalLiteral.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/DefaultExpressionTraversalVisitor.java (94%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/DefaultTraversalVisitor.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Delete.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/DereferenceExpression.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/DescribeTable.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/DoubleLiteral.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/DropColumn.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/DropDB.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/DropFunction.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/DropIndex.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/DropTable.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Except.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/ExistsPredicate.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Explain.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/ExplainAnalyze.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Expression.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/FieldReference.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/FunctionCall.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/GenericDataType.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/GenericLiteral.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/GroupBy.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/GroupingElement.java (94%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/GroupingSets.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Identifier.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/IfExpression.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/InListExpression.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/InPredicate.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Insert.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Intersect.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/IsNotNullPredicate.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/IsNullPredicate.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Join.java (98%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/JoinCriteria.java (94%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/JoinOn.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/JoinUsing.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/LikePredicate.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Limit.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Literal.java (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/LogicalExpression.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/LongLiteral.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/NaturalJoin.java (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Node.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/NodeLocation.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/NotExpression.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/NullIfExpression.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/NullLiteral.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/NumericParameter.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Offset.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/OrderBy.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Parameter.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Property.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/QualifiedName.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/QuantifiedComparisonExpression.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Query.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/QueryBody.java (94%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/QuerySpecification.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Relation.java (94%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/RenameColumn.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/RenameTable.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Row.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/SearchedCaseExpression.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Select.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/SelectItem.java (93%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/SetOperation.java (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/SetProperties.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/ShowDB.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/ShowFunctions.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/ShowIndex.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/ShowTables.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/SimpleCaseExpression.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/SimpleGroupBy.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/SingleColumn.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/SortItem.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/StackableAstVisitor.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Statement.java (94%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/StringLiteral.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/SubqueryExpression.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/SymbolReference.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Table.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/TableExpressionType.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/TableSubquery.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Trim.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/TypeParameter.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Union.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Update.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/UpdateAssignment.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Use.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/Values.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/WhenClause.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/With.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/{tree
=> ast}/WithQuery.java (98%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/attribute/DeviceAttributeStore.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/relational/sql/tree/JoinCriteria.java
=> schemaengine/schemaregion/attribute/IDeviceAttributeStore.java} (62%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/mem/mnode/container/KeyNullableConcurrentHashMap.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/mem/mnode/info/TableDeviceInfo.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/read/req/impl/ShowTableDevicesPlan.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/SchemaRegionTableDeviceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/process/StreamSortOperatorTest.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/mem/mnode/info/BasicMNodeInfo.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/compressor/PipeCompressorConfig.java}
(65%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/MemUsageUtil.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/DeviceAttributeFilter.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/DeviceFilterUtil.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/DeviceIdFilter.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/filter/impl/OrFilter.java
