Module barrier_complete_response

risingwave_pb::stream_service

Module barrier_complete_response 

Source
Expand description

Nested message and enum types in BarrierCompleteResponse.

Structs§

CdcTableBackfillProgress
CreateMviewProgress
ListFinishedSource
SourceExecutor reports the source list is finished, and then meta will issue a ListFinish barrier to notify the source to start loading.
LoadFinishedSource
Used for refreshable batch source. SourceExecutor reports the source load is finished, and then meta will issue a LoadFinish barrier to notify MaterializeExecutor to start diff calculation.
LocalSstableInfo

Type Aliases§

PbCdcTableBackfillProgress
PbCreateMviewProgress
PbListFinishedSource
PbLoadFinishedSource
PbLocalSstableInfo