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 subsequentfetch()
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.