risingwave_meta::controller::utils

Function get_fragments_for_jobs

source 
pub async fn get_fragments_for_jobs<C>(
    db: &C,
    streaming_jobs: Vec<ObjectId>,
) -> MetaResult<(HashMap<SourceId, BTreeSet<FragmentId>>, HashSet<ActorId>, HashSet<FragmentId>)>
where
    C: ConnectionTrait,
Expand description

For the given streaming jobs, returns

  • All source fragments
  • All actors
  • All fragments