[
https://issues.apache.org/jira/browse/NIFI-6970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ilya Kovalev updated NIFI-6970:
-------------------------------
External issue URL: https://github.com/apache/nifi/pull/3984
> Add DistributeRecord processor for distribute data by key hash
> --------------------------------------------------------------
>
> Key: NIFI-6970
> URL: https://issues.apache.org/jira/browse/NIFI-6970
> Project: Apache NiFi
> Issue Type: New Feature
> Components: Extensions
> Affects Versions: 1.10.0
> Reporter: Ilya Kovalev
> Priority: Minor
>
> Necessary to add Processor for distribute data over user specified
> relationships by distribution key/keys. Data is distributed across
> relationships in the amount proportional to the relationship weight. For
> example, if there are two relationships and the first has a weight of 9 while
> the second has a weight of 10, the first will be sent 9 / 19 parts of the
> rows, and the second will be sent 10 / 19.
> The row will be sent to the relationship that corresponds to the
> half-interval of the remainders from 'prev_weight' to 'prev_weights +
> weight', where 'prev_weights' is the total weight of the relationships with
> the smallest number, and 'weight' is the weight of this relationship." For
> example, if there are two relationships, and the first has a weight of 9
> while the second has a weight of 10, the row will be sent to the first
> relationship for the remainders from the range [0, 9), and to the second for
> the remainders from the range [9, 19).
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
