pyflink.dataframe.convert.from_pandas#
- from_pandas(pdf: Any, schema: List[str] | None = None) 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)