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 7b783591192 [FLINK-38499][runtime] Limit max sleep time in Curator for
Zookeeper HA
add e24149ba9a4 [FLINK-38426][table] Introduce sync vector search operator
(#27122)
No new revisions were added by this update.
Summary of changes:
.../generated/execution_config_configuration.html | 27 +++
.../table/api/config/ExecutionConfigOptions.java | 45 ++++
.../table/functions/AsyncVectorSearchFunction.java | 2 +-
.../table/functions/VectorSearchFunction.java | 2 +-
.../nodes/exec/spec/DynamicTableSourceSpec.java | 14 ++
.../nodes/exec/spec/TemporalTableSourceSpec.java | 2 +-
.../plan/nodes/exec/spec/VectorSearchSpec.java | 14 +-
.../exec/spec/VectorSearchTableSourceSpec.java | 59 ++++++
.../StreamExecVectorSearchTableFunction.java | 231 +++++++++++++++++++++
.../StreamPhysicalVectorSearchTableFunction.java | 73 +++++--
...treamPhysicalVectorSearchTableFunctionRule.java | 6 +-
.../planner/plan/utils/ExecNodeMetadataUtil.java | 2 +
.../table/planner/plan/utils/FunctionCallUtil.java | 13 ++
.../table/planner/plan/utils/VectorSearchUtil.java | 80 +++++++
...rator.scala => VectorSearchCodeGenerator.scala} | 125 +++++------
.../factories/TestValuesRuntimeFunctions.java | 104 ++++++++++
.../planner/factories/TestValuesTableFactory.java | 88 ++++++++
.../runtime/stream/table/VectorSearchITCase.java | 153 ++++++++++++++
...ava => VectorSearchRuntimeProviderContext.java} | 38 ++--
.../runtime/operators/ml/MLPredictRunner.java | 8 +
.../VectorSearchRunner.java} | 63 ++----
21 files changed, 986 insertions(+), 163 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/spec/VectorSearchTableSourceSpec.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecVectorSearchTableFunction.java
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/VectorSearchUtil.java
copy
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/{MLPredictCodeGenerator.scala
=> VectorSearchCodeGenerator.scala} (52%)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/table/VectorSearchITCase.java
copy
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/connector/source/{LookupRuntimeProviderContext.java
=> VectorSearchRuntimeProviderContext.java} (63%)
copy
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/{join/lookup/LookupJoinRunner.java
=> search/VectorSearchRunner.java} (63%)
