risingwave_meta::controller::utils

Function check_sink_into_table_cycle

source 
pub async fn check_sink_into_table_cycle<C>(
    target_table: ObjectId,
    dependent_objs: Vec<ObjectId>,
    db: &C,
) -> MetaResult<bool>
where
    C: ConnectionTrait,
Expand description

Check if create a sink with given dependent objects into the target table will cause a cycle, return true if it will.