pyflink.dataframe.DataFrame.limit#
- DataFrame.limit(n: int) pyflink.dataframe.dataframe.DataFrame[source]#
Limit the DataFrame to the first n rows.
This is a lazy transformation that returns a new DataFrame.
- Parameters
n – The maximum number of rows to return. Must be non-negative.
- Returns
A new DataFrame limited to at most n rows.
- Example::
>>> df = pf.from_records([(1,), (2,), (3,)], schema=["a"]) >>> df.limit(2).collect() [Row(a=1), Row(a=2)]