pyflink.dataframe.dataframe.DataFrame.iter_rows

DataFrame.iter_rows(*, named: Literal[False] = False) → Iterator[Tuple[Any, ...]]

DataFrame.iter_rows(*, named: Literal[True]) → Iterator[Dict[str, Any]]

Return an iterator over rows of the DataFrame.

This is a terminal operation that triggers execution.

Parameters:

named – If False (default), yields tuples of values. If True, yields dictionaries {column_name: value}.

Returns:

A generator that yields rows as tuples or dicts.

Example:

>>> df = pf.from_records([(1, "a"), (2, "b")], schema=["id", "name"])
>>> for row in df.iter_rows():
...     print(row)
(1, 'a')
(2, 'b')
>>> for row in df.iter_rows(named=True):
...     print(row)
{'id': 1, 'name': 'a'}
{'id': 2, 'name': 'b'}