pyflink.table.table_environment.TableEnvironment.register_table

TableEnvironment.register_table(name: str, table: Table)

Registers a Table under a unique name in the TableEnvironment’s catalog. Registered tables can be referenced in SQL queries.

Example:

>>> tab = table_env.from_elements([(1, 'Hi'), (2, 'Hello')], ['a', 'b'])
>>> table_env.register_table("source", tab)

Parameters:

• name – The name under which the table will be registered.

• table – The table to register.

Note

Deprecated in 1.10. Use create_temporary_view() instead.