risingwave_stream::executor::lookup::sides

Function align_barrier

source 
pub fn align_barrier(
    left: BoxedMessageStream,
    right: BoxedMessageStream,
) -> impl Stream<Item = Result<Either<Message, Message>, StreamExecutorError>>
Expand description

A biased barrier aligner which prefers message from the right side. Barrier message will be available for both left and right side, instead of being combined.