[
https://issues.apache.org/jira/browse/NIFI-5516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16611741#comment-16611741
]
ASF GitHub Bot commented on NIFI-5516:
--------------------------------------
Github user ijokarumawak commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2947#discussion_r216925801
--- Diff:
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-client-dto/src/main/java/org/apache/nifi/web/api/dto/ConnectionDTO.java
---
@@ -231,6 +239,46 @@ public void setPrioritizers(List<String> prioritizers)
{
this.prioritizers = prioritizers;
}
+ @ApiModelProperty(value = "How to load balance the data in this
Connection across the nodes in the cluster.",
+ allowableValues = "DO_NOT_LOAD_BALANCE, PARTITION_BY_ATTRIBUTE,
ROUND_ROBIN, SINGLE_NODE")
+ public String getLoadBalanceStrategy() {
+ return loadBalanceStrategy;
+ }
+
+ public void setLoadBalanceStrategy(String loadBalanceStrategy) {
+ this.loadBalanceStrategy = loadBalanceStrategy;
+ }
+
+ @ApiModelProperty(value = "The FlowFile Attribute to use for
determining which node a FlowFile will go to if the Load Balancing Strategy is
set to PARTITION_BY_ATTRIBUTE")
+ public String getLoadBalancePartitionAttribute() {
+ return loadBalancePartitionAttribute;
+ }
+
+ public void setLoadBalancePartitionAttribute(String
partitionAttribute) {
+ this.loadBalancePartitionAttribute = partitionAttribute;
+ }
+
+ @ApiModelProperty(value = "Whether or not data should be compressed
when being transferred between nodes in the cluster.",
+ allowableValues = "DO_NOT_COMPRESS, COMPRESS_ATTRIBUTES_ONLY,
COMPRESS_ATTRIBUTES_AND_CONTENT")
+ public String getLoadBalanceCompression() {
+ return loadBalanceCompression;
+ }
+
+ public void setLoadBalanceCompression(String compression) {
+ this.loadBalanceCompression = compression;
+ }
+
+ @ApiModelProperty(value = "The current status of the Connection's Load
Balancing Activities. Status can indicate that Load Balancing is not configured
for the connection, that Load Balancing " +
--- End diff --
Better to annotate this method with readOnly = true.
> Allow data in a Connection to be Load-Balanced across cluster
> -------------------------------------------------------------
>
> Key: NIFI-5516
> URL: https://issues.apache.org/jira/browse/NIFI-5516
> Project: Apache NiFi
> Issue Type: New Feature
> Components: Core Framework
> Reporter: Mark Payne
> Assignee: Mark Payne
> Priority: Major
>
> Allow user to configure a Connection to be load balanced across the cluster.
> For more information, see Feature Proposal atÂ
> https://cwiki.apache.org/confluence/display/NIFI/Load-Balanced+Connections
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
