This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch fix_count_1 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 13f72c8b00923d5f17e0f3aa8c77a1ce08a682df Merge: e074834acac 3f9778a6004 Author: Beyyes <[email protected]> AuthorDate: Thu Mar 13 16:20:44 2025 +0800 Merge branch 'master' of github.com:apache/iotdb .../iotdb/udf/table/ExcludeColumnExample.java | 108 +++++ .../org/apache/iotdb/udf/table/RepeatExample.java | 125 ++++++ .../org/apache/iotdb/udf/table/SplitExample.java | 114 +++++ .../example/relational/MyErrorTableFunction.java | 114 +++++ .../udf/example/relational/MyExcludeColumn.java | 89 ++++ .../udf/example/relational/MyRepeatWithIndex.java | 102 +++++ .../example/relational/MyRepeatWithoutIndex.java | 99 +++++ .../db/query/udf/example/relational/MySplit.java | 98 +++++ .../org/apache/iotdb/ainode/it/AINodeBasicIT.java | 15 +- .../org/apache/iotdb/db/it/utils/TestUtils.java | 1 - .../it/db/it/udf/IoTDBSQLFunctionManagementIT.java | 22 +- .../db/it/udf/IoTDBUserDefinedTableFunctionIT.java | 272 ++++++++++++ .../iotdb/udf/api/relational/TableFunction.java | 83 +++- .../iotdb/udf/api/relational/access/Record.java | 2 + .../relational/table/TableFunctionAnalysis.java | 89 ++++ .../table/TableFunctionProcessorProvider.java | 43 ++ .../api/relational/table/argument/Argument.java | 34 +- .../relational/table/argument/DescribedSchema.java | 89 ++++ .../relational/table/argument/ScalarArgument.java | 155 +++++++ .../relational/table/argument/TableArgument.java | 177 ++++++++ .../processor/TableFunctionDataProcessor.java | 64 +++ .../processor/TableFunctionLeafProcessor.java | 28 +- .../specification/ParameterSpecification.java | 77 ++++ .../ScalarParameterSpecification.java | 76 ++++ .../specification/TableParameterSpecification.java | 98 +++++ .../java/org/apache/iotdb/udf/api/type/Type.java | 38 ++ .../java/org/apache/iotdb/cli/AbstractCli.java | 20 +- .../impl/schema/UnsetTemplateProcedure.java | 146 +++---- .../deletion/persist/PageCacheDeletionBuffer.java | 9 +- .../pipeconsensus/PipeConsensusReceiver.java | 32 +- .../v1/handler/StatementConstructionHandler.java | 2 +- .../impl/DataNodeInternalRPCServiceImpl.java | 33 +- .../execution/executor/RegionWriteExecutor.java | 18 +- .../operator/process/AssignUniqueIdOperator.java | 2 +- .../operator/process/EnforceSingleRowOperator.java | 2 +- .../operator/process/ai/InferenceOperator.java | 42 +- .../process/function/PartitionRecognizer.java | 179 ++++++++ .../function/TableFunctionLeafOperator.java | 111 +++++ .../process/function/TableFunctionOperator.java | 269 ++++++++++++ .../process/function/partition/PartitionState.java | 62 +++ .../operator/process/function/partition/Slice.java | 183 ++++++++ .../process/function/partition/SliceCache.java | 106 +++++ .../process/window/TableWindowOperator.java | 2 +- .../operator/sink/ShuffleHelperOperator.java | 2 +- .../queryengine/plan/analyze/AnalyzeVisitor.java | 49 +-- .../plan/analyze/lock/SchemaLockType.java | 13 - .../config/executor/ClusterConfigTaskExecutor.java | 18 + .../config/metadata/ShowFunctionsTask.java | 6 + .../db/queryengine/plan/parser/ASTVisitor.java | 3 + .../plan/parser/StatementGenerator.java | 4 +- .../plan/planner/LogicalPlanBuilder.java | 1 + .../plan/planner/LogicalPlanVisitor.java | 2 +- .../plan/planner/OperatorTreeGenerator.java | 1 + .../plan/planner/TableOperatorGenerator.java | 87 ++++ .../plan/planner/plan/node/PlanGraphPrinter.java | 54 +++ .../plan/planner/plan/node/PlanNodeType.java | 9 +- .../plan/planner/plan/node/PlanVisitor.java | 10 + .../plan/node/process/AI/InferenceNode.java | 18 +- .../plan/relational/analyzer/Analysis.java | 14 + .../relational/analyzer/StatementAnalyzer.java | 482 ++++++++++++++++++++- .../analyzer/tablefunction/ArgumentAnalysis.java} | 32 +- .../analyzer/tablefunction/ArgumentsAnalysis.java | 52 +++ .../tablefunction/TableArgumentAnalysis.java | 152 +++++++ .../TableFunctionInvocationAnalysis.java | 68 +++ .../plan/relational/metadata/Metadata.java | 3 + .../relational/metadata/TableMetadataImpl.java | 13 + .../plan/relational/metadata/TableSchema.java | 2 +- .../planner/DataOrganizationSpecification.java | 106 +++++ .../plan/relational/planner/QueryPlanner.java | 20 + .../plan/relational/planner/RelationPlanner.java | 137 ++++++ .../planner/distribute/AddExchangeNodes.java | 21 +- .../distribute/TableDistributedPlanGenerator.java | 20 +- .../rule/ImplementTableFunctionSource.java | 163 +++++++ .../rule/PruneTableFunctionProcessorColumns.java | 86 ++++ .../PruneTableFunctionProcessorSourceColumns.java | 96 ++++ .../plan/relational/planner/node/Patterns.java | 13 +- .../relational/planner/node/TableFunctionNode.java | 358 +++++++++++++++ .../planner/node/TableFunctionProcessorNode.java | 274 ++++++++++++ .../optimizations/LogicalOptimizeFactory.java | 6 + .../PushLimitOffsetIntoTableScan.java | 11 + .../planner/optimizations/SymbolMapper.java | 7 + .../optimizations/UnaliasSymbolReferences.java | 107 +++++ .../plan/relational/sql/ast/AstVisitor.java | 13 + .../relational/sql/ast/TableFunctionArgument.java | 92 ++++ .../sql/ast/TableFunctionInvocation.java | 92 ++++ .../sql/ast/TableFunctionTableArgument.java | 119 +++++ .../plan/relational/sql/parser/AstBuilder.java | 108 +++++ .../plan/relational/sql/util/SqlFormatter.java | 75 ++++ .../plan/statement/crud/QueryStatement.java | 9 + .../db/schemaengine/table/DataNodeTableCache.java | 28 +- .../template/TemplateInternalRPCUpdateType.java | 5 +- .../db/storageengine/dataregion/DataRegion.java | 4 + .../task/InsertionCrossSpaceCompactionTask.java | 10 +- .../execute/utils/MultiTsFileDeviceIterator.java | 5 +- .../tsfile/timeindex/ArrayDeviceTimeIndex.java | 3 +- .../dataregion/tsfile/timeindex/FileTimeIndex.java | 2 +- .../rescon/memory/TimePartitionManager.java | 4 +- .../apache/iotdb/db/utils/ErrorHandlingUtils.java | 3 +- .../process/tvf/TableFunctionOperatorTest.java | 302 +++++++++++++ .../db/queryengine/plan/function/Exclude.java | 89 ++++ .../iotdb/db/queryengine/plan/function/Repeat.java | 106 +++++ .../iotdb/db/queryengine/plan/function/Split.java | 98 +++++ .../plan/parser/StatementGeneratorTest.java | 2 +- .../plan/relational/analyzer/TSBSMetadata.java | 6 + .../relational/analyzer/TableFunctionTest.java | 303 +++++++++++++ .../plan/relational/analyzer/TestMatadata.java | 20 + .../planner/assertions/PlanMatchPattern.java | 20 + .../planner/assertions/SpecificationProvider.java | 79 ++++ .../assertions/TableFunctionProcessorMatcher.java | 303 +++++++++++++ .../compaction/CompactionWithMinTimestampTest.java | 136 ++++++ .../apache/iotdb/commons/memory/IMemoryBlock.java | 3 - .../schema/table/column/TsTableColumnCategory.java | 2 +- .../viewExpression/unary/LikeViewExpression.java | 53 ++- .../iotdb/commons/udf/access/RecordIterator.java | 141 +++--- .../relational/TableBuiltinTableFunction.java | 62 +++ .../builtin/relational/tvf/HOPTableFunction.java | 153 +++++++ .../db/relational/grammar/sql/RelationalSql.g4 | 29 ++ 117 files changed, 8081 insertions(+), 348 deletions(-)
