pub fn copy_buffer_to_snapshot(
        &self,
    ) -> Result<Option<Arc<SnapshotBatch>>, mutable_batch::Error> {
        if let Some(buf) = &self.buffer {
            return Ok(Some(Arc::new(SnapshotBatch {
                min_sequencer_number: buf.min_sequence_number,
                max_sequencer_number: buf.max_sequence_number,
                data: Arc::new(buf.data.to_arrow(Selection::All)?),
            })));
        }

        Ok(None)
    }
/// Returns snapshot of the buffer but keep data in the buffer
Returns snapshot of the buffer but keep data in the buffer
Returns snapshot of the buffer but keep data in the buffer
pub fn copy_buffer_to_snapshot(
        &self,
    ) -> Result<Option<Arc<SnapshotBatch>>, mutable_batch::Error> {
        if let Some(buf) = &self.buffer {
            return Ok(Some(Arc::new(SnapshotBatch {
                min_sequencer_number: buf.min_sequence_number,
                max_sequencer_number: buf.max_sequence_number,
                data: Arc::new(buf.data.to_arrow(Selection::All)?),
            })));
        }
        Ok(None)
    }
pub fn copy_buffer_to_snapshot ( & self , ) -> Result < Option < Arc < SnapshotBatch > > , mutable_batch :: Error > { if let Some ( buf ) = & self . buffer { return Ok ( Some ( Arc :: new ( SnapshotBatch { min_sequencer_number : buf . min_sequence_number , max_sequencer_number : buf . max_sequence_number , data : Arc :: new ( buf . data . to_arrow ( Selection :: All ) ? ) , } ) ) ) ; } Ok ( None ) }
Returns snapshot of the buffer but keep data in the buffer
Returns snapshot of the buffer but keep data in the buffer
&self
&self