risingwave_stream::executor

Module wrapper

Source

Modules§

epoch_check 🔒
epoch_provide 🔒
schema_check 🔒
stream_node_metrics 🔒
trace 🔒
update_check 🔒

Structs§

WrapperExecutor
WrapperExecutor will do some sanity checks and logging for the wrapped executor.