Flink table modules

classic Classic list List threaded Threaded
4 messages Options
Reply | Threaded
Open this post in threaded view
|

Flink table modules

Flavio Pompermaier
Hi to all,
I've seen that table API provides modules. What are they exactly?
Are they basically a way to group together a set of UDF functions?
Or they can add other stuff to the table API?

Best,
Flavi
Reply | Threaded
Open this post in threaded view
|

Re: Flink table modules

Jark Wu-3
Hi Flavio,

It is a plugin mechanism for users to register a set of UDF functions, e.g. ML function, Geo functions. 

Best,
Jark


On Thu, 23 Apr 2020 at 23:12, Flavio Pompermaier <[hidden email]> wrote:
Hi to all,
I've seen that table API provides modules. What are they exactly?
Are they basically a way to group together a set of UDF functions?
Or they can add other stuff to the table API?

Best,
Flavi
Reply | Threaded
Open this post in threaded view
|

Re: Flink table modules

Danny Chan
In reply to this post by Flavio Pompermaier
> Are they basically a way to group together a set of UDF functions

You are right, each module would have a set of functions which behaves like a Flink builtin function, the functions don’t have any namespaces. When there are two objects of the same name residing in two modules, Flink always resolves the object reference to the one in the 1st loaded module. Here is the doc why we evolves this feature [1]


Best,
Danny Chan
在 2020年4月23日 +0800 PM11:12,Flavio Pompermaier <[hidden email]>,写道:

Are they basically a way to group together a set of UDF functions
Reply | Threaded
Open this post in threaded view
|

Re: Flink table modules

Flavio Pompermaier
Thank you all for the clarification and pointers! 

Il Dom 26 Apr 2020, 10:52 Danny Chan <[hidden email]> ha scritto:
> Are they basically a way to group together a set of UDF functions

You are right, each module would have a set of functions which behaves like a Flink builtin function, the functions don’t have any namespaces. When there are two objects of the same name residing in two modules, Flink always resolves the object reference to the one in the 1st loaded module. Here is the doc why we evolves this feature [1]


Best,
Danny Chan
在 2020年4月23日 +0800 PM11:12,Flavio Pompermaier <[hidden email]>,写道:

Are they basically a way to group together a set of UDF functions