Can't you use a KeyedStream, I mean keyBy with the sameKey? something like this, source.flatMap(new Tokenizer()).keyBy(0).sum(2).project(2).print();
Assuming tokenizer is giving Tuple3<String,String,Integer> 1-> is always the same key, say "test" 2->the actual word 3-> 1 There might be some other good choices but this is the first thing that quickly came in my mind :-) Hari -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/counting-words-not-frequency-tp8099p8100.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
