async fn mark_persisted(
        &self,
        table_name: &str,
        partition_key: &str,
        sequence_number: SequenceNumber,
    ) {
        if let Some(t) = self.table_data(table_name) {
            let mut t = t.write().await;
            let partition = t.partition_data.get_mut(partition_key);

            if let Some(p) = partition {
                p.data.max_persisted_sequence_number = Some(sequence_number);
                p.data.persisting = None;
                // clear the deletes kept for this persisting batch
                p.data.deletes_during_persisting.clear();
            }
        }
    }
/// Walks down the table and partition and clears the persisting batch. The sequence number is
/// the max_sequence_number for the persisted parquet file, which should be kept in the table
/// data buffer.
Walks down the table and partition and clears the persisting batch. The sequence number is
the max_sequence_number for the persisted parquet file, which should be kept in the table
data buffer.
Walks down the table and partition and clears the persisting batch . The sequence number is the max_sequence_number for the persisted parquet file which should be kept in the table data buffer .
async fn mark_persisted(
        &self,
        table_name: &str,
        partition_key: &str,
        sequence_number: SequenceNumber,
    ) {
        if let Some(t) = self.table_data(table_name) {
            let mut t = t.write().await;
            let partition = t.partition_data.get_mut(partition_key);
            if let Some(p) = partition {
                p.data.max_persisted_sequence_number = Some(sequence_number);
                p.data.persisting = None;
                // clear the deletes kept for this persisting batch
                p.data.deletes_during_persisting.clear();
            }
        }
    }
async fn mark_persisted ( & self , table_name : & str , partition_key : & str , sequence_number : SequenceNumber , ) { if let Some ( t ) = self . table_data ( table_name ) { let mut t = t . write ( ) . await ; let partition = t . partition_data . get_mut ( partition_key ) ; if let Some ( p ) = partition { p . data . max_persisted_sequence_number = Some ( sequence_number ) ; p . data . persisting = None ; // clear the deletes kept for this persisting batch p . data . deletes_during_persisting . clear ( ) ; } } }
Walks down the table and partition and clears the persisting batch.
Walks down the table and partition and clears the persisting batch .
&self
table_name
&str
partition_key
&str
sequence_number
SequenceNumber
&self
table_name
&str
partition_key
&str
sequence_number
SequenceNumber