apply_project_exprs

risingwave_stream::executor::project

Function apply_project_exprs 

Source 
pub async fn apply_project_exprs(
    exprs: &[NonStrictExpression],
    chunk: StreamChunk,
) -> StreamExecutorResult<StreamChunk>