I just want to add another workaround, which does not need a
self-compiled version. You can use TimeWindow with a CountTriger.of(1)
combined with a FoldFunction for pre-aggregration and a
RichWindowFunction to update the queryable state. Additionally, you need
a TimeWindow for the final results. So
This is not possible at the moment. We discussed this a couple of
times before, but in the end did not want to expose it with the
initial version, because the interfaces are still very raw. This is
definitely on the agenda though.
As a work around you would have to build a custom Flink version wit
>From what I've read in the documentation, and from the examples I've seen, in
>order to make state queryable externally to Flink, the state descriptor
>variables need access to the Flink runtime context.
This means the stream processor has to have access to the 'Rich' level objects
- 'RichFla
