Ctrl+K
Logo image Logo image

Site Navigation

  • API Reference
  • Examples

Site Navigation

  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
    • TableEnvironment
    • Table
    • Data Types
    • Window
    • Expressions
    • User Defined Functions
    • Descriptors
    • StatementSet
    • Catalog
  • PyFlink DataStream
  • PyFlink Common

pyflink.table.Table.limit#

Table.limit(fetch: int, offset: int = 0) → pyflink.table.table.Table[source]#

Limits a (possibly sorted) result to the first n rows.

This method is a synonym for offset() followed by fetch().

Example:

Returns the first 3 records.

>>> tab.limit(3)

Skips the first 10 rows and returns the next 5 rows.

>>> tab.limit(5, 10)
Parameters
  • fetch – the first number of rows to fetch.

  • offset – the number of records to skip, default 0.

Returns

The result table.

previous

pyflink.table.Table.left_outer_join_lateral

next

pyflink.table.Table.map

Show Source

Created using Sphinx 4.5.0.