pyflink.dataframe.convert.from_table

from_table(table: Table) → DataFrame

Create a DataFrame from a PyFlink Table.

Parameters:

table – The PyFlink Table to wrap.

Returns:

A new DataFrame instance.

Example::

>>> import pyflink.dataframe as pf
>>> table = t_env.from_elements([(1, 'a')], ['id', 'name'])
>>> df = pf.from_table(table)