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 4931d08d7b2 [FLINK-38229][runtime-web] Enhanced Job History Retention
Policies for HistoryServer (#26902)
add 3ab320c3c04 [FLINK-38431][table] Support VECTOR_SEARCH in batch mode
(#27154)
No new revisions were added by this update.
Summary of changes:
.../BatchExecVectorSearchTableFunction.java} | 66 +--
.../CommonExecVectorSearchTableFunction.java} | 68 +--
.../StreamExecVectorSearchTableFunction.java | 263 +----------
.../BatchPhysicalVectorSearchTableFunction.java | 111 +++++
.../common/CommonPhysicalVectorSearchFunction.java | 111 +++++
.../StreamPhysicalVectorSearchTableFunction.java | 79 +---
.../PhysicalVectorSearchTableFunctionRule.java} | 132 ++++--
.../planner/plan/rules/FlinkBatchRuleSets.scala | 5 +
.../planner/plan/rules/FlinkStreamRuleSets.scala | 3 +-
...est.java => VectorSearchTableFunctionTest.java} | 13 +-
.../VectorSearchTableFunctionTestBase.java} | 40 +-
.../VectorSearchBatchRestoreTest.java} | 18 +-
.../VectorSearchTestPrograms.java | 3 +-
.../nodes/exec/stream/VectorSearchRestoreTest.java | 6 +-
.../stream/sql/VectorSearchTableFunctionTest.java | 502 +--------------------
.../sql/AsyncVectorSearchITCase.java} | 23 +-
.../sql/VectorSearchITCase.java} | 15 +-
.../{table => sql}/AsyncVectorSearchITCase.java | 2 +-
...omicRtasITCase.java => VectorSearchITCase.java} | 22 +-
.../VectorSearchITCaseBase.java} | 57 ++-
.../sql/VectorSearchTableFunctionTest.xml | 94 ++--
.../plan/async-vector-search.json | 18 +-
.../plan/sync-vector-search.json | 18 +-
.../plan/vector-search-with-runtime-config.json | 19 +-
24 files changed, 598 insertions(+), 1090 deletions(-)
copy
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/{stream/StreamExecAsyncCorrelate.java
=> batch/BatchExecVectorSearchTableFunction.java} (53%)
copy
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/{stream/StreamExecVectorSearchTableFunction.java
=> common/CommonExecVectorSearchTableFunction.java} (82%)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchPhysicalVectorSearchTableFunction.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/physical/common/CommonPhysicalVectorSearchFunction.java
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/physical/{stream/StreamPhysicalVectorSearchTableFunctionRule.java
=> common/PhysicalVectorSearchTableFunctionRule.java} (70%)
copy
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/batch/sql/{CalcMergeTest.java
=> VectorSearchTableFunctionTest.java} (74%)
copy
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/{stream/sql/VectorSearchTableFunctionTest.java
=> common/VectorSearchTableFunctionTestBase.java} (95%)
copy
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/{stream/VectorSearchRestoreTest.java
=> batch/VectorSearchBatchRestoreTest.java} (63%)
rename
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/{stream
=> common}/VectorSearchTestPrograms.java (97%)
copy
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/{stream/sql/AtomicRtasITCase.java
=> batch/sql/AsyncVectorSearchITCase.java} (71%)
copy
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/{stream/sql/AtomicRtasITCase.java
=> batch/sql/VectorSearchITCase.java} (77%)
rename
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/{table
=> sql}/AsyncVectorSearchITCase.java (99%)
copy
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/{AtomicRtasITCase.java
=> VectorSearchITCase.java} (68%)
rename
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/{stream/table/VectorSearchITCase.java
=> utils/VectorSearchITCaseBase.java} (77%)
copy
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/{stream
=> batch}/sql/VectorSearchTableFunctionTest.xml (75%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-vector-search-table-function_1
=>
batch-exec-vector-search-table-function_1}/async-vector-search/plan/async-vector-search.json
(91%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-vector-search-table-function_1
=>
batch-exec-vector-search-table-function_1}/sync-vector-search/plan/sync-vector-search.json
(91%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/{stream-exec-vector-search-table-function_1
=>
batch-exec-vector-search-table-function_1}/vector-search-with-runtime-config/plan/vector-search-with-runtime-config.json
(89%)
