risingwave_compaction_test::compaction_test_runner

Function start_replay

Source 
async fn start_replay(
    opts: CompactionTestOpts,
    table_to_check: u32,
    version_delta_logs: Vec<HummockVersionDelta>,
) -> Result<()>