Re: how does time-windowed join and Over-Window Aggregation implemented in flink SQL?

2017-12-14 Thread Yan Zhou [FDS Science]
Thanks for the information. Best Yan From: Xingcan Cui <xingc...@gmail.com> Date: Wednesday, December 13, 2017 at 6:02 PM To: "Yan Zhou [FDS Science]" <yz...@coupang.com> Cc: "user@flink.apache.org" <user@flink.apache.org> Subject: Re: how does time-win

Re: how does time-windowed join and Over-Window Aggregation implemented in flink SQL?

2017-12-13 Thread Xingcan Cui
Hi Yan Zhou, as you may have noticed, the SQL level stream join was not built on top of some join APIs but was implemented with the low-level CoProcessFunction (see TimeBoundedStreamInnerJoin.scala

how does time-windowed join and Over-Window Aggregation implemented in flink SQL?

2017-12-13 Thread Yan Zhou [FDS Science]
Hi, I am building a data pipeline with a lot of streaming join and over window aggregation. And flink SQL have these feature supported. However, there is no similar DataStream APIs provided(maybe there is and I didn't find them. please point out if there is). I got confused because I assume