Skip to main content

Module project_scalar

risingwave_stream::executor::project

Module project_scalar 

Source

Structs§

Inner 🔒
ProjectExecutor
ProjectExecutor project data with the expr. The expr takes a chunk of data, and returns a new data chunk. And then, ProjectExecutor will insert, delete or update element into next operator according to the result of the expression.

Enums§

ProjectMessageInput 🔒
ProjectedMessage 🔒

Functions§

apply_project_exprs

Type Aliases§

PendingProjectMessages 🔒
ProjectMessageFuture 🔒