Skip to main content

DispatcherBarrier

risingwave_stream::executor

Type Alias DispatcherBarrier 

Source 
pub type DispatcherBarrier = BarrierInner<()>;

Aliased Type§

pub struct DispatcherBarrier {
    pub epoch: EpochPair,
    pub mutation: (),
    pub kind: BarrierKind,
    pub tracing_context: TracingContext,
    pub iceberg_pk_index_compaction: Option<IcebergPkIndexCompactionContext>,
}

Fields§

§epoch: EpochPair§mutation: ()§kind: BarrierKind§tracing_context: TracingContext

Tracing context for the current epoch of this barrier.

§iceberg_pk_index_compaction: Option<IcebergPkIndexCompactionContext>

Implementations§