risingwave_stream::executor

Module merge

source

Structs§

  • BufferChunks 🔒
    A wrapper that buffers the StreamChunks from upstream until no more ready items are available. Besides, any message other than StreamChunk will trigger the buffered StreamChunks to be emitted immediately along with the message itself.
  • MergeExecutor
    MergeExecutor merges data from multiple channels. Dataflow from one channel will be stopped on barrier.
  • MergeExecutorInput 🔒
  • SelectReceivers
    A stream for merging messages from multiple upstreams.

Enums§