Re: ListCheckpointed function - what happens prior to restoreState() being called?

2018-03-22 Thread Fabian Hueske
Hi Ken, ListCheckpointed.restoreState() is part of the operator state initialization, but you are right that it is not explicitly mentioned in the docs. That documentation page is rather about the internals and does not directly like to public API. I think you can also initialize the variable in

Re: ListCheckpointed function - what happens prior to restoreState() being called?

2018-03-21 Thread Ken Krugler
Hi Fabian, > On Mar 20, 2018, at 6:38 AM, Fabian Hueske wrote: > > Hi Ken, > > The documentation page describes that first the state is restored / > initialized and then the function's open() method is called [1]. Yes, thanks - my question was about

ListCheckpointed function - what happens prior to restoreState() being called?

2018-03-19 Thread Ken Krugler
Hi all, If I implement ListCheckpointed in a function, is there a guarantee that open() is called before restoreState()? Asking because it doesn’t seem to be the case, and I didn’t notice this being described here: