Was trying to write a simple streaming Flink program that counts the total words(not the frequency) in a fie. I was thinking on the lines of :
counts = text.flatMap(new Tokenizer()) .count(); // count() isnt part of streamin APIs (but supported for batching) Any suggestions on how to do this ? I just want a continuous count (not windowed count) -roshan
