pyflink.table.Table.offset#

Table.offset(offset: int) → pyflink.table.table.Table[source]#

Limits a (possibly sorted) result from an offset position.

This method can be combined with a preceding order_by() call for a deterministic order and a subsequent fetch() call to return n rows after skipping the first o rows.

Example:

# skips the first 3 rows and returns all following rows.
>>> tab.order_by(col('name').desc).offset(3)
# skips the first 10 rows and returns the next 5 rows.
>>> tab.order_by(col('name').desc).offset(10).fetch(5)

For unbounded tables, this operation requires a subsequent fetch operation.

Parameters: offset – Number of records to skip.
Returns: The result table.