You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by sh...@apache.org on 2025/06/17 01:33:44 UTC

(flink) branch master updated (e94511f49f6 -> 8ec65160f0d)

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 e94511f49f6 [FLINK-37952] Skip compressing built python wheels by hand in Nightly workflow
     add 8ec65160f0d [FLINK-37794][table] Add ML_EVALUTE sql function (#26644)

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/flink/table/ml/TaskType.java   |  32 +-
 .../org/apache/flink/table/ml/TaskTypeTest.java    |  75 +++
 .../functions/sql/FlinkSqlOperatorTable.java       |   2 +
 .../sql/ml/SqlMLEvaluateTableFunction.java         | 233 +++++++++
 .../sql/ml/SqlMLPredictTableFunction.java          | 186 +------
 .../functions/sql/ml/SqlMLTableFunction.java       | 180 +++++++
 .../stream/sql/MLEvaluateTableFunctionTest.java    | 537 +++++++++++++++++++++
 .../stream/sql/MLPredictTableFunctionTest.java     |  28 +-
 8 files changed, 1086 insertions(+), 187 deletions(-)
 copy flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/declare/NamedCallback.java => flink-table/flink-table-common/src/main/java/org/apache/flink/table/ml/TaskType.java (51%)
 create mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/ml/TaskTypeTest.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/ml/SqlMLEvaluateTableFunction.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/stream/sql/MLEvaluateTableFunctionTest.java