risingwave_stream::executor

Module filter

source

Structsยง

  • FilterExecutor filters data with the expr. The expr takes a chunk of data, and returns a boolean array on whether each item should be retained. And then, FilterExecutor will insert, delete or update element into next executor according to the result of the expression.