risingwave_stream::executor::wrapper

Module schema_check

source

Functionsยง

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