Function project_with_partition

pub fn project_with_partition(
    input: Arc<dyn ExecutionPlan>,
    table: &Table,
) -> Result<Arc<dyn ExecutionPlan>>

Extends an ExecutionPlan with partition value calculations for Iceberg tables.

This function takes an input ExecutionPlan and extends it with an additional column containing calculated partition values based on the table’s partition specification. For unpartitioned tables, returns the original plan unchanged.

Arguments

• input - The input ExecutionPlan to extend
• table - The Iceberg table with partition specification

Returns

• Ok(Arc<dyn ExecutionPlan>) - Extended plan with partition values column
• Err - If partition spec is not found or transformation fails