[
https://issues.apache.org/jira/browse/MINIFICPP-2404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gábor Gyimesi updated MINIFICPP-2404:
-------------------------------------
Description:
In NiFi some processors support configuring a run duration. This setting tells
a processor to continue to use the same task to work on as many flow files (or
batches of flow files) from an incoming queue in a single trigger. This is
ideal for processors where the individual tasks themselves are completed very
fast and the volume of FlowFile are large as well.
We could implement a similiar functionality in MiNiFi C++ with the run duration
could be set on processor level. MINIFICPP-2398 already implements a similar
functionality for event driven scheduling, but only with a fixed 500ms time
slice. This feature would make that time slice duration configurable, and also
implement the same functionality for timer driven scheduling.
This is connected to MINIFICPP-2033. Instead of removing runDurationNanos
altogether we could reuse it with this feature, but probably have to change it
to use milliseconds instead.
was:
In NiFi some processors support configuring a run duration. This setting tells
a processor to continue to use the same task to work on as many flow files (or
batches of flow files) from an incoming queue in a single trigger. This is
ideal for processors where the individual tasks themselves are completed very
fast and the volume of FlowFile are large as well.
We could implement a similiar functionality in MiNiFi C++ with the run duration
could be set on processor level. MINIFICPP-2398 already implements a similar
functionality for event driven scheduling, but only with a fixed 500ms time
slice. This feature would make that time slice duration configurable, and also
implement the same functionality for timer driven scheduling.
This
> Add run duration functionality for processors
> ---------------------------------------------
>
> Key: MINIFICPP-2404
> URL: https://issues.apache.org/jira/browse/MINIFICPP-2404
> Project: Apache NiFi MiNiFi C++
> Issue Type: New Feature
> Reporter: Gábor Gyimesi
> Priority: Major
>
> In NiFi some processors support configuring a run duration. This setting
> tells a processor to continue to use the same task to work on as many flow
> files (or batches of flow files) from an incoming queue in a single trigger.
> This is ideal for processors where the individual tasks themselves are
> completed very fast and the volume of FlowFile are large as well.
> We could implement a similiar functionality in MiNiFi C++ with the run
> duration could be set on processor level. MINIFICPP-2398 already implements a
> similar functionality for event driven scheduling, but only with a fixed
> 500ms time slice. This feature would make that time slice duration
> configurable, and also implement the same functionality for timer driven
> scheduling.
> This is connected to MINIFICPP-2033. Instead of removing runDurationNanos
> altogether we could reuse it with this feature, but probably have to change
> it to use milliseconds instead.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
