appreciating our reply.
Hi,
An UDTF will be wrapped into an operator, an operator instance will be
executed by a slot (or parallelism/thread) ,
About operator, task, slot, you can refer to [1] for more details.
A TM (a JVM process) may has multiple slots, that means a JVM process may
has multiple UDTF instances.
It's bet
Hi:
I always wonder how much instance has been initialized in the whole
flink application.
Suppose there is such a scenario:
I have a UDTF called '*mongo_join'* through which the flink
table can join with external different mongo table according to the
parameters passed in.