risingwave_frontend::handler::create_subscription

Function create_subscription_catalog

source 
pub fn create_subscription_catalog(
    session: &SessionImpl,
    context: OptimizerContextRef,
    stmt: CreateSubscriptionStatement,
) -> Result<SubscriptionCatalog, RwError>