fn remove_partition_by_columns( parted_batch: &RecordBatch, partition_by: &[(String, DataType)], ) -> Result<RecordBatch>