risingwave_frontend::optimizer::plan_node

Module stream_row_merge

Source

Structsยง

StreamRowMerge
StreamRowMerge is used for merging two streams with the same stream key and distribution. It will buffer the outputs from its input streams until we receive a barrier. On receiving a barrier, it will Project their outputs according to the provided lhs_mapping and rhs_mapping.