Re: [PR] [FLIP 400] Introduces AsyncScalarFunction as a new UDF type [flink]

2024-01-03 Thread via GitHub
AlanConfluent commented on code in PR #23975: URL: https://github.com/apache/flink/pull/23975#discussion_r1440888375 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/AsyncCalcSyncModeRule.java: ## @@ -0,0 +1,146 @@ +/* + *

Re: [PR] [FLIP 400] Introduces AsyncScalarFunction as a new UDF type [flink]

2023-12-20 Thread via GitHub
AlanConfluent commented on code in PR #23975: URL: https://github.com/apache/flink/pull/23975#discussion_r1433297124 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/AsyncCalcSyncModeRule.java: ## @@ -0,0 +1,146 @@ +/* + *

Re: [PR] [FLIP 400] Introduces AsyncScalarFunction as a new UDF type [flink]

2023-12-20 Thread via GitHub
flinkbot commented on PR #23975: URL: https://github.com/apache/flink/pull/23975#issuecomment-1865305626 ## CI report: * 0a5a00a39da8ce1ab4db47295b49251fa8d1c631 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLIP 400] Introduces AsyncScalarFunction as a new UDF type [flink]

2023-12-20 Thread via GitHub
AlanConfluent commented on code in PR #23975: URL: https://github.com/apache/flink/pull/23975#discussion_r1433296125 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/trait/AsyncOperatorModeTrait.java: ## @@ -0,0 +1,47 @@ +package

[PR] [FLIP 400] Introduces AsyncScalarFunction as a new UDF type [flink]

2023-12-20 Thread via GitHub
AlanConfluent opened a new pull request, #23975: URL: https://github.com/apache/flink/pull/23975 ## What is the purpose of the change This introduces `AsyncScalarFunction` a new UDF type which allows asynchronous responses. The functionality here is covered in FLIP-400: