Yes, as mentioned in the first email, what I want is something like spark
transform.
But I found that lambda function is not supported in Calcite
https://issues.apache.org/jira/browse/CALCITE-3679, so it may be hard to do the
same thing in Flink.
I'll write some customized UDF for my require
Hi
Thanks @Alexey. I think what @kui needs is quite similar to transform in
Spark, right?
Best,
Shammon
On Wed, Feb 22, 2023 at 10:12 PM Alexey Novakov
wrote:
> Xuekui, I guess you want high-order functions support in Flink SQL like
> Spark has https://spark.apache.org/docs/latest/api/sql/#tr
Xuekui, I guess you want high-order functions support in Flink SQL like
Spark has https://spark.apache.org/docs/latest/api/sql/#transform ?
Best regards,
Alexey
On Wed, Feb 22, 2023 at 10:31 AM Xuekui wrote:
> Hi Yuxia and Shammon,
>
> Thanks for your reply.
>
> The requirements is dynamic in m
