risingwave_stream::executor::mview::materialize

Function generate_output

Source 
fn generate_output(
    change_buffer: ChangeBuffer,
    data_types: Vec<DataType>,
) -> StreamExecutorResult<Option<StreamChunk>>
Expand description

Construct output StreamChunk from given buffer.