risingwave_stream::executor::wrapper

Module schema_check

Source

Functionsยง

schema_check
Streams wrapped by schema_check will check the passing stream chunk against the expected schema.