MCPcopy Create free account
hub / github.com/apache/nifi-minifi-cpp / transfer

Method transfer

libminifi/src/core/ProcessSession.cpp:206–211  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

204}
205
206void ProcessSession::transfer(const std::shared_ptr<core::FlowFile> &flow, Relationship relationship) {
207 logging::LOG_INFO(logger_) << "Transferring " << flow->getUUIDStr() << " from " << process_context_->getProcessorNode()->getName() << " to relationship " << relationship.getName();
208 utils::Identifier uuid = flow->getUUID();
209 _transferRelationship[uuid] = relationship;
210 flow->setDeleted(false);
211}
212
213void ProcessSession::write(const std::shared_ptr<core::FlowFile> &flow, OutputStreamCallback *callback) {
214 std::shared_ptr<ResourceClaim> claim = content_session_->create();

Callers 12

writeMethod · 0.45
onTriggerMethod · 0.45
onTriggerFunction · 0.45
onTriggerFunction · 0.45
onTriggerFunction · 0.45
onTriggerMethod · 0.45
SessionTests.cppFile · 0.45
RepoTests.cppFile · 0.45
onTriggerMethod · 0.45
receiveFlowFilesMethod · 0.45

Calls 5

getProcessorNodeMethod · 0.80
setDeletedMethod · 0.80
getUUIDStrMethod · 0.45
getNameMethod · 0.45
getUUIDMethod · 0.45

Tested by 3

writeMethod · 0.36
onTriggerMethod · 0.36
onTriggerMethod · 0.36