| 184 | } |
| 185 | |
| 186 | void ProcessSession::putAttribute(const std::shared_ptr<core::FlowFile> &flow, std::string key, std::string value) { |
| 187 | flow->setAttribute(key, value); |
| 188 | std::stringstream details; |
| 189 | details << process_context_->getProcessorNode()->getName() << " modify flow record " << flow->getUUIDStr() << " attribute " << key << ":" << value; |
| 190 | provenance_report_->modifyAttributes(flow, details.str()); |
| 191 | } |
| 192 | |
| 193 | void ProcessSession::removeAttribute(const std::shared_ptr<core::FlowFile> &flow, std::string key) { |
| 194 | flow->removeAttribute(key); |
nothing calls this directly
no test coverage detected