pyflink.table.table_environment.StreamTableEnvironment.create_java_temporary_function

StreamTableEnvironment.create_java_temporary_function(path: str, function_class_name: str)

Registers a java user defined function class as a temporary catalog function.

Compared to .. seealso:: create_java_temporary_system_function() with a globally defined name, catalog functions are always (implicitly or explicitly) identified by a catalog and database.

Temporary functions can shadow permanent ones. If a permanent function under a given name exists, it will be inaccessible in the current session. To make the permanent function available again one can drop the corresponding temporary function.

Example:

>>> table_env.create_java_temporary_function("func",
...     "java.user.defined.function.class.name")

Parameters

• path – The path under which the function will be registered. See also the TableEnvironment class description for the format of the path.

• function_class_name – The java full qualified class name of the function class containing the implementation. The function must have a public no-argument constructor and can be founded in current Java classloader.

New in version 1.12.0.