pyflink.table.Table.to_pandas

Table.to_pandas()

Converts the table to a pandas DataFrame. It will collect the content of the table to the client side and so please make sure that the content of the table could fit in memory before calling this method.

Example:

>>> pdf = pd.DataFrame(np.random.rand(1000, 2))
>>> table = table_env.from_pandas(pdf, ["a", "b"])
>>> table.filter(col('a') > 0.5).to_pandas()

Returns

the result pandas DataFrame.

New in version 1.11.0.