flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timo Walther <twal...@apache.org>
Subject Re: Use case
Date Thu, 28 Jul 2016 15:18:11 GMT
Hi Kevin,

I don't know what your entire program is doing but wouldn't be a 
FlatMapFunction containing a state with your biggest value sufficient? 
Your stream goes through your FlatMapper and compares with the last 
saved biggest value. You can then emit something if the value has increased.

I hope that helps.


Am 28/07/16 um 17:00 schrieb Kevin Jacobs:
> Hi all,
> I am trying to keep track of the biggest value in a stream. I do this 
> by using the iterative step mechanism of Apache Flink. However, I get 
> an exception that checkpointing is not supported for iterative jobs. 
> Why can't this be enabled? My iterative stream is also quite small: 
> only one value. Is there a better way to keep track of a largest value 
> in a stream?
> Regards,
> Kevin

Freundliche Grüße / Kind Regards

Timo Walther

Follow me: @twalthr

View raw message