Skip to main content

dfplan_body_with_spec

krishiv_sql::distributed_plan

Function dfplan_body_with_spec 

Source 
pub fn dfplan_body_with_spec(
    body: &str,
    spec: &DfplanTaskSpec,
) -> SqlResult<String>
Expand description

Rewrite an existing dfplan body to a new partition spec, preserving the encoded plan bytes verbatim (no proto decode — coordinator-side AQE rewrites reuse the b64 payload untouched).