[ 
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)

Reply via email to