risingwave_stream::executor::join

Function forward_exactly_once

source
pub const fn forward_exactly_once(join_type: u8, side_type: u8) -> bool
Expand description

Send the update only once if the join type is semi/anti and the update is the same side as the join