| 42 | std::atomic<uint64_t> FlowFileRecord::local_flow_seq_number_(0); |
| 43 | |
| 44 | FlowFileRecord::FlowFileRecord() { |
| 45 | // TODO(adebreceni): |
| 46 | // we should revisit if we need these in a follow-up ticket |
| 47 | id_ = local_flow_seq_number_++; |
| 48 | addAttribute(core::SpecialFlowAttribute::FILENAME, std::to_string(utils::timeutils::getTimeNano())); |
| 49 | } |
| 50 | |
| 51 | std::shared_ptr<FlowFileRecord> FlowFileRecord::DeSerialize(const std::string& key, const std::shared_ptr<core::Repository>& flowRepository, |
| 52 | const std::shared_ptr<core::ContentRepository>& content_repo, utils::Identifier& container) { |
nothing calls this directly
no test coverage detected