Method flush

arrow-csv/src/reader/mod.rs:657–673

Flushes the currently buffered data to a [`RecordBatch`] This should only be called after [`Self::decode`] has returned `Ok(0)`, otherwise may return an error if part way through decoding a record Returns `Ok(None)` if no buffered data

(&mut self)

    ///
    /// Returns `Ok(None)` if no buffered data
    pub fn flush(&mut self) -> Result<Option<RecordBatch>, ArrowError> {
        if self.record_decoder.is_empty() {
            return Ok(None);
        }

        let rows = self.record_decoder.flush()?;
        let batch = parse(
            &rows,
            self.schema.fields(),
            Some(self.schema.metadata.clone()),
            self.projection.as_ref(),
            self.line_number,
            &self.null_regex,
        )?;
        self.line_number += rows.len();
        Ok(Some(batch))
    }

    /// Returns the number of records that can be read before requiring a call to [`Self::flush`]
    pub fn capacity(&self) -> usize {