Module scale

Macros

crit_check_in_loop 🔒

Structs

RescheduleWorkingSet

Enums

NoShuffleResolveDirection 🔒

Functions

construct_no_shuffle_downstream_traverse_query

construct_no_shuffle_traverse_query_helper 🔒

construct_no_shuffle_upstream_traverse_query

This function will construct a query using recursive cte to find no_shuffle upstream relation graph for target fragments.

resolve_no_shuffle_query 🔒

resolve_streaming_job_definition 🔒