risingwave_stream::executor

Module barrier_align

Source

Enums§

AlignedMessage

Functions§

barrier_align

Type Aliases§

AlignedMessageStreamItem

Trait Aliases§

AlignedMessageStream