risingwave_pb::stream_service

Type Alias PbBarrierCompleteResponse

Source 
pub type PbBarrierCompleteResponse = BarrierCompleteResponse;

Aliased Type§

pub struct PbBarrierCompleteResponse {
    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>,
}

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>