Hi Renjie,

that would be great. There is already a Jira issue for it: https://issues.apache.org/jira/browse/FLINK-6968

Feel free to assign it to yourself. You can reuse parts of my code if you want. But maybe it would make sense to have a little design document first about what we want to support.


Am 3/2/18 um 11:10 AM schrieb Renjie Liu:
Hi, Timo, I've been planning on the same thing and would like to contribute

On Fri, Mar 2, 2018 at 6:05 PM Timo Walther <twal...@apache.org> wrote:

Hi Stefano,

yes there are plan in this direction. Actually, I already worked on such
a QueryableStateTableSink [1] in the past but never finished it because
of priority shifts. Would be great if somebody wants to contribute this
functionality :)


[1] https://github.com/twalthr/flink/tree/QueryableTableSink

Am 3/2/18 um 10:58 AM schrieb Stefano Bortoli:
Hi guys,

I am checking out the queriable state API, and it seems that most of the
tooling is already available. However, the queriable state is available
just for the streaming API, not at the StreamSQL API level. In principle,
as the flink-table is aware of the query semantic and data output type, it
should be possible to configure the query compilation to nest queriable
state in the process/window functions. Is there any plan in this direction?

Liu, Renjie
Software Engineer, MVAD

Reply via email to