risingwave_stream::executor::mview::materialize

Function generate_output

source 
fn generate_output(
    changes: MaterializeBuffer,
    data_types: Vec<DataType>,
) -> StreamExecutorResult<Option<StreamChunk>>
Expand description

Construct output StreamChunk from given buffer.