davidradl commented on code in PR #27130:
URL: https://github.com/apache/flink/pull/27130#discussion_r2444236700
##########
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java:
##########
@@ -532,6 +532,51 @@ public class ExecutionConfigOptions {
+ "the correctness of the results.\n"
+ "ORDERED ensures that the operator emits
the result in the same order as the data enters it. This is the default.");
+ // ------------------------------------------------------------------------
+ // Async VECTOR_SEARCH Options
+ // ------------------------------------------------------------------------
+ @Documentation.TableOption(execMode =
Documentation.ExecMode.BATCH_STREAMING)
+ public static final ConfigOption<Boolean>
TABLE_EXEC_ASYNC_VECTOR_SEARCH_ASYNC =
+ key("table.exec.async-vector-search.async")
+ .booleanType()
+ .defaultValue(false)
+ .withDescription(
+ "Whether to run an async search function or not.
Default to false.");
+
+ @Documentation.TableOption(execMode =
Documentation.ExecMode.BATCH_STREAMING)
+ public static final ConfigOption<Integer>
+ TABLE_EXEC_ASYNC_VECTOR_SEARCH_MAX_CONCURRENT_OPERATIONS =
+
key("table.exec.async-vector-search.max-concurrent-operations")
+ .intType()
+ .defaultValue(10)
+ .withDescription(
+ "The max number of async i/o operation
that the async vector search can trigger.");
Review Comment:
nit: operation -> operations
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
