Method cloneDuringTransfer

libminifi/src/core/ProcessSession.cpp:124–157

}

std::shared_ptr<core::FlowFile> ProcessSession::cloneDuringTransfer(const std::shared_ptr<core::FlowFile> &parent) {
  auto record = std::make_shared<FlowFileRecord>();

  auto flow_version = process_context_->getProcessorNode()->getFlowIdentifier();
  if (flow_version != nullptr) {
    record->setAttribute(SpecialFlowAttribute::FLOW_ID, flow_version->getFlowId());
  }
  this->_clonedFlowFiles.push_back(record);
  logger_->log_debug("Clone FlowFile with UUID %s during transfer", record->getUUIDStr());
  // Copy attributes
  for (const auto& attribute : parent->getAttributes()) {
    if (attribute.first == SpecialFlowAttribute::ALTERNATE_IDENTIFIER
        || attribute.first == SpecialFlowAttribute::DISCARD_REASON
        || attribute.first == SpecialFlowAttribute::UUID) {
      // Do not copy special attributes from parent
      continue;
    }
    record->setAttribute(attribute.first, attribute.second);
  }
  record->setLineageStartDate(parent->getlineageStartDate());
  record->setLineageIdentifiers(parent->getlineageIdentifiers());
  record->getlineageIdentifiers().push_back(parent->getUUID());

  // Copy Resource Claim
  std::shared_ptr<ResourceClaim> parent_claim = parent->getResourceClaim();
  record->setResourceClaim(parent_claim);
  if (parent_claim != nullptr) {
    record->setOffset(parent->getOffset());
    record->setSize(parent->getSize());
  }
  provenance_report_->clone(parent, record);

  return record;
}

std::shared_ptr<core::FlowFile> ProcessSession::clone(const std::shared_ptr<core::FlowFile> &parent, int64_t offset, int64_t size) {
  if ((uint64_t) (offset + size) > parent->getSize()) {