pyflink.table.table_environment.StreamTableEnvironment.load_module

StreamTableEnvironment.load_module(module_name: str, module: pyflink.table.module.Module)

Loads a Module under a unique name. Modules will be kept in the loaded order. ValidationException is thrown when there is already a module with the same name.

Parameters

• module_name – Name of the Module.

• module – The module instance.

New in version 1.12.0.