Thanks Fabian!
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi Shahar,
That's not possible at the moment. The SQL API does not provide any knobs
to control state size besides the idle state retention.
The reason is that it aims to be as accurate as possible.
In the future it might be possible to provide more information to the
system (like constraints in
I have a scenario in which i do a non-windowed group by using SQL. something
like
"Select count(*) as events, shouldTrigger(..) as shouldTrigger from source
group by sessionId"
i'm then converting to a retracted stream, filtering by "add" messages, then
further filtering by "shouldTrigger" field a