This is an automated email from the ASF dual-hosted git repository.
shengkai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 5eeb2fc8197 [FLINK-37823][python] Add Python 3.12 support (#26579)
add 4c77daaf355 [FLINK-37790][table] Introduce model provider related
interfaces (#26577)
No new revisions were added by this update.
Summary of changes:
.../table/factories/ModelProviderFactory.java | 90 ++++++++++++++++++++++
...okupFunction.java => AsyncPredictFunction.java} | 28 +++----
.../{LookupFunction.java => PredictFunction.java} | 36 ++++-----
.../table/ml/AsyncPredictRuntimeProvider.java | 12 +--
.../org/apache/flink/table/ml/ModelProvider.java | 60 +++++++++++++++
.../flink/table/ml/PredictRuntimeProvider.java | 14 ++--
.../java/org/apache/flink/table/module/Module.java | 24 ++++++
7 files changed, 215 insertions(+), 49 deletions(-)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/ModelProviderFactory.java
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/{AsyncLookupFunction.java
=> AsyncPredictFunction.java} (70%)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/{LookupFunction.java
=> PredictFunction.java} (53%)
copy
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/strategy/ResultInfo.java
=>
flink-table/flink-table-common/src/main/java/org/apache/flink/table/ml/AsyncPredictRuntimeProvider.java
(71%)
create mode 100644
flink-table/flink-table-common/src/main/java/org/apache/flink/table/ml/ModelProvider.java
copy
flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/hadoop/mapred/wrapper/HadoopDummyProgressable.java
=>
flink-table/flink-table-common/src/main/java/org/apache/flink/table/ml/PredictRuntimeProvider.java
(72%)
