Skip to main content

run_direct_iteration

Function run_direct_iteration 

Source
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>