Liu Liu created FLINK-40471:
-------------------------------
Summary: Add per-UDF concurrency and batch size support
Key: FLINK-40471
URL: https://issues.apache.org/jira/browse/FLINK-40471
Project: Flink
Issue Type: Sub-task
Reporter: Liu Liu
Support specifying per-UDF concurrency and batch size in UDF creation:
{code:java}
def udf(
func=None,
*,
return_dtype: DataType = None,
deterministic: bool = True,
name: str = None,
concurrency: Optional[int] = None, // per-UDF concurrency
batch_size: Optional[int] = None, // per-UDF batch size
) -> DataFrameUDFWrapper {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
