Re: Ask about counting elements per window

2018-11-03 Thread Rad Rad
Thanks very much. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Ask about counting elements per window

2018-10-31 Thread Hequn Cheng
Hi Rad, You can take a look at the group window[1] of SQL. I think it may help you. Best, Hequn [1] https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sql.html#aggregations On Thu, Nov 1, 2018 at 12:53 AM Rad Rad wrote: > Hi All, > > I have a GPS stream consumed by FlinkKafkaCons

Ask about counting elements per window

2018-10-31 Thread Rad Rad
Hi All, I have a GPS stream consumed by FlinkKafkaConsumer which contains a set of GPSs of different users. I need to count a number of users per a specific window of this stream. Could anyone help me, a part of my code is below // read data from Kafka DataStream st