Hi Dian !
Thx a lot for your reply, it's very helpful for us.
чт, 15 окт. 2020 г. в 04:30, Dian Fu :
> Hi Rinat,
>
> It's called in single thread fashion and so there is no need for the
> synchronization.
>
> Besides, there is a pair of open/close methods in the ScalarFunction and
> you could
Hi Rinat,
It's called in single thread fashion and so there is no need for the
synchronization.
Besides, there is a pair of open/close methods in the ScalarFunction and you
could also override them and perform the initialization work in the open method.
Regards,
Dian
> 在
Hi mates !
I keep moving in my research of new features of PyFlink and I'm really
excited about that functionality.
My main goal is to understand how to integrate our ML registry, powered by
ML Flow and PyFlink jobs and what restrictions we have.
I need to bootstrap the UDF function on it's
