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.

Added in version 1.11.0.