pyflink.dataframe.from_pandas#

from_pandas(pdf: Any, schema: Optional[List[str]] = None) → pyflink.dataframe.dataframe.DataFrame[source]#

Create a DataFrame from a Pandas DataFrame.

Parameters

pdf – The Pandas DataFrame.
schema – Optional list of column names. If None, uses pandas column names.

Returns

A new DataFrame instance.

Example::

>>> import pandas as pd
>>> import pyflink.dataframe as pf
>>> pdf = pd.DataFrame({"a": [1, 2, 3], "b": ["x", "y", "z"]})
>>> df = pf.from_pandas(pdf)