flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rong Rong <walter...@gmail.com>
Subject Re: Is the eval method invoked in a thread safe manner in Fink UDF
Date Sun, 13 Jan 2019 18:16:45 GMT
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

On Sat, Jan 12, 2019 at 11:42 PM Anil <anilsingh.jsr@gmail.com> wrote:

> 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-flink-user-mailing-list-archive.2336050.n4.nabble.com/
>

Mime
View raw message