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