pub fn decode_dfplan_task(
body: &str,
ctx: &TaskContext,
codec: &dyn PhysicalExtensionCodec,
) -> SqlResult<(DfplanTaskSpec, Arc<dyn ExecutionPlan>)>Expand description
Decode a dfplan:v1: fragment body into (partition spec, plan).
ctx supplies the runtime environment (object stores, UDFs) the decoded
plan executes under; it does not need the original tables registered —
scan nodes carry their own file/split descriptions in the proto.