Skip to main content

Module stream

risingwave_stream::executor::backfill::snapshot_backfill::consume_upstream

Module stream 

Source

Modules§

upstream_table_ext 🔒

Structs§

ConsumeUpstreamStream 🔒

Enums§

ConsumeUpstreamStreamState 🔒

Functions§

is_retention_or_snapshot_expired_error 🔒
log_retention_or_snapshot_expired 🔒