[jira] [Created] (FLINK-38140) Change name from table.exec.async-scalar.buffer-capacity to max-concurrent-operations

Alan Sheinberg created FLINK-38140: -- Summary: Change name from table.exec.async-scalar.buffer-capacity to max-concurrent-operations Key: FLINK-38140 URL: https://issues.apache.org/jira/browse/FLINK-38140

[jira] [Created] (FLINK-37989) Add condition support

Alan Sheinberg created FLINK-37989: -- Summary: Add condition support Key: FLINK-37989 URL: https://issues.apache.org/jira/browse/FLINK-37989 Project: Flink Issue Type: Sub-task Re

[jira] [Created] (FLINK-37988) Add left join support

Alan Sheinberg created FLINK-37988: -- Summary: Add left join support Key: FLINK-37988 URL: https://issues.apache.org/jira/browse/FLINK-37988 Project: Flink Issue Type: Sub-task Re

[jira] [Created] (FLINK-37927) Add batch mode support for AsyncTableFunction

Alan Sheinberg created FLINK-37927: -- Summary: Add batch mode support for AsyncTableFunction Key: FLINK-37927 URL: https://issues.apache.org/jira/browse/FLINK-37927 Project: Flink Issue Type:

[jira] [Created] (FLINK-37865) Add documentation for AsyncTableFunction

Alan Sheinberg created FLINK-37865: -- Summary: Add documentation for AsyncTableFunction Key: FLINK-37865 URL: https://issues.apache.org/jira/browse/FLINK-37865 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-37817) Add Bundled Aggregate API and operator for group by

Alan Sheinberg created FLINK-37817: -- Summary: Add Bundled Aggregate API and operator for group by Key: FLINK-37817 URL: https://issues.apache.org/jira/browse/FLINK-37817 Project: Flink Issue

[jira] [Created] (FLINK-37816) FLIP-491: BundledAggregateFunction for batched aggregation

Alan Sheinberg created FLINK-37816: -- Summary: FLIP-491: BundledAggregateFunction for batched aggregation Key: FLINK-37816 URL: https://issues.apache.org/jira/browse/FLINK-37816 Project: Flink

[jira] [Created] (FLINK-37725) Share PythonCorrelateSplitRule with Async Scalar

Alan Sheinberg created FLINK-37725: -- Summary: Share PythonCorrelateSplitRule with Async Scalar Key: FLINK-37725 URL: https://issues.apache.org/jira/browse/FLINK-37725 Project: Flink Issue Ty

[jira] [Created] (FLINK-37724) Add AsyncTableFunction as new UDF type

Alan Sheinberg created FLINK-37724: -- Summary: Add AsyncTableFunction as new UDF type Key: FLINK-37724 URL: https://issues.apache.org/jira/browse/FLINK-37724 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-37723) FLIP-498: AsyncTableFunction for async table function support

Alan Sheinberg created FLINK-37723: -- Summary: FLIP-498: AsyncTableFunction for async table function support Key: FLINK-37723 URL: https://issues.apache.org/jira/browse/FLINK-37723 Project: Flink

[jira] [Created] (FLINK-37721) Fix Janino Bug which resulted in

Alan Sheinberg created FLINK-37721: -- Summary: Fix Janino Bug which resulted in Key: FLINK-37721 URL: https://issues.apache.org/jira/browse/FLINK-37721 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37243) Ensure that async callbacks happen on known thread

Alan Sheinberg created FLINK-37243: -- Summary: Ensure that async callbacks happen on known thread Key: FLINK-37243 URL: https://issues.apache.org/jira/browse/FLINK-37243 Project: Flink Issue

[jira] [Created] (FLINK-36472) Correlates with UDTF don't handle right-side conditions or projections

Alan Sheinberg created FLINK-36472: -- Summary: Correlates with UDTF don't handle right-side conditions or projections Key: FLINK-36472 URL: https://issues.apache.org/jira/browse/FLINK-36472 Project: F

[jira] [Created] (FLINK-35716) Fix use of AsyncScalarFunction in join conditions

Alan Sheinberg created FLINK-35716: -- Summary: Fix use of AsyncScalarFunction in join conditions Key: FLINK-35716 URL: https://issues.apache.org/jira/browse/FLINK-35716 Project: Flink Issue T

[jira] [Created] (FLINK-35403) FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding

Alan Sheinberg created FLINK-35403: -- Summary: FLIP-452: Allow Skipping Invocation of Function Calls While Constant-folding Key: FLINK-35403 URL: https://issues.apache.org/jira/browse/FLINK-35403 Proj

[jira] [Created] (FLINK-34027) Create initial PR for FLIP-400

Alan Sheinberg created FLINK-34027: -- Summary: Create initial PR for FLIP-400 Key: FLINK-34027 URL: https://issues.apache.org/jira/browse/FLINK-34027 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34028) Allow multiple parallel async calls in a single operator

Alan Sheinberg created FLINK-34028: -- Summary: Allow multiple parallel async calls in a single operator Key: FLINK-34028 URL: https://issues.apache.org/jira/browse/FLINK-34028 Project: Flink

[jira] [Created] (FLINK-33978) FLIP-400: AsyncScalarFunction for asynchronous scalar function support

Alan Sheinberg created FLINK-33978: -- Summary: FLIP-400: AsyncScalarFunction for asynchronous scalar function support Key: FLINK-33978 URL: https://issues.apache.org/jira/browse/FLINK-33978 Project: F