Hi aitozi, 1> how will sql translated into a datastream job? The Table API and SQL leverage Apache Calcite for parsing, validation, and query optimization. After optimization, the logical plan of the job will be translated into a datastream job. The logical plan contains many different logical operators(source, sink, group-by, join...) and different operators have different datstream implementations.
2> global count distinct Yes, you can use the AllWindowedStream or the SQL above. I think SQL may be more convenience and worth a try. :-) On Thu, Jun 28, 2018 at 2:47 PM, aitozi <gjying1...@gmail.com> wrote: > Hi, all > > Thanks for your reply. > > 1. Can i ask how does the SQL like below transform to a low-level > datastream > job? > > > 2. If i implement a distinct in datastream job, and there is no keyBy > needed > advance , and we just calculate the global distinct count, Does i just can > used the AllWindowedStream or the SQL above? > > Thanks, > Aitozi > > > > > > -- > Sent from: http://apache-flink-user-mailing-list-archive.2336050. > n4.nabble.com/ >
