pub fn iter_record_batches(
        &mut self,
        buffer_size: usize,
    ) -> impl Iterator<Item = RecordBatch> + '_ {
        match self.n_chunks() {
            Ok(1) => {}
            Ok(_) => {
                self.columns = self
                    .columns
                    .iter()
                    .map(|s| s.rechunk(None).unwrap())
                    .collect();
            }
            Err(_) => {} // no data. So iterator will be empty
        }
        RecordBatchIter {
            columns: &self.columns,
            schema: Arc::new(self.schema()),
            buffer_size,
            idx: 0,
            len: self.height(),
        }
    }
/// Iterator over the rows in this DataFrame as Arrow RecordBatches.
Iterator over the rows in this DataFrame as Arrow RecordBatches.
Iterator over the rows in this DataFrame as Arrow RecordBatches .
pub fn iter_record_batches(
        &mut self,
        buffer_size: usize,
    ) -> impl Iterator<Item = RecordBatch> + '_ {
        match self.n_chunks() {
            Ok(1) => {}
            Ok(_) => {
                self.columns = self
                    .columns
                    .iter()
                    .map(|s| s.rechunk(None).unwrap())
                    .collect();
            }
            Err(_) => {} // no data. So iterator will be empty
        }
        RecordBatchIter {
            columns: &self.columns,
            schema: Arc::new(self.schema()),
            buffer_size,
            idx: 0,
            len: self.height(),
        }
    }
pub fn iter_record_batches ( & mut self , buffer_size : usize , ) -> impl Iterator < Item = RecordBatch > + ' _ { match self . n_chunks ( ) { Ok ( 1 ) => { } Ok ( _ ) => { self . columns = self . columns . iter ( ) . map ( | s | s . rechunk ( None ) . unwrap ( ) ) . collect ( ) ; } Err ( _ ) => { } // no data. So iterator will be empty } RecordBatchIter { columns : & self . columns , schema : Arc :: new ( self . schema ( ) ) , buffer_size , idx : 0 , len : self . height ( ) , } }
Iterator over the rows in this DataFrame as Arrow RecordBatches.
Iterator over the rows in this DataFrame as Arrow RecordBatches .
&mut self
buffer_size
usize
&mut self
buffer_size
usize