DataFrame Creation#
Functions to create a DataFrame from various data sources
such as Python dictionaries, lists of records, pandas DataFrames, or existing PyFlink Tables.
Example:
>>> import pyflink.dataframe as pf
>>> df = pf.from_dict({"name": ["Alice", "Bob"], "age": [25, 30]})
>>> df = pf.from_pandas(pandas_df)
>>> df = pf.from_table(flink_table)
|
Create a DataFrame from a PyFlink Table. |
|
Create a DataFrame from a Pandas DataFrame. |
|
Create a DataFrame from a dictionary of sequences. |
|
Create a DataFrame from a sequence of records. |