pyflink.table.table_environment.TableEnvironment.create_java_function#

TableEnvironment.create_java_function(path: str, function_class_name: str, ignore_if_exists: Optional[bool] = None)[source]#

Registers a java user defined function class as a catalog function in the given path.

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

There must not be another function (temporary or permanent) registered under the same path.

Example:

>>> table_env.create_java_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.
ignore_if_exists – If a function exists under the given path and this flag is set, no operation is executed. An exception is thrown otherwise.

New in version 1.12.0.