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.
Regards,
Timo
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
that.
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 :)
Regards,
Timo
[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?
Best,
Stefano
--
Liu, Renjie
Software Engineer, MVAD
