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