flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Peter Ertl <peter.e...@gmx.net>
Subject state inside functions
Date Thu, 03 Aug 2017 10:11:14 GMT
Hi,

can someone elaborate on when I should set properties transient / non-transient within operators
(e.g. map / flatMap / reduce) ?

I see these two possibilies:

(1) initialize a non-transient property from the constructor
(2) initialize a transient property inside a Rich???Function when open(ConfigurationParameters)
is invoked

on what criteria should I choose (1) or (2) ?

how is this related to checkpointing / rebalancing?

Thanks in advance
Peter
Mime
View raw message