Seems a bit convoluted for such a simple problem. I am thinking a custom streaming count() operator will simplify. Wasn¹t able to find examples for custom Streaming operators. -roshan
On 7/21/16, 8:00 PM, "hrajaram" <hraja...@arcogent.com> wrote: >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/counti >ng-words-not-frequency-tp8099p8100.html >Sent from the Apache Flink User Mailing List archive. mailing list >archive at Nabble.com. >
