/// Build a chunk that may move with lifecycle before/after deletes. Note that the only chunk in
/// this function can be moved to different stages, and delete predicates can be applied at
/// different stages when the chunk is moved.
Build a chunk that may move with lifecycle before/after deletes. Note that the only chunk in
this function can be moved to different stages, and delete predicates can be applied at
different stages when the chunk is moved.
Build a chunk that may move with lifecycle before / after deletes . Note that the only chunk in this function can be moved to different stages and delete predicates can be applied at different stages when the chunk is moved .
async fn make_chunk_with_deletes_at_different_stages(
    lp_lines: Vec<&str>,
    chunk_stage: ChunkStage,
    preds: Vec<Pred<'_>>,
    delete_table_name: Option<&str>,
    partition_key: &str,
) -> DbScenario {
    let chunk_data = ChunkData {
        lp_lines,
        chunk_stage: Some(chunk_stage),
        preds,
        delete_table_name,
        partition_key,
    };
    let mut mock_ingester = MockIngester::new().await;
    let scenario_name = make_chunk(&mut mock_ingester, chunk_data).await;
    let db = mock_ingester.into_query_namespace().await;
    DbScenario { scenario_name, db }
}
async fn make_chunk_with_deletes_at_different_stages ( lp_lines : Vec < & str > , chunk_stage : ChunkStage , preds : Vec < Pred < ' _ > > , delete_table_name : Option < & str > , partition_key : & str , ) -> DbScenario { let chunk_data = ChunkData { lp_lines , chunk_stage : Some ( chunk_stage ) , preds , delete_table_name , partition_key , } ; let mut mock_ingester = MockIngester :: new ( ) . await ; let scenario_name = make_chunk ( & mut mock_ingester , chunk_data ) . await ; let db = mock_ingester . into_query_namespace ( ) . await ; DbScenario { scenario_name , db } }
Build a chunk that may move with lifecycle before/after deletes.
Build a chunk that may move with lifecycle before / after deletes .
lp_lines
Vec<&str>
chunk_stage
ChunkStage
preds
Vec<Pred<'_>>
delete_table_name
Option<&str>
partition_key
&str