| 646 | } |
| 647 | |
| 648 | flow_file_record* get(processor_session *session, processor_context *context) { |
| 649 | auto ff = session->get(); |
| 650 | if(!ff) { |
| 651 | return nullptr; |
| 652 | } |
| 653 | |
| 654 | auto ffr = flowfile_to_record(ff, context->getContentRepository()); |
| 655 | // The content of the flow file must be kept in a processor logic |
| 656 | ffr->keepContent = 1; |
| 657 | return ffr; |
| 658 | } |
| 659 | |
| 660 | flow_file_record * get_next_flow_file(nifi_instance * instance, flow * flow) { |
| 661 | if (instance == nullptr || nullptr == flow) |