(iotdb) branch new_udtf created (now efebc400a98)

[ch...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

chenyz pushed a change to branch new_udtf
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at efebc400a98 udtf

This branch includes the following new commits:

     new efebc400a98 udtf

The 1 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.

(iotdb) 01/01: udtf

[ch...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

chenyz pushed a commit to branch new_udtf
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit efebc400a9831ff6d9f073a67bba99ac5ac279df
Merge: 3238ec257a1 6e7f105122c
Author: Chen YZ <ch...@gmail.com>
AuthorDate: Wed Dec 25 22:01:06 2024 +0800

    udtf

 .../udf/api/relational/table/TableFunction.java    |  47 ++
 .../relational/table/TableFunctionAnalysis.java    |  97 ++++
 .../relational/table/TableFunctionPartition.java   |  28 +
 .../table/TableFunctionProcessorProvider.java      |  43 ++
 .../api/relational/table/argument/Argument.java    |  22 +
 .../api/relational/table/argument/Descriptor.java  |  95 ++++
 .../table/argument/DescriptorArgument.java         |  57 ++
 .../relational/table/argument/ScalarArgument.java  |  40 ++
 .../relational/table/argument/TableArgument.java   |  68 +++
 .../processor/TableFunctionDataProcessor.java      |  44 ++
 .../processor/TableFunctionProcessorState.java     |  72 +++
 .../processor/TableFunctionSplitProcessor.java     |  22 +
 .../DescriptorParameterSpecification.java          |  57 ++
 .../specification/ParameterSpecification.java      |  78 +++
 .../specification/ReturnTypeSpecification.java     |  68 +++
 .../ScalarParameterSpecification.java              |  76 +++
 .../specification/TableParameterSpecification.java | 103 ++++
 .../java/org/apache/iotdb/udf/api/type/Type.java   |  31 ++
 .../transformation/TableFunctionPartitionImpl.java | 179 ++++++
 .../common/transformation/Transformation.java      |  41 ++
 .../common/transformation/TransformationState.java | 131 +++++
 .../execution/function/table/HOPTableFunction.java | 105 ++++
 .../process/function/TableFunctionOperator.java    | 168 ++++++
 .../TableFunctionPartitionTransformation.java      |  86 +++
 .../GroupedUserDefinedAggregateAccumulator.java    |   4 +
 .../plan/planner/TableOperatorGenerator.java       |  60 ++
 .../plan/planner/plan/node/PlanGraphPrinter.java   |  73 +++
 .../plan/planner/plan/node/PlanVisitor.java        |  10 +
 .../plan/relational/analyzer/Analysis.java         |  29 +
 .../relational/analyzer/StatementAnalyzer.java     | 615 ++++++++++++++++++++-
 .../analyzer/tablefunction/ArgumentAnalysis.java   |  46 ++
 .../analyzer/tablefunction/ArgumentsAnalysis.java  |  52 ++
 .../tablefunction/TableArgumentAnalysis.java       | 173 ++++++
 .../TableFunctionInvocationAnalysis.java           |  68 +++
 .../plan/relational/metadata/Metadata.java         |   3 +
 .../relational/metadata/TableMetadataImpl.java     |   8 +
 .../planner/DataOrganizationSpecification.java     |  51 +-
 .../plan/relational/planner/QueryPlanner.java      |  20 +
 .../plan/relational/planner/RelationPlanner.java   | 136 +++++
 .../rule/ImplementTableFunctionSource.java         | 165 ++++++
 .../plan/relational/planner/node/Patterns.java     |  13 +-
 .../relational/planner/node/TableFunctionNode.java | 241 ++++++++
 .../planner/node/TableFunctionProcessorNode.java   | 207 +++++++
 .../optimizations/LogicalOptimizeFactory.java      |   3 +
 .../planner/optimizations/SymbolMapper.java        |   7 +
 .../optimizations/UnaliasSymbolReferences.java     | 112 ++++
 .../plan/relational/sql/ast/AstVisitor.java        |  30 +
 .../plan/relational/sql/ast/Descriptor.java        |  80 +++
 .../plan/relational/sql/ast/DescriptorField.java   |  88 +++
 .../relational/sql/ast/EmptyTableTreatment.java    |  86 +++
 .../relational/sql/ast/TableFunctionArgument.java  |  95 ++++
 .../sql/ast/TableFunctionDescriptorArgument.java   |  87 +++
 .../sql/ast/TableFunctionInvocation.java           | 117 ++++
 .../sql/ast/TableFunctionTableArgument.java        | 128 +++++
 .../plan/relational/sql/parser/AstBuilder.java     | 140 +++++
 .../plan/relational/sql/util/SqlFormatter.java     | 116 ++++
 .../db/relational/grammar/sql/RelationalSql.g4     |  35 ++
 57 files changed, 4815 insertions(+), 41 deletions(-)