You mean you want to output some data when you know that you don’t have any
counts for a given time window?
This is not (easily) possible in Flink right now because this would require an
operation with parallelism one that determines that there is no data across all
keys.
Best,
Aljoscha
> On
Hi,
I am trying to implement a flink job which takes the twitter as the source
and collects tweets from a list of hashtags. The flink job basically
aggregates the volume of tweets per hashtag in a given time frame. I have
implemented them successfully, but then if there is no tweet across all the
