pyflink.table.Table.order_by

Table.order_by(*fields: Expression) → Table

Sorts the given Table. Similar to SQL ORDER BY. The resulting Table is sorted globally sorted across all parallel partitions.

Example:

>>> tab.order_by(col('name').desc)

For unbounded tables, this operation requires a sorting on a time attribute or a subsequent fetch operation.

Parameters:

fields – Order fields expression string.

Returns:

The result table.