This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 9b3bdc40f50 Pipe: Implemented tree auth check for source +
write-back-sink (#16531)
add 8a5e1e3707f feat: add AstMemoryEstimator for SQL AST memory estimation
(#16882)
No new revisions were added by this update.
Summary of changes:
.../plan/execution/config/session/PrepareTask.java | 3 +-
.../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 | 15 +
.../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 +
.../read/resp/info/impl/ShowDevicesResult.java | 24 +-
.../relational/sql/AstMemoryEstimatorTest.java | 892 +++++++++++++++++++++
.../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 +
pom.xml | 2 +-
222 files changed, 3722 insertions(+), 77 deletions(-)
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/queryengine/plan/relational/sql/AstMemoryEstimatorTest.java
