risingwave_stream::executor::project::project_scalar

Function apply_project_exprs

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