pub async fn rollover_and_load(db: &Arc<Db>, partition_key: &str, table_name: &str) {
    db.rollover_partition(table_name, partition_key)
        .await
        .unwrap();
    db.move_chunk_to_read_buffer(table_name, partition_key, 0)
        .await
        .unwrap();
    db.persist_partition(
        table_name,
        partition_key,
        Instant::now() + Duration::from_secs(1),
    )
    .await
    .unwrap();
}
/// Rollover the mutable buffer and load chunk 0 to the read buffer and object store
Rollover the mutable buffer and load chunk 0 to the read buffer and object store
Rollover the mutable buffer and load chunk 0 to the read buffer and object store
pub async fn rollover_and_load(db: &Arc<Db>, partition_key: &str, table_name: &str) {
    db.rollover_partition(table_name, partition_key)
        .await
        .unwrap();
    db.move_chunk_to_read_buffer(table_name, partition_key, 0)
        .await
        .unwrap();
    db.persist_partition(
        table_name,
        partition_key,
        Instant::now() + Duration::from_secs(1),
    )
    .await
    .unwrap();
}
pub async fn rollover_and_load ( db : & Arc < Db > , partition_key : & str , table_name : & str ) { db . rollover_partition ( table_name , partition_key ) . await . unwrap ( ) ; db . move_chunk_to_read_buffer ( table_name , partition_key , 0 ) . await . unwrap ( ) ; db . persist_partition ( table_name , partition_key , Instant :: now ( ) + Duration :: from_secs ( 1 ) , ) . await . unwrap ( ) ; }
Rollover the mutable buffer and load chunk 0 to the read buffer and object store
Rollover the mutable buffer and load chunk 0 to the read buffer and object store
db
&Arc<Db>
partition_key
&str
table_name
&str
db
&Arc<Db>
partition_key
&str
table_name
&str