risingwave_stream::executor::temporal_join

Function align_input

source 
pub(super) fn align_input<const YIELD_RIGHT_CHUNKS: bool>(
    left: Executor,
    right: Executor,
) -> impl Stream<Item = Result<InternalMessage, StreamExecutorError>>