Skip to main content

get_incoming_sink_objects_for_target

risingwave_meta::controller::utils

Function get_incoming_sink_objects_for_target 

Source 
async fn get_incoming_sink_objects_for_target<C>(
    target_id: ObjectId,
    target_type: ObjectType,
    db: &C,
) -> MetaResult<Vec<PartialObject>>
where
    C: ConnectionTrait,