pyflink.table.table_environment.StreamTableEnvironment.register_java_function

StreamTableEnvironment.register_java_function(name: str, function_class_name: str)

Registers a java user defined function under a unique name. Replaces already existing user-defined functions under this name. The acceptable function type contains ScalarFunction, TableFunction and AggregateFunction.

Example:

>>> table_env.register_java_function("func1", "java.user.defined.function.class.name")

Parameters

• name – The name under which the function is registered.

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

Note

Deprecated in 1.12. Use create_java_temporary_system_function() instead.