Skip to main content

is_dfplan_body

Function is_dfplan_body 

Source
pub fn is_dfplan_body(body: &str) -> bool
Expand description

True when a task-fragment body carries a proto-encoded physical plan.

Tolerates a leading Python-UDF registration directive (a staged Python-UDF fragment prepends one ahead of its dfplan: body), so the coordinator’s shuffle-input wiring and AQE analysis classify it correctly.