Thanks Rong!. The UDF makes a http call to another service synchronously.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
According to the codegen result, I think each field is invoked
sequentially.
However, if you maintain internal state within your UDF, it is your
responsibility to maintain the internal state consistency.
Are you invoking external RPC in your "GetName" UDF method and that has to
be async?
--
Rong
Thanks Hequn!. Is it also thread safe when the same UDF is called multiple
times in the same record.
Is the UDF called sequentially for each fields a single record, I have a
query like -
select GetName(data.id, 'city'), GetName(data.id, 'zone') from ..
--
Sent from: http://apache-f
in a thread safe manner in Fink UDF.
>
>
>
> --
> Sent from:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
>
Is the eval method invoked in a thread safe manner in Fink UDF.
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/