pub fn process<F>(
        &mut self,
        mut block_reader: impl BlockDecoder,
        mut apply_fn: F,
    ) -> Result<(), TsmError>
    where
        F: FnMut(TableSection) -> Result<(), TsmError>,
    {
        for (i, (tag_set_pair, blocks)) in self.tag_set_fields_blocks().iter_mut().enumerate() {
            let (ts, field_cols) = map_field_columns(&mut block_reader, blocks)?;

            let col_set = TableSection {
                i,
                ts,
                field_cols,
                tag_cols: tag_set_pair.clone(),
            };
            apply_fn(col_set)?;
        }
        Ok(())
    }
// Process the MeasurementTable in sections.
//
// Each call to `process` emits a `TableSection`, which is a partial section
// of the final table. Each section contains the data for all columns
// in the table, though not all of that data will necessarily be
// materialised.
//
// `process` expects a closure to process each section.
Process the MeasurementTable in sections.
Each call to `process` emits a `TableSection`, which is a partial section
of the final table. Each section contains the data for all columns
in the table, though not all of that data will necessarily be
materialised.

`process` expects a closure to process each section.
Process the MeasurementTable in sections . Each call to ` process ` emits a ` TableSection ` which is a partial section of the final table . Each section contains the data for all columns in the table though not all of that data will necessarily be materialised . ` process ` expects a closure to process each section .
pub fn process<F>(
        &mut self,
        mut block_reader: impl BlockDecoder,
        mut apply_fn: F,
    ) -> Result<(), TsmError>
    where
        F: FnMut(TableSection) -> Result<(), TsmError>,
    {
        for (i, (tag_set_pair, blocks)) in self.tag_set_fields_blocks().iter_mut().enumerate() {
            let (ts, field_cols) = map_field_columns(&mut block_reader, blocks)?;
            let col_set = TableSection {
                i,
                ts,
                field_cols,
                tag_cols: tag_set_pair.clone(),
            };
            apply_fn(col_set)?;
        }
        Ok(())
    }
pub fn process < F > ( & mut self , mut block_reader : impl BlockDecoder , mut apply_fn : F , ) -> Result < ( ) , TsmError > where F : FnMut ( TableSection ) -> Result < ( ) , TsmError > , { for ( i , ( tag_set_pair , blocks ) ) in self . tag_set_fields_blocks ( ) . iter_mut ( ) . enumerate ( ) { let ( ts , field_cols ) = map_field_columns ( & mut block_reader , blocks ) ? ; let col_set = TableSection { i , ts , field_cols , tag_cols : tag_set_pair . clone ( ) , } ; apply_fn ( col_set ) ? ; } Ok ( ( ) ) }
Process the MeasurementTable in sections.
Process the MeasurementTable in sections .
&mut self
block_reader
impl BlockDecoder
apply_fn
F
&mut self
block_reader
impl BlockDecoder
apply_fn
F