Hi Justin,
Flink SQL is currently not extensible enough for this task. And FLIP-440
[1] aims to change that. It will expose functionality requested by many
advanced use cases. Until this FLIP has been accepted by the community,
a solution would consist of a mixture of Flink SQL and DataStream
Hello
I wanted to bump on this (may have missed the response).
Adding a bit more color, we have some functionality that we want to
implement using (Key)ProcessFunctions but our users are primarily not
Scala/Java developers so looking for ways to provide that functionality
using something they're
