flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Meghashyam Sandeep V <vr1meghash...@gmail.com>
Subject use case for sliding windows
Date Mon, 12 Dec 2016 21:30:30 GMT
Hi There,

I have a streaming job which has source as Kafka and sink as Cassandra. I
have a use case where I wouldn't want to write some events to Cassandra
when there are more than 100 events for a given 'id' (field in my Pojo) in
5mins. Is this a good usecase for SlidingWindows? Can I get the sliding
count for each key and then decide whether to add it to sink or not?

Thanks,

Mime
View raw message