This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch client-opc
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 32c0a61ec36 fix
add 52002e86d2d [AINode] Append model management IT (#16938)
add e9c614eb3ae Add independent ttl check for object file (#16929)
add 609bc289c09 Pipe: Fixed the hardlink bug of plugin meta (#16937)
add 19a4bef273d Support objectLength in Record interface of udf-api
(#16946)
add 9b3bdc40f50 Pipe: Implemented tree auth check for source +
write-back-sink (#16531)
add 8a5e1e3707f feat: add AstMemoryEstimator for SQL AST memory estimation
(#16882)
add 5203eb48a99 Merge branch 'master' of https://github.com/apache/iotdb
into client-opc
add 4861ca3c2a4 compile-fix
No new revisions were added by this update.
Summary of changes:
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 2 +-
.../iotdb/ainode/it/AINodeCallInferenceIT.java | 24 +-
.../apache/iotdb/ainode/it/AINodeForecastIT.java | 16 +-
.../iotdb/ainode/it/AINodeModelManageIT.java | 58 +-
.../apache/iotdb/ainode/utils/AINodeTestUtils.java | 44 +
.../org/apache/iotdb/db/it/utils/TestUtils.java | 30 +-
.../manual/basic/IoTDBPipeLifeCycleIT.java | 230 +++---
.../manual/basic/IoTDBPipePermissionIT.java | 4 +-
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 36 +-
.../treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 137 ++--
.../treemodel/auto/basic/IoTDBPipeLifeCycleIT.java | 207 ++---
.../treemodel/auto/basic/IoTDBPipeProcessorIT.java | 19 +-
.../treemodel/auto/basic/IoTDBPipeProtocolIT.java | 87 +-
.../auto/basic/IoTDBPipeSinkParallelIT.java | 20 +-
.../treemodel/auto/basic/IoTDBPipeSourceIT.java | 460 +++++------
.../auto/basic/IoTDBPipeSwitchStatusIT.java | 88 +-
.../treemodel/auto/basic/IoTDBPipeSyntaxIT.java | 376 ++++-----
.../auto/basic/IoTDBTreePatternFormatIT.java | 203 ++---
.../auto/enhanced/IoTDBPipeAutoConflictIT.java | 126 +--
.../auto/enhanced/IoTDBPipeAutoDropIT.java | 42 +-
.../auto/enhanced/IoTDBPipeClusterIT.java | 277 ++++---
.../auto/enhanced/IoTDBPipeIdempotentIT.java | 30 +-
.../auto/enhanced/IoTDBPipeNullValueIT.java | 22 +-
.../auto/enhanced/IoTDBPipeSinkCompressionIT.java | 103 +--
.../auto/enhanced/IoTDBPipeWithLoadIT.java | 17 +-
.../treemodel/auto/enhanced/PipeNowFunctionIT.java | 153 ++--
.../treemodel/manual/IoTDBPipeInclusionIT.java | 67 +-
.../manual/IoTDBPipeManualConflictIT.java | 102 +--
.../manual/IoTDBPipeMetaHistoricalIT.java | 67 +-
.../manual/IoTDBPipeMetaLeaderChangeIT.java | 52 +-
.../treemodel/manual/IoTDBPipeMetaRestartIT.java | 52 +-
.../manual/IoTDBPipeMultiSchemaRegionIT.java | 26 +-
.../treemodel/manual/IoTDBPipePermissionIT.java | 201 +++++
.../iotdb/pipe/it/single/IoTDBPipeAggregateIT.java | 14 +-
.../pipe/it/single/IoTDBPipePermissionIT.java | 3 +-
.../iotdb/pipe/it/triple/IoTDBPipeForwardIT.java | 2 +
.../IoTDBSubscriptionConsumerGroupIT.java | 68 +-
.../iotdb/udf/api/relational/access/Record.java | 8 +
.../iotdb/ainode/core/manager/model_manager.py | 6 +-
.../ainode/iotdb/ainode/core/model/model_info.py | 12 +-
.../iotdb/ainode/core/model/model_storage.py | 80 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 38 +-
.../pipe/payload/PipeDeactivateTemplatePlan.java | 2 +-
.../write/template/CreateSchemaTemplatePlan.java | 2 +-
.../response/template/TemplateInfoResp.java | 2 +-
.../response/template/TemplateSetInfoResp.java | 2 +-
.../iotdb/confignode/manager/ConfigManager.java | 10 +-
.../confignode/manager/PermissionManager.java | 7 +
.../iotdb/confignode/manager/ProcedureManager.java | 2 +-
.../pipe/agent/task/PipeConfigNodeTaskStage.java | 8 +-
.../pipe/source/IoTDBConfigRegionSource.java | 71 +-
...ava => PipeConfigTablePatternParseVisitor.java} | 2 +-
...a => PipeConfigTablePrivilegeParseVisitor.java} | 2 +-
....java => PipeConfigTableScopeParseVisitor.java} | 2 +-
...java => PipeConfigTreePatternParseVisitor.java} | 8 +-
.../PipeConfigTreePrivilegeParseVisitor.java | 395 +++++++++
...r.java => PipeConfigTreeScopeParseVisitor.java} | 2 +-
.../manager/schema/ClusterSchemaManager.java | 2 +-
.../confignode/persistence/auth/AuthorInfo.java | 7 +
.../persistence/auth/AuthorPlanExecutor.java | 20 +
.../persistence/auth/IAuthorPlanExecutor.java | 5 +
.../persistence/pipe/PipePluginInfo.java | 33 +-
.../schema/CNPhysicalPlanGenerator.java | 2 +-
.../persistence/schema/ClusterSchemaInfo.java | 2 +-
.../persistence/schema/ConfigMTreeStore.java | 2 +-
.../persistence/schema/TemplateTable.java | 2 +-
.../impl/schema/DeactivateTemplateProcedure.java | 2 +-
.../procedure/impl/schema/SchemaUtils.java | 2 +-
.../impl/schema/SetTemplateProcedure.java | 2 +-
.../impl/schema/UnsetTemplateProcedure.java | 2 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 2 +-
...t.java => PipeConfigScopeParseVisitorTest.java} | 2 +-
...=> PipeConfigTablePatternParseVisitorTest.java} | 2 +-
... => PipeConfigTreePatternParseVisitorTest.java} | 4 +-
.../PipeConfigTreePrivilegeParseVisitorTest.java | 259 ++++++
.../persistence/CNPhysicalPlanGeneratorTest.java | 2 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 16 +-
.../persistence/schema/ClusterSchemaInfoTest.java | 2 +-
.../persistence/schema/TemplateTableTest.java | 2 +-
.../pipe/receiver/PipeEnrichedProcedureTest.java | 2 +-
.../schema/DeactivateTemplateProcedureTest.java | 2 +-
.../impl/schema/UnsetTemplateProcedureTest.java | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 2 +-
.../schemaregion/SchemaExecutionVisitor.java | 2 +-
.../agent/task/connection/PipeEventCollector.java | 22 +-
.../db/pipe/event/common/PipeInsertionEvent.java | 1 +
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 81 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 27 +-
.../tablet/parser/TabletInsertionEventParser.java | 3 +-
.../TabletInsertionEventTablePatternParser.java | 4 +-
.../TabletInsertionEventTreePatternParser.java | 39 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 124 ++-
.../tsfile/parser/TsFileInsertionEventParser.java | 8 +-
.../parser/TsFileInsertionEventParserProvider.java | 26 +-
.../query/TsFileInsertionEventQueryParser.java | 48 +-
.../scan/TsFileInsertionEventScanParser.java | 60 +-
.../table/TsFileInsertionEventTableParser.java | 38 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 3 +-
...leStatementDataTypeConvertExecutionVisitor.java | 2 +-
.../batch/PipeTabletEventTsFileBatch.java | 6 +-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 7 +-
.../thrift/sync/IoTDBSchemaRegionSink.java | 4 +-
.../sink/protocol/writeback/WriteBackSink.java | 68 +-
.../matcher/CachedSchemaPatternMatcher.java | 8 +-
.../schemaregion/IoTDBSchemaRegionSource.java | 80 +-
.../PipePlanTreePrivilegeParseVisitor.java | 355 ++++++++
...r.java => PipeTableStatementToPlanVisitor.java} | 2 +-
.../PipeTreeStatementToPlanVisitor.java | 60 ++
.../common/schematree/ClusterSchemaTree.java | 2 +-
.../queryengine/common/schematree/ISchemaTree.java | 2 +-
.../schematree/visitor/SchemaTreeVisitor.java | 2 +-
.../SchemaTreeVisitorWithLimitOffsetWrapper.java | 2 +-
.../execution/executor/RegionWriteExecutor.java | 2 +-
.../operator/process/function/partition/Slice.java | 9 +
.../operator/schema/SchemaFetchScanOperator.java | 2 +-
.../schema/source/SchemaSourceFactory.java | 2 +-
.../schema/source/TimeSeriesSchemaSource.java | 2 +-
.../relational/aggregation/RecordIterator.java | 9 +
.../db/queryengine/plan/analyze/Analysis.java | 2 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 2 +-
.../plan/analyze/TemplatedAggregationAnalyze.java | 2 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 2 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 2 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 2 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 2 +-
.../plan/analyze/schema/ISchemaFetcher.java | 2 +-
.../plan/analyze/schema/TemplateSchemaFetcher.java | 2 +-
.../execution/config/TableConfigTaskVisitor.java | 47 +-
.../execution/config/TreeConfigTaskVisitor.java | 31 +-
.../config/executor/ClusterConfigTaskExecutor.java | 57 +-
.../template/ShowNodesInSchemaTemplateTask.java | 2 +-
.../metadata/template/ShowSchemaTemplateTask.java | 2 +-
.../plan/execution/config/session/PrepareTask.java | 3 +-
.../execution/config/sys/pipe/AlterPipeTask.java | 10 +-
.../execution/config/sys/pipe/CreatePipeTask.java | 8 +-
.../execution/config/sys/pipe/ShowPipeTask.java | 5 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 87 +-
.../plan/planner/LogicalPlanBuilder.java | 2 +-
.../plan/planner/LogicalPlanVisitor.java | 2 +-
.../metadata/read/LevelTimeSeriesCountNode.java | 2 +-
.../metadata/read/SeriesSchemaFetchScanNode.java | 2 +-
.../node/metadata/read/TimeSeriesCountNode.java | 2 +-
.../metadata/read/TimeSeriesSchemaScanNode.java | 2 +-
.../metadata/cache/DeviceSchemaRequestCache.java | 8 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 4 +-
.../cache/TreeDeviceSchemaCacheManager.java | 2 +-
.../plan/relational/security/AccessControl.java | 10 +
.../relational/security/AccessControlImpl.java | 13 +
.../relational/security/AllowAllAccessControl.java | 17 +
.../security/TreeAccessCheckVisitor.java | 42 +
.../plan/relational/sql/AstMemoryEstimator.java | 67 --
.../sql/ast/AbstractQueryDeviceWithCache.java | 21 +
.../relational/sql/ast/AbstractTraverseDevice.java | 48 ++
.../plan/relational/sql/ast/AddColumn.java | 13 +
.../plan/relational/sql/ast/AliasedRelation.java | 14 +
.../plan/relational/sql/ast/AllColumns.java | 13 +
.../plan/relational/sql/ast/AllRows.java | 9 +
.../plan/relational/sql/ast/AlterDB.java | 9 +
.../plan/relational/sql/ast/AlterPipe.java | 15 +
.../plan/relational/sql/ast/AnchorPattern.java | 11 +
.../sql/ast/ArithmeticBinaryExpression.java | 12 +
.../sql/ast/ArithmeticUnaryExpression.java | 11 +
.../plan/relational/sql/ast/AsofJoinOn.java | 11 +
.../sql/ast/AstMemoryEstimationHelper.java | 123 +++
.../plan/relational/sql/ast/BetweenPredicate.java | 13 +
.../plan/relational/sql/ast/BinaryLiteral.java | 11 +
.../plan/relational/sql/ast/BooleanLiteral.java | 10 +
.../queryengine/plan/relational/sql/ast/Cast.java | 12 +
.../plan/relational/sql/ast/ClearCache.java | 11 +
.../relational/sql/ast/CoalesceExpression.java | 11 +
.../plan/relational/sql/ast/ColumnDefinition.java | 15 +
.../plan/relational/sql/ast/Columns.java | 11 +
.../relational/sql/ast/ComparisonExpression.java | 12 +
.../plan/relational/sql/ast/CountDevice.java | 8 +
.../plan/relational/sql/ast/CountStatement.java | 13 +
.../plan/relational/sql/ast/CreateDB.java | 9 +
.../plan/relational/sql/ast/CreateFunction.java | 13 +
.../plan/relational/sql/ast/CreateIndex.java | 13 +
.../plan/relational/sql/ast/CreateModel.java | 13 +
.../relational/sql/ast/CreateOrUpdateDevice.java | 16 +
.../plan/relational/sql/ast/CreatePipe.java | 52 +-
.../plan/relational/sql/ast/CreatePipePlugin.java | 14 +
.../plan/relational/sql/ast/CreateTable.java | 26 +
.../plan/relational/sql/ast/CreateTopic.java | 13 +
.../plan/relational/sql/ast/CreateTraining.java | 15 +
.../plan/relational/sql/ast/CreateView.java | 14 +
.../plan/relational/sql/ast/CurrentDatabase.java | 11 +
.../plan/relational/sql/ast/CurrentTime.java | 14 +
.../plan/relational/sql/ast/CurrentUser.java | 11 +
.../plan/relational/sql/ast/DatabaseStatement.java | 9 +
.../plan/relational/sql/ast/Deallocate.java | 12 +
.../plan/relational/sql/ast/DecimalLiteral.java | 11 +
.../plan/relational/sql/ast/Delete.java | 12 +
.../plan/relational/sql/ast/DeleteDevice.java | 16 +
.../relational/sql/ast/DereferenceExpression.java | 13 +
.../plan/relational/sql/ast/DescribeTable.java | 11 +
.../plan/relational/sql/ast/DoubleLiteral.java | 10 +
.../plan/relational/sql/ast/DropColumn.java | 12 +
.../plan/relational/sql/ast/DropDB.java | 11 +
.../plan/relational/sql/ast/DropFunction.java | 11 +
.../plan/relational/sql/ast/DropIndex.java | 12 +
.../plan/relational/sql/ast/DropModel.java | 12 +
.../plan/relational/sql/ast/DropPipe.java | 11 +
.../plan/relational/sql/ast/DropPipePlugin.java | 12 +
.../plan/relational/sql/ast/DropSubscription.java | 12 +
.../plan/relational/sql/ast/DropTable.java | 12 +
.../plan/relational/sql/ast/DropTopic.java | 12 +
.../plan/relational/sql/ast/EmptyPattern.java | 11 +
.../plan/relational/sql/ast/Except.java | 12 +
.../plan/relational/sql/ast/ExcludedPattern.java | 12 +
.../plan/relational/sql/ast/Execute.java | 12 +
.../plan/relational/sql/ast/ExecuteImmediate.java | 13 +
.../plan/relational/sql/ast/ExistsPredicate.java | 12 +
.../plan/relational/sql/ast/Explain.java | 11 +
.../plan/relational/sql/ast/ExplainAnalyze.java | 12 +
.../plan/relational/sql/ast/ExtendRegion.java | 11 +
.../plan/relational/sql/ast/Extract.java | 11 +
.../plan/relational/sql/ast/FetchDevice.java | 19 +
.../plan/relational/sql/ast/FieldReference.java | 11 +
.../queryengine/plan/relational/sql/ast/Fill.java | 16 +
.../plan/relational/sql/ast/FrameBound.java | 13 +
.../plan/relational/sql/ast/FunctionCall.java | 23 +
.../plan/relational/sql/ast/GenericDataType.java | 12 +
.../plan/relational/sql/ast/GenericLiteral.java | 12 +
.../plan/relational/sql/ast/GroupBy.java | 11 +
.../plan/relational/sql/ast/GroupingSets.java | 14 +
.../plan/relational/sql/ast/Identifier.java | 11 +
.../plan/relational/sql/ast/IfExpression.java | 14 +
.../plan/relational/sql/ast/InListExpression.java | 12 +
.../plan/relational/sql/ast/InPredicate.java | 12 +
.../plan/relational/sql/ast/Insert.java | 13 +
.../plan/relational/sql/ast/Intersect.java | 12 +
.../relational/sql/ast/IsNotNullPredicate.java | 11 +
.../plan/relational/sql/ast/IsNullPredicate.java | 11 +
.../queryengine/plan/relational/sql/ast/Join.java | 13 +
.../plan/relational/sql/ast/JoinCriteria.java | 4 +-
.../plan/relational/sql/ast/JoinOn.java | 13 +
.../plan/relational/sql/ast/JoinUsing.java | 11 +
.../plan/relational/sql/ast/KillQuery.java | 12 +
.../plan/relational/sql/ast/LikePredicate.java | 13 +
.../queryengine/plan/relational/sql/ast/Limit.java | 11 +
.../plan/relational/sql/ast/LoadModel.java | 14 +
.../plan/relational/sql/ast/LoadTsFile.java | 36 +
.../plan/relational/sql/ast/LogicalExpression.java | 11 +
.../plan/relational/sql/ast/LongLiteral.java | 11 +
.../plan/relational/sql/ast/MeasureDefinition.java | 13 +
.../plan/relational/sql/ast/MigrateRegion.java | 10 +
.../plan/relational/sql/ast/NaturalJoin.java | 9 +
.../queryengine/plan/relational/sql/ast/Node.java | 9 +-
.../plan/relational/sql/ast/NotExpression.java | 11 +
.../plan/relational/sql/ast/NullIfExpression.java | 13 +
.../plan/relational/sql/ast/NullLiteral.java | 11 +
.../plan/relational/sql/ast/NumericParameter.java | 11 +
.../plan/relational/sql/ast/Offset.java | 11 +
.../relational/sql/ast/OneOrMoreQuantifier.java | 12 +
.../plan/relational/sql/ast/OrderBy.java | 11 +
.../plan/relational/sql/ast/Parameter.java | 11 +
.../relational/sql/ast/PatternAlternation.java | 12 +
.../relational/sql/ast/PatternConcatenation.java | 12 +
.../relational/sql/ast/PatternPermutation.java | 12 +
.../sql/ast/PatternRecognitionRelation.java | 22 +
.../plan/relational/sql/ast/PatternVariable.java | 12 +
.../plan/relational/sql/ast/PipeEnriched.java | 13 +
.../plan/relational/sql/ast/Prepare.java | 12 +
.../plan/relational/sql/ast/ProcessingMode.java | 11 +
.../plan/relational/sql/ast/Property.java | 12 +
.../plan/relational/sql/ast/QualifiedName.java | 20 +-
.../sql/ast/QuantifiedComparisonExpression.java | 13 +
.../plan/relational/sql/ast/QuantifiedPattern.java | 13 +
.../queryengine/plan/relational/sql/ast/Query.java | 17 +
.../relational/sql/ast/QuerySpecification.java | 22 +
.../plan/relational/sql/ast/RangeQuantifier.java | 14 +
.../plan/relational/sql/ast/ReconstructRegion.java | 11 +
.../sql/ast/RelationalAuthorStatement.java | 19 +
.../plan/relational/sql/ast/RemoveAINode.java | 10 +
.../plan/relational/sql/ast/RemoveConfigNode.java | 10 +
.../plan/relational/sql/ast/RemoveDataNode.java | 11 +
.../plan/relational/sql/ast/RemoveRegion.java | 11 +
.../plan/relational/sql/ast/RenameColumn.java | 14 +
.../plan/relational/sql/ast/RenameTable.java | 13 +
.../queryengine/plan/relational/sql/ast/Row.java | 11 +
.../relational/sql/ast/SearchedCaseExpression.java | 13 +
.../plan/relational/sql/ast/Select.java | 10 +
.../plan/relational/sql/ast/SetColumnComment.java | 13 +
.../plan/relational/sql/ast/SetProperties.java | 12 +
.../plan/relational/sql/ast/SetSqlDialect.java | 10 +
.../plan/relational/sql/ast/SetTableComment.java | 12 +
.../plan/relational/sql/ast/ShowAIDevices.java | 12 +
.../plan/relational/sql/ast/ShowAINodes.java | 11 +
.../plan/relational/sql/ast/ShowAvailableUrls.java | 11 +
.../plan/relational/sql/ast/ShowCluster.java | 11 +
.../plan/relational/sql/ast/ShowClusterId.java | 11 +
.../plan/relational/sql/ast/ShowConfigNodes.java | 11 +
.../plan/relational/sql/ast/ShowConfiguration.java | 1 -
.../relational/sql/ast/ShowCurrentDatabase.java | 11 +
.../relational/sql/ast/ShowCurrentSqlDialect.java | 11 +
.../relational/sql/ast/ShowCurrentTimestamp.java | 11 +
.../plan/relational/sql/ast/ShowCurrentUser.java | 11 +
.../plan/relational/sql/ast/ShowDB.java | 10 +
.../plan/relational/sql/ast/ShowDataNodes.java | 11 +
.../plan/relational/sql/ast/ShowDevice.java | 12 +
.../plan/relational/sql/ast/ShowFunctions.java | 11 +
.../plan/relational/sql/ast/ShowIndex.java | 12 +
.../plan/relational/sql/ast/ShowLoadedModels.java | 13 +
.../plan/relational/sql/ast/ShowModels.java | 12 +
.../plan/relational/sql/ast/ShowPipePlugins.java | 12 +
.../plan/relational/sql/ast/ShowPipes.java | 13 +
.../plan/relational/sql/ast/ShowRegions.java | 13 +
.../plan/relational/sql/ast/ShowStatement.java | 17 +
.../plan/relational/sql/ast/ShowSubscriptions.java | 13 +
.../plan/relational/sql/ast/ShowTables.java | 12 +
.../plan/relational/sql/ast/ShowTopics.java | 13 +
.../plan/relational/sql/ast/ShowVariables.java | 11 +
.../plan/relational/sql/ast/ShowVersion.java | 11 +
.../relational/sql/ast/SimpleCaseExpression.java | 14 +
.../plan/relational/sql/ast/SimpleGroupBy.java | 12 +
.../plan/relational/sql/ast/SingleColumn.java | 15 +
.../plan/relational/sql/ast/SkipTo.java | 12 +
.../plan/relational/sql/ast/SortItem.java | 11 +
.../plan/relational/sql/ast/StartPipe.java | 12 +
.../plan/relational/sql/ast/StopPipe.java | 11 +
.../plan/relational/sql/ast/StringLiteral.java | 11 +
.../relational/sql/ast/SubqueryExpression.java | 12 +
.../plan/relational/sql/ast/SubsetDefinition.java | 14 +
.../plan/relational/sql/ast/SymbolReference.java | 11 +
.../queryengine/plan/relational/sql/ast/Table.java | 11 +
.../relational/sql/ast/TableFunctionArgument.java | 14 +
.../sql/ast/TableFunctionInvocation.java | 14 +
.../sql/ast/TableFunctionTableArgument.java | 15 +
.../plan/relational/sql/ast/TableSubquery.java | 12 +
.../plan/relational/sql/ast/TimeRange.java | 12 +
.../queryengine/plan/relational/sql/ast/Trim.java | 12 +
.../plan/relational/sql/ast/TypeParameter.java | 12 +
.../queryengine/plan/relational/sql/ast/Union.java | 11 +
.../plan/relational/sql/ast/UnloadModel.java | 14 +
.../plan/relational/sql/ast/Update.java | 11 +
.../plan/relational/sql/ast/UpdateAssignment.java | 13 +
.../queryengine/plan/relational/sql/ast/Use.java | 11 +
.../plan/relational/sql/ast/Values.java | 11 +
.../relational/sql/ast/VariableDefinition.java | 13 +
.../plan/relational/sql/ast/WhenClause.java | 12 +
.../plan/relational/sql/ast/WindowDefinition.java | 13 +
.../plan/relational/sql/ast/WindowFrame.java | 14 +
.../plan/relational/sql/ast/WindowReference.java | 12 +
.../relational/sql/ast/WindowSpecification.java | 18 +
.../queryengine/plan/relational/sql/ast/With.java | 11 +
.../plan/relational/sql/ast/WithQuery.java | 14 +
.../plan/relational/sql/ast/WrappedStatement.java | 5 +
.../relational/sql/ast/ZeroOrMoreQuantifier.java | 12 +
.../relational/sql/ast/ZeroOrOneQuantifier.java | 12 +
.../plan/relational/sql/util/SqlFormatter.java | 8 +-
.../InternalBatchActivateTemplateStatement.java | 2 +-
.../internal/SeriesSchemaFetchStatement.java | 2 +-
.../metadata/pipe/AlterPipeStatement.java | 40 +-
.../metadata/pipe/CreatePipeStatement.java | 28 +-
.../template/ActivateTemplateStatement.java | 11 +-
.../template/BatchActivateTemplateStatement.java | 2 +-
.../template/DeactivateTemplateStatement.java | 2 +-
.../rescon/MemSchemaRegionStatistics.java | 2 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 2 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 2 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 2 +-
.../schemaregion/mtree/IMTreeStore.java | 2 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 2 +-
.../schemaregion/mtree/impl/mem/MemMTreeStore.java | 2 +-
.../mnode/iterator/AbstractTraverserIterator.java | 2 +-
.../mnode/iterator/MemoryTraverserIterator.java | 2 +-
.../mtree/impl/pbtree/CachedMTreeStore.java | 2 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 2 +-
.../pbtree/ReentrantReadOnlyCachedMTreeStore.java | 2 +-
.../mnode/iterator/CachedTraverserIterator.java | 2 +-
.../schemaregion/mtree/traverser/Traverser.java | 2 +-
.../schemaregion/read/req/IShowTimeSeriesPlan.java | 2 +-
.../read/req/SchemaRegionReadPlanFactory.java | 2 +-
.../read/req/impl/ShowTimeSeriesPlanImpl.java | 2 +-
.../read/resp/info/impl/ShowDevicesResult.java | 24 +-
.../schemaregion/utils/MNodeUtils.java | 2 +-
.../template/ClusterTemplateManager.java | 1 +
.../db/schemaengine/template/ITemplateManager.java | 1 +
.../template/TemplateInternalRPCUtil.java | 2 +
.../db/service/metrics/CompactionMetrics.java | 14 +-
.../db/storageengine/dataregion/DataRegion.java | 15 +
.../execute/task/CrossSpaceCompactionTask.java | 6 -
.../execute/task/InnerSpaceCompactionTask.java | 6 -
.../execute/task/SettleCompactionTask.java | 1 -
.../compaction/execute/utils/CompactionUtils.java | 274 +++----
.../execute/utils/MultiTsFileDeviceIterator.java | 10 -
.../fast/FastAlignedSeriesCompactionExecutor.java | 23 -
.../compaction/schedule/TTLScheduleTask.java | 12 +
...leStatementDataTypeConvertExecutionVisitor.java | 2 +-
.../cache/TreeDeviceSchemaCacheManagerTest.java | 2 +-
.../schemaRegion/SchemaRegionManagementTest.java | 2 +-
.../SchemaRegionSimpleRecoverTest.java | 2 +-
.../schemaRegion/SchemaRegionTemplateTest.java | 2 +-
.../schemaRegion/SchemaRegionTestUtil.java | 2 +-
.../schemaRegion/SchemaStatisticsTest.java | 2 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 91 ++-
.../pipe/event/PipeTsFileInsertionEventTest.java | 298 +++++++
.../pipe/event/TsFileInsertionEventParserTest.java | 7 +-
.../db/pipe/pattern/IoTDBTreePatternTest.java | 35 +
.../source/PipeTreeStatementToPlanVisitorTest.java | 87 ++
.../common/schematree/ClusterSchemaTreeTest.java | 2 +-
.../plan/analyze/FakeSchemaFetcherImpl.java | 2 +-
.../plan/function/RecordObjectTypeTest.java | 2 +
.../plan/planner/distribution/Util.java | 2 +-
.../plan/planner/distribution/Util2.java | 2 +-
.../statement/sys/pipe/PipeStatementTest.java | 8 +-
.../relational/sql/AstMemoryEstimatorTest.java | 892 +++++++++++++++++++++
.../object/ObjectTypeCompactionTest.java | 161 +++-
.../db/utils/SchemaRegionSnapshotParserTest.java | 2 +-
.../datastructure/pattern/IoTDBTreePattern.java | 26 +
.../pipe/datastructure/pattern/TreePattern.java | 2 +-
.../pipe/source/IoTDBNonDataRegionSource.java | 14 +-
.../iotdb/commons/schema/column/ColumnHeader.java | 14 +-
.../iotdb/commons/schema/filter/SchemaFilter.java | 3 +-
.../commons/schema/filter/impl/DataTypeFilter.java | 9 +
.../schema/filter/impl/PathContainsFilter.java | 10 +
.../commons/schema/filter/impl/TagFilter.java | 9 +
.../commons/schema/filter/impl/TemplateFilter.java | 10 +
.../commons/schema/filter/impl/ViewTypeFilter.java | 10 +
.../multichildren/AbstractMultiChildrenFilter.java | 25 +
.../filter/impl/multichildren/AndFilter.java | 9 +
.../schema/filter/impl/multichildren/OrFilter.java | 9 +
.../singlechild/AbstractSingleChildFilter.java | 16 +
.../filter/impl/singlechild/AttributeFilter.java | 10 +
.../schema/filter/impl/singlechild/NotFilter.java | 9 +
.../schema/filter/impl/singlechild/TagFilter.java | 10 +
.../filter/impl/values/ComparisonFilter.java | 10 +
.../schema/filter/impl/values/InFilter.java | 8 +
.../schema/filter/impl/values/LikeFilter.java | 11 +
.../schema/filter/impl/values/PreciseFilter.java | 10 +
.../iotdb/commons/schema}/template/Template.java | 2 +-
.../thrift-ainode/src/main/thrift/ainode.thrift | 4 +-
pom.xml | 2 +-
434 files changed, 8692 insertions(+), 2396 deletions(-)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/{PipeConfigPhysicalPlanTablePatternParseVisitor.java
=> PipeConfigTablePatternParseVisitor.java} (99%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/{PipeConfigPhysicalPlanTablePrivilegeParseVisitor.java
=> PipeConfigTablePrivilegeParseVisitor.java} (99%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/{PipeConfigPhysicalPlanTableScopeParseVisitor.java
=> PipeConfigTableScopeParseVisitor.java} (98%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/{PipeConfigPhysicalPlanTreePatternParseVisitor.java
=> PipeConfigTreePatternParseVisitor.java} (97%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/PipeConfigTreePrivilegeParseVisitor.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/{PipeConfigPhysicalPlanTreeScopeParseVisitor.java
=> PipeConfigTreeScopeParseVisitor.java} (98%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/source/{PipeConfigPhysicalPlanScopeParseVisitorTest.java
=> PipeConfigScopeParseVisitorTest.java} (98%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/source/{PipeConfigPhysicalPlanTablePatternParseVisitorTest.java
=> PipeConfigTablePatternParseVisitorTest.java} (99%)
rename
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/source/{PipeConfigPhysicalPlanTreePatternParseVisitorTest.java
=> PipeConfigTreePatternParseVisitorTest.java} (99%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/source/PipeConfigTreePrivilegeParseVisitorTest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/schemaregion/PipePlanTreePrivilegeParseVisitor.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/schemaregion/{PipeStatementToPlanVisitor.java
=> PipeTableStatementToPlanVisitor.java} (96%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/schemaregion/PipeTreeStatementToPlanVisitor.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/AstMemoryEstimator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/AstMemoryEstimationHelper.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/PipeTsFileInsertionEventTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/PipeTreeStatementToPlanVisitorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/sql/AstMemoryEstimatorTest.java
rename iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/schemaengine =>
node-commons/src/main/java/org/apache/iotdb/commons/schema}/template/Template.java
(99%)
