pyflink.table.catalog.Catalog.create_function

Catalog.create_function(function_path: pyflink.table.catalog.ObjectPath, function: pyflink.table.catalog.CatalogFunction, ignore_if_exists: bool)

Create a function.

Parameters

• function_path – Path ObjectPath of the function.

• function – The function CatalogFunction to be created.

• ignore_if_exists – Flag to specify behavior if a function with the given name already exists: if set to false, it throws a FunctionAlreadyExistException, if set to true, nothing happens.

Raise

CatalogException in case of any runtime exception. FunctionAlreadyExistException if the function already exist. DatabaseNotExistException if the given database does not exist.