risingwave_frontend::handler::show

Function get_columns_from_sink

source
pub fn get_columns_from_sink(
    session: &SessionImpl,
    sink_name: ObjectName,
) -> Result<Vec<ColumnCatalog>, RwError>