Module utils

Functions

add_sort_above

This utility function adds a SortExec above an operator according to the given ordering requirements while preserving the original partitioning.

add_sort_above_with_check

This utility function adds a SortExec above an operator according to the given ordering requirements while preserving the original partitioning. If requirement is already satisfied no SortExec is added.

is_coalesce_partitions

Checks whether the given operator is a CoalescePartitionsExec.

is_limit

Checks whether the given operator is a limit; i.e. either a LocalLimitExec or a GlobalLimitExec.

is_repartition

Checks whether the given operator is a RepartitionExec.

is_sort

Checks whether the given operator is a SortExec.

is_sort_preserving_merge

Checks whether the given operator is a SortPreservingMergeExec.

is_union

Checks whether the given operator is a UnionExec.

is_window

Checks whether the given operator is a window; i.e. either a WindowAggExec or a BoundedWindowAggExec.