pyflink.dataframe.from_table

from_table(table: Table) → pyflink.dataframe.dataframe.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)