Hi Piyush,
Custom triggers (or early firing) is currently not supported by SQL or the
Table API.
It is also not on the roadmap [1].
Currently, most efforts on the relational API are focused on restructuring
the code and working towards the integration of the Blink contribution [2].
AFAIK, there
Hi folks,
I’m trying to write a Flink job that computes a bunch of counters which
requires custom triggers and I was trying to figure out the best way to express
that.
The query looks something like this:
SELECT userId, customUDAF(...) AS counter1, customUDAF(...) AS counter2, ...
FROM (
