Re: Towards a spec for robust streaming SQL, Part 2

2017-07-30 Thread Shaoxuan Wang
Hi Tyler, Thanks for putting all the efforts into a doc. It is really well written and organized. I like the most part. The major concern I have is about the "explicit trigger". I left a few comments towards this and would like to know what the others think about it. Regards, Shaoxuan On Sun,

Re: Towards a spec for robust streaming SQL, Part 1

2017-05-12 Thread Shaoxuan Wang
(which should be many :-). > > Shaoxuan, can you please refresh my memory what a dynamic table means in > Flink? It's basically just a state table, right? The "dynamic" part of the > name is to simply to imply it can evolve and change over time? > > -Tyler > >

Re: Towards a spec for robust streaming SQL, Part 1

2017-05-12 Thread Shaoxuan Wang
Thanks to Tyler and Fabian for sharing your thoughts. Regarding to the early/late update control of FLINK. IMO, each dynamic table can have an EMIT config. For FLINK table-API, this can be easily implemented in different manners, case by case. For instance, in window aggregate, we could define