pub type PbBarrierCompleteResponse = BarrierCompleteResponse;Aliased Type§
pub struct PbBarrierCompleteResponse {Show 16 fields
pub request_id: String,
pub status: Option<Status>,
pub create_mview_progress: Vec<CreateMviewProgress>,
pub synced_sstables: Vec<LocalSstableInfo>,
pub worker_id: TypedId<7>,
pub table_watermarks: HashMap<TypedId<1>, TableWatermarks>,
pub old_value_sstables: Vec<SstableInfo>,
pub partial_graph_id: u32,
pub epoch: u64,
pub database_id: TypedId<3>,
pub load_finished_sources: Vec<LoadFinishedSource>,
pub vector_index_adds: HashMap<TypedId<1>, VectorIndexAdds>,
pub cdc_table_backfill_progress: Vec<CdcTableBackfillProgress>,
pub truncate_tables: Vec<TypedId<1>>,
pub refresh_finished_tables: Vec<TypedId<1>>,
pub list_finished_sources: Vec<ListFinishedSource>,
}Fields§
§request_id: String§status: Option<Status>§create_mview_progress: Vec<CreateMviewProgress>§synced_sstables: Vec<LocalSstableInfo>§worker_id: TypedId<7>§table_watermarks: HashMap<TypedId<1>, TableWatermarks>§old_value_sstables: Vec<SstableInfo>§partial_graph_id: u32§epoch: u64prev_epoch of barrier
database_id: TypedId<3>§load_finished_sources: Vec<LoadFinishedSource>§vector_index_adds: HashMap<TypedId<1>, VectorIndexAdds>§cdc_table_backfill_progress: Vec<CdcTableBackfillProgress>§truncate_tables: Vec<TypedId<1>>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<TypedId<1>>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.
list_finished_sources: Vec<ListFinishedSource>