Re: StreamSQL queriable state

2018-03-08 Thread Renjie Liu
(besides the query 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 queriabl

Re: StreamSQL queriable state

2018-03-08 Thread Fabian Hueske
; 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: > I've read your QueryableStateTableSink implementation and tha

RE: StreamSQL queriable state

2018-03-08 Thread Stefano Bortoli
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 writing a design doc. > > On Fri, Mar 2, 2018 at 6:40 PM Timo Walther <twal...

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 b

Re: StreamSQL queriable state

2018-03-05 Thread Timo Walther
t 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, 2018 11:42 AM To: dev@flink.apache.org Subject: Re: Str

Re: StreamSQL queriable state

2018-03-04 Thread Renjie Liu
> 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 writing a design doc. > > On Fri, Mar 2, 2018 at 6:40 PM Timo Walther <twal...@apache.org> wrote: > > > I gave you

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 writing a

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

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

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

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

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

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]