This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8e079a2 [FLINK-25763][match-recognize][docs] Updated docs to use code
tag consistent with other tables
add ce9c100 [FLINK-25769][table-common] Introduce hidden functions in
module system
add 54f1f9e [FLINK-25769][table] Introduce internal and versioned
built-in functions
add 72ed6b8 [FLINK-25769][table-planner] Update some SqlFunction to new
architecture
No new revisions were added by this update.
Summary of changes:
.../apache/flink/table/module/ModuleManager.java | 8 +-
.../flink/table/module/ModuleManagerTest.java | 102 ++++-----
.../org/apache/flink/table/utils/ModuleMock.java | 39 +++-
.../table/functions/BuiltInFunctionDefinition.java | 122 ++++++++++-
.../functions/BuiltInFunctionDefinitions.java | 3 +-
.../org/apache/flink/table/module/CoreModule.java | 51 +++--
.../java/org/apache/flink/table/module/Module.java | 17 +-
.../apache/flink/table/module/CoreModuleTest.java | 47 +++-
.../inference/utils/FunctionDefinitionMock.java | 9 +
.../planner/functions/sql/BuiltInSqlFunction.java | 244 +++++++++++++++++++++
.../planner/functions/sql/BuiltInSqlOperator.java | 77 +++++++
.../planner/functions/sql/CalciteSqlFunction.java | 69 ------
.../functions/sql/FlinkSqlOperatorTable.java | 162 +++++++-------
.../functions/sql/MatchRowTimeFunction.java | 3 +-
.../sql/ProctimeMaterializeSqlFunction.java | 66 ------
.../sql/StreamRecordTimestampSqlFunction.java | 53 -----
.../exec/stream/StreamExecDataStreamScan.java | 4 +-
.../planner/plan/batch/sql/SetOperatorsTest.xml | 4 +-
.../planner/plan/batch/table/SetOperatorsTest.xml | 4 +-
.../planner/plan/common/PartialInsertTest.xml | 8 +-
.../rules/logical/RewriteIntersectAllRuleTest.xml | 8 +-
.../plan/rules/logical/RewriteMinusAllRuleTest.xml | 8 +-
.../planner/plan/stream/sql/SetOperatorsTest.xml | 4 +-
23 files changed, 732 insertions(+), 380 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/BuiltInSqlFunction.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/BuiltInSqlOperator.java
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/CalciteSqlFunction.java
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/ProctimeMaterializeSqlFunction.java
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/StreamRecordTimestampSqlFunction.java
