pyflink.table.table_environment.TableEnvironment.from_table_source#

TableEnvironment.from_table_source(table_source: pyflink.table.sources.TableSource) → pyflink.table.table.Table[source]#

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.