[
https://issues.apache.org/jira/browse/MINIFI-231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15892491#comment-15892491
]
ASF GitHub Bot commented on MINIFI-231:
---------------------------------------
Github user phrocker commented on a diff in the pull request:
https://github.com/apache/nifi-minifi-cpp/pull/62#discussion_r103960736
--- Diff: libminifi/src/FlowFileRecord.cpp ---
@@ -74,6 +76,43 @@ FlowFileRecord::FlowFileRecord(std::map<std::string,
std::string> attributes, Re
logger_ = Logger::getLogger();
}
+FlowFileRecord::FlowFileRecord(FlowFileEventRecord *event)
+: _size(0),
+ _id(_localFlowSeqNumber.load()),
+ _offset(0),
+ _penaltyExpirationMs(0),
+ _claim(NULL),
+ _isStoredToRepo(false),
+ _markedDelete(false),
+ _connection(NULL),
+ _orginalConnection(NULL)
+{
+ _entryDate = event->getFlowFileEntryDate();
+ _lineageStartDate = event->getlineageStartDate();
+ _size = event->getFileSize();
+ _offset = event->getFileOffset();
+ _lineageIdentifiers = event->getLineageIdentifiers();
+ _attributes = event->getAttributes();
+ _snapshot = false;
+ _uuidStr = event->getFlowFileUuid();
+ uuid_parse(_uuidStr.c_str(), _uuid);
+
+ if (_size > 0)
+ {
+ _claim = new ResourceClaim();
--- End diff --
Why does claim_ need to be a pointer? You should use a unique_ptr if that
is required.
> FlowFile Persistent
> --------------------
>
> Key: MINIFI-231
> URL: https://issues.apache.org/jira/browse/MINIFI-231
> Project: Apache NiFi MiNiFi
> Issue Type: Bug
> Components: Core Framework, Data Format
> Affects Versions: cpp-1.0.0
> Reporter: bqiu
> Assignee: bqiu
> Fix For: cpp-1.0.0
>
>
> Add FlowFile persistent support
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
