[
https://issues.apache.org/jira/browse/NIFI-2590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alex Halldin updated NIFI-2590:
-------------------------------
Status: Patch Available (was: Open)
Submitting patch after applying and testing our changes against the 0.6.x
branch.
> Added the FlowFileAggregationController Processor
> -------------------------------------------------
>
> Key: NIFI-2590
> URL: https://issues.apache.org/jira/browse/NIFI-2590
> Project: Apache NiFi
> Issue Type: New Feature
> Reporter: Alex Halldin
>
> This processor is used to aggregate flowfiles and continuously feed them into
> another processor. This processor will keep track of the individual flow
> files, as well as an entire batch of flowfiles, and will throw away old flow
> files when a new batch is detected in an event driven fashion. The processor
> will also create and update a "startTime" attribute on all flowfiles that is
> controlled by the "Data Retrieval Time Delay" property.
> An example of usage would be a query use case. The
> FlowFileAggregationController will aggregate a number of flowfiles
> representing query attributes, and will update the startTime's on each
> flowfile. As each flowfile is processed by the query processor and returned
> to the Aggregator, the Aggregator will update the startTime's once again with
> the end time of the previous query execution and will feed them back into the
> query processor. In other words, this processor will allows us to continually
> query using timestamps that are updated after each previous processing
> attempt.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
