pyflink.table.table_environment.TableEnvironment.from_table_source

TableEnvironment.from_table_source(table_source: TableSource) → Table

Creates a table from a table source.

Example:

>>> csv_table_source = CsvTableSource(
...     csv_file_path, ['a', 'b'], [DataTypes.STRING(), DataTypes.BIGINT()])
>>> table_env.from_table_source(csv_table_source)

Parameters:

table_source – The table source used as table.

Returns:

The result table.