@@ -434,30 +434,10 @@ async fn table_scan(
434434
435435 if enable_data_file_path_column {
436436 table_partition_cols. push ( Field :: new ( DATA_FILE_PATH_COLUMN , DataType :: Utf8 , false ) ) ;
437- // let index = file_schema.fields().len() + table_partition_cols.len() - 1;
438- // if let Some(projection) = &mut projection {
439- // projection.push(index);
440- // }
441- // if let Some(projection_expr) = &mut projection_expr {
442- // projection_expr.push((
443- // Arc::new(Column::new(DATA_FILE_PATH_COLUMN, index)) as Arc<dyn PhysicalExpr>,
444- // DATA_FILE_PATH_COLUMN.to_owned(),
445- // ));
446- // }
447437 }
448438
449439 if enable_manifest_file_path_column {
450440 table_partition_cols. push ( Field :: new ( MANIFEST_FILE_PATH_COLUMN , DataType :: Utf8 , false ) ) ;
451- // let index = file_schema.fields().len() + table_partition_cols.len() - 1;
452- // if let Some(projection) = &mut projection {
453- // projection.push(index);
454- // }
455- // if let Some(projection_expr) = &mut projection_expr {
456- // projection_expr.push((
457- // Arc::new(Column::new(MANIFEST_FILE_PATH_COLUMN, index)) as Arc<dyn PhysicalExpr>,
458- // MANIFEST_FILE_PATH_COLUMN.to_owned(),
459- // ));
460- // }
461441 }
462442
463443 // All files have to be grouped according to their partition values. This is done by using a HashMap with the partition values as the key.
0 commit comments