pub(crate) async fn make_one_chunk_rub_scenario(
    partition_key: &str,
    data: &str,
) -> Vec<DbScenario> {
    // Scenario 1: One closed chunk in RUB
    let db = make_db().await.db;
    let table_names = write_lp(&db, data).await;
    for table_name in &table_names {
        db.rollover_partition(table_name, partition_key)
            .await
            .unwrap();
        db.move_chunk_to_read_buffer(table_name, partition_key, 0)
            .await
            .unwrap();
    }
    let scenario = DbScenario {
        scenario_name: "Data in read buffer".into(),
        db,
    };

    vec![scenario]
}
/// This function loads one chunk of lp data into RUB only
///
This function loads one chunk of lp data into RUB only
This function loads one chunk of lp data into RUB only
pub(crate) async fn make_one_chunk_rub_scenario(
    partition_key: &str,
    data: &str,
) -> Vec<DbScenario> {
    // Scenario 1: One closed chunk in RUB
    let db = make_db().await.db;
    let table_names = write_lp(&db, data).await;
    for table_name in &table_names {
        db.rollover_partition(table_name, partition_key)
            .await
            .unwrap();
        db.move_chunk_to_read_buffer(table_name, partition_key, 0)
            .await
            .unwrap();
    }
    let scenario = DbScenario {
        scenario_name: "Data in read buffer".into(),
        db,
    };
    vec![scenario]
}
pub ( crate ) async fn make_one_chunk_rub_scenario ( partition_key : & str , data : & str , ) -> Vec < DbScenario > { // Scenario 1: One closed chunk in RUB let db = make_db ( ) . await . db ; let table_names = write_lp ( & db , data ) . await ; for table_name in & table_names { db . rollover_partition ( table_name , partition_key ) . await . unwrap ( ) ; db . move_chunk_to_read_buffer ( table_name , partition_key , 0 ) . await . unwrap ( ) ; } let scenario = DbScenario { scenario_name : " " . into ( ) , db , } ; vec ! [ scenario ] }
This function loads one chunk of lp data into RUB only
This function loads one chunk of lp data into RUB only
partition_key
&str
data
&str
partition_key
&str
data
&str