pub type PbBarrierCompleteResponse = BarrierCompleteResponse;Aliased Type§
pub struct PbBarrierCompleteResponse {Show 15 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>,
pub truncate_tables: Vec<u32>,
pub refresh_finished_tables: Vec<u32>,
}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: u64prev_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>§truncate_tables: Vec<u32>Used for truncating tables in storage layer. MaterializeExecutor reports the tables to truncate, and then meta will apply truncate operation in next commit epoch.
refresh_finished_tables: Vec<u32>Used for reporting materialized view refresh completion. MaterializeExecutor reports when refresh has finished, and then meta will update the table’s refresh state to Finished.