Type Alias PbBarrierCompleteResponse

Source
pub type PbBarrierCompleteResponse = BarrierCompleteResponse;

Aliased Type§

pub struct PbBarrierCompleteResponse {
Show 13 fields pub request_id: String, pub status: Option<Status>, pub create_mview_progress: Vec<CreateMviewProgress>, pub synced_sstables: Vec<LocalSstableInfo>, pub worker_id: u32, pub table_watermarks: HashMap<u32, TableWatermarks>, pub old_value_sstables: Vec<SstableInfo>, pub partial_graph_id: u32, pub epoch: u64, pub database_id: u32, pub load_finished_source_ids: Vec<u32>, pub vector_index_adds: HashMap<u32, VectorIndexAdds>, pub cdc_table_backfill_progress: Vec<CdcTableBackfillProgress>,
}

Fields§

§request_id: String§status: Option<Status>§create_mview_progress: Vec<CreateMviewProgress>§synced_sstables: Vec<LocalSstableInfo>§worker_id: u32§table_watermarks: HashMap<u32, TableWatermarks>§old_value_sstables: Vec<SstableInfo>§partial_graph_id: u32§epoch: u64

prev_epoch of barrier

§database_id: u32§load_finished_source_ids: Vec<u32>

Used for refreshable batch source. SourceExecutor reports the source load is finished, and then meta will issue a LoadFinished barrier to notify MaterializeExecutor to start diff calculation.

§vector_index_adds: HashMap<u32, VectorIndexAdds>§cdc_table_backfill_progress: Vec<CdcTableBackfillProgress>