/// Store the write or delete in the in memory buffer. Deletes will
/// be written into the catalog before getting stored in the buffer.
/// Any writes that create new IOx partitions will have those records
/// created in the catalog before putting into the buffer. Writes will
/// get logged in the lifecycle manager. If it indicates ingest should
/// be paused, this function will return true.
Store the write or delete in the in memory buffer. Deletes will
be written into the catalog before getting stored in the buffer.
Any writes that create new IOx partitions will have those records
created in the catalog before putting into the buffer. Writes will
get logged in the lifecycle manager. If it indicates ingest should
be paused, this function will return true.
Store the write or delete in the in memory buffer . Deletes will be written into the catalog before getting stored in the buffer . Any writes that create new IOx partitions will have those records created in the catalog before putting into the buffer . Writes will get logged in the lifecycle manager . If it indicates ingest should be paused this function will return true .
pub async fn buffer_operation(
        &self,
        sequencer_id: SequencerId,
        dml_operation: DmlOperation,
        lifecycle_handle: &dyn LifecycleHandle,
    ) -> Result<bool> {
        let sequencer_data = self
            .sequencers
            .get(&sequencer_id)
            .context(SequencerNotFoundSnafu { sequencer_id })?;
        sequencer_data
            .buffer_operation(
                dml_operation,
                sequencer_id,
                self.catalog.as_ref(),
                lifecycle_handle,
                self.partitioner.as_ref(),
                &self.exec,
            )
            .await
    }
pub async fn buffer_operation ( & self , sequencer_id : SequencerId , dml_operation : DmlOperation , lifecycle_handle : & dyn LifecycleHandle , ) -> Result < bool > { let sequencer_data = self . sequencers . get ( & sequencer_id ) . context ( SequencerNotFoundSnafu { sequencer_id } ) ? ; sequencer_data . buffer_operation ( dml_operation , sequencer_id , self . catalog . as_ref ( ) , lifecycle_handle , self . partitioner . as_ref ( ) , & self . exec , ) . await }
Store the write or delete in the in memory buffer.
Store the write or delete in the in memory buffer .
&self
sequencer_id
SequencerId
dml_operation
DmlOperation
lifecycle_handle
&dyn LifecycleHandle