pyflink.dataframe.from_arrow

from_arrow(table: Any, schema: Optional[List[str]] = None, watermark: Optional[Tuple[str, str]] = None) → pyflink.dataframe.dataframe.DataFrame

Create a DataFrame from a PyArrow Table.

Parameters

• table – The PyArrow Table.

• schema – Optional list of column names. If None, uses Arrow column names.

• watermark – Optional (column, expression) event-time watermark definition.

Returns

A new DataFrame instance.