pyflink.table.table_environment.StreamTableEnvironment.register_table_source

StreamTableEnvironment.register_table_source(name: str, table_source: TableSource)

Registers an external TableSource in this TableEnvironment’s catalog. Registered tables can be referenced in SQL queries.

Example:

>>> table_env.register_table_source("source",
...                                 CsvTableSource("./1.csv",
...                                                ["a", "b"],
...                                                [DataTypes.INT(),
...                                                 DataTypes.STRING()]))

Parameters:

• name – The name under which the table source is registered.

• table_source – The table source to register.

Note

Deprecated in 1.10. Use execute_sql() instead.