Ask about counting elements per window

[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 stream = env.addSource(
                                new 
FlinkKafkaConsumer09<>(parameterTool.getRequired("topic")
                                                , new 
JSONDeserializationSchema(), parameterTool.getProperties()));

                DataStream<Tuple7&lt;String, String,String, String, Float, 
Float,
Timestamp>>  gpsStream  = stream.flatMap(gpsFlatMapFunc). 


Thanks in advanced. 





--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/