This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch TableModelGrammar0606 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c9899af78631dd6545da6837c4cc2d6858c1cb24 Merge: 344301e9008 e9583f870c9 Author: Beyyes <[email protected]> AuthorDate: Tue Jun 11 15:34:31 2024 +0800 merge .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(-) diff --cc iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/Analysis.java index a74f35526b5,9faf14e320d..1b6a6c0ff11 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/Analysis.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/Analysis.java @@@ -19,12 -19,12 +19,15 @@@ package org.apache.iotdb.db.queryengine.plan.relational.analyzer; ++import org.apache.iotdb.common.rpc.thrift.TEndPoint; import org.apache.iotdb.common.rpc.thrift.TSStatus; import org.apache.iotdb.commons.partition.DataPartition; ++import org.apache.iotdb.commons.partition.SchemaPartition; import org.apache.iotdb.db.queryengine.common.MPPQueryContext; import org.apache.iotdb.db.queryengine.common.header.DatasetHeader; import org.apache.iotdb.db.queryengine.plan.analyze.IAnalysis; import org.apache.iotdb.db.queryengine.plan.execution.memory.StatementMemorySource; ++import org.apache.iotdb.db.queryengine.plan.planner.plan.TimePredicate; import org.apache.iotdb.db.queryengine.plan.relational.metadata.QualifiedObjectName; import org.apache.iotdb.db.queryengine.plan.relational.metadata.TableSchema; import org.apache.iotdb.db.queryengine.plan.relational.security.AccessControl; @@@ -642,6 -642,6 +645,27 @@@ public class Analysis implements IAnaly return null; } ++ @Override ++ public SchemaPartition getSchemaPartitionInfo() { ++ return null; ++ } ++ ++ @Override ++ public DataPartition getDataPartitionInfo() { ++ return dataPartition; ++ } ++ ++ @Override ++ public void setRedirectNodeList(List<TEndPoint> redirectNodeList) {} ++ ++ @Override ++ public void addEndPointToRedirectNodeList(TEndPoint endPoint) {} ++ ++ @Override ++ public TimePredicate getCovertedTimePredicate() { ++ return null; ++ } ++ public static final class AccessControlInfo { private final AccessControl accessControl; private final Identity identity;
