Re: StreamSQL queriable state

2018-03-08 Thread Renjie Liu
ery to the state, of course). > > My2c. > > Best, > Stefano > > -Original Message- > From: Renjie Liu [mailto:liurenjie2...@gmail.com] > Sent: Monday, March 05, 2018 3:52 AM > To: dev@flink.apache.org > Subject: Re: StreamSQL queriable state > > Hi, Timo

Re: StreamSQL queriable state

2018-03-08 Thread Fabian Hueske
iginal Message- > From: Renjie Liu [mailto:liurenjie2...@gmail.com] > Sent: Monday, March 05, 2018 3:52 AM > To: dev@flink.apache.org > Subject: Re: StreamSQL queriable state > > Hi, Timo: > I've read your QueryableStateTableSink implementation and that basically > im

RE: StreamSQL queriable state

2018-03-08 Thread Stefano Bortoli
ubject: Re: StreamSQL queriable state Hi, Timo: I've read your QueryableStateTableSink implementation and that basically implementes what I want to do. I also want to extend SQL client so that user can do point query against the table sink. Do we still need a design doc for that? It seems t

Re: StreamSQL queriable state

2018-03-05 Thread Renjie Liu
> create the hook for the queriable state in the operator. Perhaps extend > the > >> current codegen and operator implementations to get as a parameter the > >> StateDescriptor to be inquired. > >> > >> Looking forward for the design document, will be happy to give

Re: StreamSQL queriable state

2018-03-05 Thread Timo Walther
Descriptor to be inquired. Looking forward for the design document, will be happy to give you feedback. Best, Stefano -Original Message- From: Renjie Liu [mailto:liurenjie2...@gmail.com] Sent: Friday, March 02, 2018 11:42 AM To: dev@flink.apache.org Subject: Re: StreamSQL queriable stat

Re: StreamSQL queriable state

2018-03-04 Thread Renjie Liu
to get as a parameter the > StateDescriptor to be inquired. > > Looking forward for the design document, will be happy to give you > feedback. > > Best, > Stefano > > -Original Message- > From: Renjie Liu [mailto:liurenjie2...@gmail.com] > Sent: Friday, March 02

RE: StreamSQL queriable state

2018-03-02 Thread Stefano Bortoli
the design document, will be happy to give you feedback. Best, Stefano -Original Message- From: Renjie Liu [mailto:liurenjie2...@gmail.com] Sent: Friday, March 02, 2018 11:42 AM To: dev@flink.apache.org Subject: Re: StreamSQL queriable state Great, thank you. I'll start by writi

Re: StreamSQL queriable state

2018-03-02 Thread Renjie Liu
Great, thank you. I'll start by writing a design doc. On Fri, Mar 2, 2018 at 6:40 PM Timo Walther wrote: > I gave you contributor permissions in Jira. You should be able to assign > it to yourself now. > > Am 3/2/18 um 11:33 AM schrieb Renjie Liu: > > Hi, Timo: > > It seems that I can't assign i

Re: StreamSQL queriable state

2018-03-02 Thread Timo Walther
I gave you contributor permissions in Jira. You should be able to assign it to yourself now. Am 3/2/18 um 11:33 AM schrieb Renjie Liu: Hi, Timo: It seems that I can't assign it to myself. Could you please help to assign that to me? My jira username is liurenjie1024 and my email is liurenjie2...

Re: StreamSQL queriable state

2018-03-02 Thread Renjie Liu
Hi, Timo: It seems that I can't assign it to myself. Could you please help to assign that to me? My jira username is liurenjie1024 and my email is liurenjie2...@gmail.com On Fri, Mar 2, 2018 at 6:24 PM Timo Walther wrote: > Hi Renjie, > > that would be great. There is already a Jira issue for it

Re: StreamSQL queriable state

2018-03-02 Thread Timo Walther
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 su

Re: StreamSQL queriable state

2018-03-02 Thread 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 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 becaus

Re: StreamSQL queriable state

2018-03-02 Thread Timo Walther
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/

StreamSQL queriable state

2018-03-02 Thread 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 t