| 61 | } |
| 62 | |
| 63 | std::shared_ptr<core::Processor> FlowConfiguration::createProvenanceReportTask() { |
| 64 | std::shared_ptr<core::Processor> processor = std::make_shared<org::apache::nifi::minifi::core::reporting::SiteToSiteProvenanceReportingTask>(stream_factory_, this->configuration_); |
| 65 | // initialize the processor |
| 66 | processor->initialize(); |
| 67 | return processor; |
| 68 | } |
| 69 | |
| 70 | std::unique_ptr<core::ProcessGroup> FlowConfiguration::updateFromPayload(const std::string& url, const std::string& yamlConfigPayload) { |
| 71 | auto old_services = controller_services_; |
nothing calls this directly
no test coverage detected