pyflink.table.Table.order_by

Table.order_by(*fields: Union[str, pyflink.table.expression.Expression]) → pyflink.table.table.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.