pyflink.dataframe.dataframe.DataFrame.offset

DataFrame.offset(n: int) → DataFrame

Skip the first n rows of the DataFrame.

This is a lazy transformation that returns a new DataFrame.

Parameters:

n – The number of rows to skip. Must be non-negative.

Returns:

A new DataFrame with the first n rows skipped.

Example:

>>> df = pf.from_records([(1,), (2,), (3,)], schema=["a"])
>>> df.offset(1).limit(2).collect()
[Row(a=2), Row(a=3)]