risingwave_stream::executor::source

Module source_backfill_executor

Source

Structs§

BackfillStage 🔒
Local variables used in the backfill stage.
BackfillStateWithProgress
Only state field is the real state for fail-over. Other fields are for observability (but we still need to persist them).
PauseControl 🔒
SourceBackfillExecutor
SourceBackfillExecutorInner

Enums§

ApplyMutationAfterBarrier 🔒
BackfillState

Functions§

compare_kafka_offset 🔒

Type Aliases§

BackfillStates