Method ephemeralOutputTopics

pj_runtime/src/DataProcessorService.cpp:724–733

}

std::unordered_set<TopicId> DataProcessorService::ephemeralOutputTopics() const {
  std::unordered_set<TopicId> out;
  for (const auto& [key, recipe] : transform_recipes_) {
    (void)key;
    if (recipe.ephemeral) {
      out.insert(recipe.output_topic_ids.begin(), recipe.output_topic_ids.end());
    }
  }
  return out;
}

std::vector<DataProcessorService::TransformRecipe> DataProcessorService::transformsDependingOn(
    const std::vector<std::string>& removed_series) const {