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.
---