Re: How to use 'dynamic' state

2017-03-07 Thread Steve Jerman
Thanks for your reply. It makes things much clearer for me. I think you are right - Side Inputs are probably the right way long term (I looked at the Team definition), but I think I can construct something in the mean time. Steve On Mar 7, 2017, at 6:11 AM, Aljoscha Krettek mailto:aljos...@a

Re: How to use 'dynamic' state

2017-03-07 Thread Aljoscha Krettek
Hi Steve, I think Gordon already gave a pretty good answer, I'll just try and go into the specifics a bit. You mentioned that there would be different kinds of operators required for the rules (you hinted at FlatMap and maybe a tumbling window). Do you know each of those types before starting yo

Re: How to use 'dynamic' state

2017-03-06 Thread Tzu-Li (Gordon) Tai
Hi Steve, I’ll try to provide some input for the approaches you’re currently looking into (I’ll comment on your email below): * API based stop and restart of job … ugly.  Yes, indeed ;) I think this is absolutely not necessary. * Use a co-map function with the rules alone stream and the events

How to use 'dynamic' state

2017-03-06 Thread Steve Jerman
I’ve been reading the code/user goup/SO and haven’t really found a great answer to this… so I thought I’d ask. I have a UI that allows the user to edit rules which include specific criteria for example trigger event if X many people present for over a minute. I would like to have a flink job th