risingwave_stream::executor

Module rearranged_chain

source

Structs§

  • RearrangedChainExecutor
    ChainExecutor is an executor that enables synchronization between the existing stream and newly appended executors. Currently, ChainExecutor is mainly used to implement MV on MV feature. It pipes new data of existing MVs to newly created MV only all of the old data in the existing MVs are dispatched.

Enums§