This is an automated email from the ASF dual-hosted git repository.
chenyz pushed a change to branch builtin-udtf
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c3c3e39e322 save
add 3f0820a79d5 save
add b03a000d66f fix bug
add 0002ea5383e fix it
add b88175bd4d1 save
add 0a5d3b0aa38 save
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/TableModelSessionExample2.java | 76 ++++++++++++++++++++++
.../org/apache/iotdb/udf/table/SessionAvg.java | 73 ++++++++++++++++-----
.../udf/IoTDBUserDefinedAggregateFunctionIT.java | 9 ++-
.../relational/table/TableFunctionAnalysis.java | 28 +++++++-
.../processor/TableFunctionDataProcessor.java | 8 +++
.../iotdb/confignode/conf/ConfigNodeConfig.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 3 +-
.../process/function/PartitionRecognizer.java | 42 +++++++++---
.../process/function/TableFunctionOperator.java | 73 ++++++++++++---------
.../process/function/partition/PartitionCache.java | 12 +++-
.../operator/process/function/partition/Slice.java | 54 ++++++++++-----
.../grouped/StreamingHashAggregationOperator.java | 32 +++++++--
.../plan/planner/TableOperatorGenerator.java | 3 +-
.../relational/analyzer/StatementAnalyzer.java | 3 +-
.../TableFunctionInvocationAnalysis.java | 9 ++-
.../plan/relational/planner/RelationPlanner.java | 3 +-
.../rule/ImplementTableFunctionSource.java | 6 +-
.../rule/PruneTableFunctionProcessorColumns.java | 3 +-
.../PruneTableFunctionProcessorSourceColumns.java | 3 +-
.../relational/planner/node/TableFunctionNode.java | 20 +++++-
.../planner/node/TableFunctionProcessorNode.java | 26 ++++++--
.../optimizations/LogicalOptimizeFactory.java | 2 +-
.../optimizations/UnaliasSymbolReferences.java | 9 ++-
.../process/tvf/TableFunctionOperatorTest.java | 2 +-
.../relational/TableBuiltinTableFunction.java | 4 +-
.../relational/tvf/CapacityTableFunction.java | 1 +
.../builtin/relational/tvf/HOPTableFunction.java | 3 +-
.../relational/tvf/SessionTableFunction.java | 24 ++++++-
.../relational/tvf/VariationTableFunction.java | 7 +-
.../commons/udf/service/UDFManagementService.java | 2 +-
30 files changed, 423 insertions(+), 119 deletions(-)
create mode 100644
example/session/src/main/java/org/apache/iotdb/TableModelSessionExample2.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/SessionTableFunction.java
=> example/udf/src/main/java/org/apache/iotdb/udf/table/SessionAvg.java (66%)
