pyflink.table.table_environment.StreamTableEnvironment.from_table_source

StreamTableEnvironment.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.