risingwave_stream::executor

Module lookup_union

source

Structsยง

  • Merges data from multiple inputs with order. If order = [2, 1, 0], then it will first pipe data from the third input; after the third input gets a barrier, it will then pipe the second, and finally the first. In the future we could have more efficient implementation.