DataFrame Creation#

Functions to create a DataFrame from various data sources such as Python dictionaries, lists of records, pandas DataFrames, Arrow Tables, ranges, 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_arrow(arrow_table)
>>> df = pf.from_table(flink_table)

from_table(table)

Create a DataFrame from a PyFlink Table.

from_pandas(pdf[, schema, watermark])

Create a DataFrame from a Pandas DataFrame.

from_arrow(table[, schema, watermark])

Create a DataFrame from a PyArrow Table.

from_dict(data[, schema, watermark])

Create a DataFrame from a dictionary of sequences.

from_records(data[, schema, watermark])

Create a DataFrame from a sequence of records.

range(start_or_end[, end, step])

Create a DataFrame containing a single id column over an integer range.