risingwave_stream::executor::lookup::sides

Function stream_lookup_arrange_this_epoch

source 
pub fn stream_lookup_arrange_this_epoch(
    stream: Executor,
    arrangement: Executor,
) -> impl Stream<Item = Result<ArrangeMessage, StreamExecutorError>>
Expand description

Join the stream with the current state of the arrangement.

For example, the executor will receive the following message sequence from stream_lookup_arrange_this_epoch:

  • [Msg] Barrier (prev = [1], current = [2])
  • [Msg] Arrangement (batch)
  • [Do] update cache with epoch [2]
  • [Msg] Stream (key = a)
  • [Do] lookup a in arrangement of epoch [2] (current epoch)
  • Barrier (prev = [2], current = [3])