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<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/

[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 <[hidden email]> wrote:

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/

[Rad Rad]

Thanks very much.



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