flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Emmanuel <ele...@msn.com>
Subject Window stream using timestamp key for time
Date Thu, 28 Jan 2016 22:08:48 GMT
Hello,
I have used Flink to stream data and do analytics on the stream, using time windows...
Now, this is assuming the data is effectively coming in real time. However I have a use case
where the data is 'batched' upstream, and comes in bursts, but has a timestamp.It obviously
messes up the windowed stream assumption. (note it is a problem with queuing in Kafka for
example when there is any kind of downtime downstream of Kafka: if data accumulates and then
is consumed, it is consumed at higher 'speed' than real clock time and statistics do not match
reality.)
So my question is:
Is it possible to use a window stream based on a timestamp key for time, as opposed to clock
time?
How would one do this with the current API?
ThanksEmmanuel 		 	   		  
Mime
View raw message