risingwave_stream::executor

Module union

Source

Structs§

Input 🔒
UnionExecutor
UnionExecutor merges data from multiple inputs.

Functions§

merge 🔒
Merges input streams and aligns with barriers.