| 191 | } |
| 192 | |
| 193 | void ProcessSession::removeAttribute(const std::shared_ptr<core::FlowFile> &flow, std::string key) { |
| 194 | flow->removeAttribute(key); |
| 195 | std::stringstream details; |
| 196 | details << process_context_->getProcessorNode()->getName() << " remove flow record " << flow->getUUIDStr() << " attribute " + key; |
| 197 | provenance_report_->modifyAttributes(flow, details.str()); |
| 198 | } |
| 199 | |
| 200 | void ProcessSession::penalize(const std::shared_ptr<core::FlowFile> &flow) { |
| 201 | uint64_t penalization_period = process_context_->getProcessorNode()->getPenalizationPeriodMsec(); |
nothing calls this directly
no test coverage detected