(flink) branch master updated (1586a55d8d3 -> 449fef0339a)

[sh...@apache.org]

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 1586a55d8d3 [FLINK-37862][table] Support inline structured types in SQL
     add 449fef0339a [FLINK-37901][table] Support to serde for StreamExecMLPredictTableFunction (#26641)

No new revisions were added by this update.

Summary of changes:
 .../flink/table/test/program/ModelTestStep.java    | 132 ++++++
 .../flink/table/test/program/TableTestProgram.java |  18 +
 .../apache/flink/table/test/program/TestStep.java  |   1 +
 .../nodes/exec/serde/CompiledPlanSerdeUtil.java    |  44 ++
 .../ContextResolvedModelJsonDeserializer.java      | 210 +++++++++
 .../serde/ContextResolvedModelJsonSerializer.java  |  84 ++++
 .../ContextResolvedTableJsonDeserializer.java      |  35 +-
 ...a => ResolvedCatalogModelJsonDeserializer.java} |  69 ++-
 .../serde/ResolvedCatalogModelJsonSerializer.java  |  86 ++++
 .../plan/nodes/exec/spec/MLPredictSpec.java        |  12 +-
 .../planner/plan/nodes/exec/spec/ModelSpec.java    |  53 ++-
 .../stream/StreamExecMLPredictTableFunction.java   | 127 ++---
 .../StreamPhysicalMLPredictTableFunction.java      |   8 -
 .../planner/plan/utils/ExecNodeMetadataUtil.java   |   5 +-
 .../table/planner/plan/utils/LookupJoinUtil.java   |   1 +
 .../exec/serde/ContextResolvedModelSerdeTest.java  | 519 +++++++++++++++++++++
 ...eRestoreTest.java => MLPredictRestoreTest.java} |  18 +-
 .../nodes/exec/stream/MLPredictTestPrograms.java   | 170 +++++++
 .../plan/nodes/exec/testutils/RestoreTestBase.java |  17 +
 .../plan/async-ordered-ml-predict.json             | 139 ++++++
 .../async-ordered-ml-predict/savepoint/_metadata   | Bin 0 -> 6537 bytes
 .../plan/async-unordered-ml-predict.json           | 139 ++++++
 .../async-unordered-ml-predict/savepoint/_metadata | Bin 0 -> 6533 bytes
 .../sync-ml-predict/plan/sync-ml-predict.json}     | 116 +++--
 .../sync-ml-predict/savepoint/_metadata            | Bin 0 -> 5148 bytes
 25 files changed, 1769 insertions(+), 234 deletions(-)
 create mode 100644 flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/test/program/ModelTestStep.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ContextResolvedModelJsonDeserializer.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ContextResolvedModelJsonSerializer.java
 copy flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/{ResolvedCatalogTableJsonDeserializer.java => ResolvedCatalogModelJsonDeserializer.java} (58%)
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ResolvedCatalogModelJsonSerializer.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ContextResolvedModelSerdeTest.java
 copy flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/{GroupWindowAggregateEventTimeRestoreTest.java => MLPredictRestoreTest.java} (63%)
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MLPredictTestPrograms.java
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-ml-predict-table-function_1/async-ordered-ml-predict/plan/async-ordered-ml-predict.json
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-ml-predict-table-function_1/async-ordered-ml-predict/savepoint/_metadata
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-ml-predict-table-function_1/async-unordered-ml-predict/plan/async-unordered-ml-predict.json
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-ml-predict-table-function_1/async-unordered-ml-predict/savepoint/_metadata
 copy flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-sink_1/sink-upsert/plan/sink-upsert.json => stream-exec-ml-predict-table-function_1/sync-ml-predict/plan/sync-ml-predict.json} (50%)
 create mode 100644 flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-ml-predict-table-function_1/sync-ml-predict/savepoint/_metadata