Thanks very much.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
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
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