| 778 | } |
| 779 | |
| 780 | int transfer_to_relationship(flow_file_record * ffr, processor_session * ps, const char * relationship) { |
| 781 | if(ffr == nullptr || ffr->ffp == nullptr || ps == nullptr || relationship == nullptr || strlen(relationship) == 0) { |
| 782 | return -1; |
| 783 | } |
| 784 | auto ff_sptr = reinterpret_cast<std::shared_ptr<core::FlowFile>*>(ffr->ffp); |
| 785 | ps->transfer(*ff_sptr, core::Relationship(relationship, "desc")); |
| 786 | return 0; |
| 787 | } |