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)

from_table(table)

Create a DataFrame from a PyFlink Table.

from_pandas(pdf[, schema])

Create a DataFrame from a Pandas DataFrame.

from_dict(data[, schema])

Create a DataFrame from a dictionary of sequences.

from_records(data[, schema])

Create a DataFrame from a sequence of records.