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 538c24c8bf4 [FLINK-31499][table] Move `SqlCreateTable` conversion
logic to `SqlCreateTableConverter` and make it more generic
add ba8312f05b4 [FLINK-38258][table] Support model args in PTFs and
ML_PREDICT built-in PTF
No new revisions were added by this update.
Summary of changes:
.../table/functions/BuiltInFunctionDefinition.java | 5 +
.../functions/BuiltInFunctionDefinitions.java | 30 +++
.../ModelSemantics.java} | 21 +-
.../flink/table/types/inference/CallContext.java | 10 +
.../table/types/inference/StaticArgument.java | 31 +++
.../table/types/inference/SystemTypeInference.java | 59 +++--
.../flink/table/types/inference/TypeInference.java | 24 +-
.../table/types/inference/TypeInferenceUtil.java | 15 ++
.../strategies/MLPredictTypeStrategy.java | 249 +++++++++++++++++++++
.../strategies/SpecificInputTypeStrategies.java | 4 +
.../strategies/SpecificTypeStrategies.java | 4 +
.../types/inference/utils/CastCallContext.java | 7 +
.../inference/InputTypeStrategiesTestBase.java | 20 ++
.../types/inference/TypeStrategiesTestBase.java | 23 ++
.../strategies/MLPredictInputTypeStrategyTest.java | 166 ++++++++++++++
.../MLPredictOutputTypeStrategyTest.java | 154 +++++++++++++
.../types/inference/utils/CallContextMock.java | 23 ++
.../types/inference/utils/ModelSemanticsMock.java} | 28 ++-
.../types/inference/utils/TableSemanticsMock.java | 79 +++++++
.../inference/CallBindingCallContext.java | 65 ++++++
.../functions/sql/FlinkSqlOperatorTable.java | 2 -
.../sql/ml/SqlMLPredictTableFunction.java | 135 -----------
.../StreamPhysicalMLPredictTableFunction.java | 28 +--
.../StreamPhysicalMLPredictTableFunctionRule.java | 145 +++++++++++-
.../stream/StreamPhysicalProcessTableFunction.java | 15 ++
.../StreamPhysicalProcessTableFunctionRule.java | 5 +-
.../exec/stream/ProcessTableFunctionTestUtils.java | 54 +++++
.../stream/sql/MLPredictTableFunctionTest.java | 78 +++----
.../plan/stream/sql/ProcessTableFunctionTest.java | 20 ++
.../plan/stream/sql/MLPredictTableFunctionTest.xml | 242 ++++++++++++--------
30 files changed, 1397 insertions(+), 344 deletions(-)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/{types/inference/TypeStrategy.java
=> functions/ModelSemantics.java} (65%)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MLPredictTypeStrategy.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/MLPredictInputTypeStrategyTest.java
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/strategies/MLPredictOutputTypeStrategyTest.java
copy
flink-table/flink-table-common/src/{main/java/org/apache/flink/table/types/inference/strategies/MissingTypeStrategy.java
=>
test/java/org/apache/flink/table/types/inference/utils/ModelSemanticsMock.java}
(57%)
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/types/inference/utils/TableSemanticsMock.java
delete mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/ml/SqlMLPredictTableFunction.java
