THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
As with the standard ScalarFunction, there is an eval method, but with a 0th parameter of the type CompletableFuture<String> future.
This is the primary method used to invoke the async functionality.
...
These options are scoped with the catalog, db, and function name as registered in the table environment so that any given definition can be configured. Similarly, a system function can be configured with the special prefix system, as in the last example.
The options have the following meaningsfollowing configurations will be available:
Name (Prefix table.exec.async-scalar.catalog.db.func-name) | Meaning |
|---|---|
buffer-capacity | The number of outstanding requests the operator allows at once |
timeout | The time which can pass before a restart strategy is triggered |
output-mode | Depending on whether the planner deems it possible to allow for the more performant unordered option. |
retry-strategy | FIXED_DELAY is for a retry after a fixed amount of time |
fixed-delay | The time to wait between retries for the FIXED_DELAY strategy. |
max-attempts | The maximum number of attempts while retrying. |
...