async fn run_direct_iteration(
object_store: ObjectStore,
file_path: String,
region_file_id: RegionFileId,
parquet_meta: ParquetMetaData,
projection: Option<Vec<usize>>,
row_groups: Vec<usize>,
sst_schema: SchemaRef,
batch_size: usize,
) -> Result<IterationStats>