pub async fn write<E>(&mut self, row_group: RowGroupIter<'_, E>) -> Result<()>
    where
        Error: From<E>,
        E: std::error::Error,
    {
        if self.offset == 0 {
            self.start().await?;
        }
        let (group, _specs, size) = write_row_group_async(
            &mut self.writer,
            self.offset,
            self.schema.columns(),
            row_group,
        )
        .await?;
        self.offset += size;
        self.row_groups.push(group);
        Ok(())
    }
/// Writes a row group to the file.
Writes a row group to the file.
Writes a row group to the file .
pub async fn write<E>(&mut self, row_group: RowGroupIter<'_, E>) -> Result<()>
    where
        Error: From<E>,
        E: std::error::Error,
    {
        if self.offset == 0 {
            self.start().await?;
        }
        let (group, _specs, size) = write_row_group_async(
            &mut self.writer,
            self.offset,
            self.schema.columns(),
            row_group,
        )
        .await?;
        self.offset += size;
        self.row_groups.push(group);
        Ok(())
    }
pub async fn write < E > ( & mut self , row_group : RowGroupIter < ' _ , E > ) -> Result < ( ) > where Error : From < E > , E : std :: error :: Error , { if self . offset == 0 { self . start ( ) . await ? ; } let ( group , _specs , size ) = write_row_group_async ( & mut self . writer , self . offset , self . schema . columns ( ) , row_group , ) . await ? ; self . offset += size ; self . row_groups . push ( group ) ; Ok ( ( ) ) }
Writes a row group to the file.
Writes a row group to the file .
&mut self
row_group
RowGroupIter<'_, E>