fn pk_projection(
parquet_schema: &SchemaDescriptor,
pk_indices: &[usize],
) -> Result<(ProjectionMask, Vec<usize>), SinkError>Expand description
Builds a projection for PK root columns and maps the projected physical order back to the downstream PK order.