/// Store the write or delete in the sequencer. 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.
Store the write or delete in the sequencer. 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.
Store the write or delete in the sequencer . 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 .
pub async fn buffer_operation(
        &self,
        dml_operation: DmlOperation,
        sequencer_id: SequencerId,
        catalog: &dyn Catalog,
        lifecycle_handle: &dyn LifecycleHandle,
        partitioner: &dyn Partitioner,
        executor: &Executor,
    ) -> Result<bool> {
        let namespace_data = match self.namespace(dml_operation.namespace()) {
            Some(d) => d,
            None => {
                self.insert_namespace(dml_operation.namespace(), catalog)
                    .await?
            }
        };
        namespace_data
            .buffer_operation(
                dml_operation,
                sequencer_id,
                catalog,
                lifecycle_handle,
                partitioner,
                executor,
            )
            .await
    }
pub async fn buffer_operation ( & self , dml_operation : DmlOperation , sequencer_id : SequencerId , catalog : & dyn Catalog , lifecycle_handle : & dyn LifecycleHandle , partitioner : & dyn Partitioner , executor : & Executor , ) -> Result < bool > { let namespace_data = match self . namespace ( dml_operation . namespace ( ) ) { Some ( d ) => d , None => { self . insert_namespace ( dml_operation . namespace ( ) , catalog ) . await ? } } ; namespace_data . buffer_operation ( dml_operation , sequencer_id , catalog , lifecycle_handle , partitioner , executor , ) . await }
Store the write or delete in the sequencer.
Store the write or delete in the sequencer .
&self
dml_operation
DmlOperation
sequencer_id
SequencerId
catalog
&dyn Catalog
lifecycle_handle
&dyn LifecycleHandle
partitioner
&dyn Partitioner
executor
&Executor