[
https://issues.apache.org/jira/browse/NIFIREG-194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16579844#comment-16579844
]
ASF GitHub Bot commented on NIFIREG-194:
----------------------------------------
Github user bbende commented on a diff in the pull request:
https://github.com/apache/nifi-registry/pull/136#discussion_r209961895
--- Diff:
nifi-registry-data-model/src/main/java/org/apache/nifi/registry/flow/VersionedConnection.java
---
@@ -134,6 +139,36 @@ public void setPrioritizers(List<String> prioritizers)
{
this.prioritizers = prioritizers;
}
+ @ApiModelProperty(value = "The Strategy to use for load balancing data
across the cluster, or null, if no Load Balance Strategy has been specified.",
+ allowableValues = "DO_NOT_LOAD_BALANCE,
PARTITION_BY_ATTRIBUTE, ROUND_ROBIN")
+ public String getLoadBalanceStrategy() {
+ return loadBalanceStrategy;
+ }
+
+ public void setLoadBalanceStrategy(String loadBalanceStrategy) {
+ this.loadBalanceStrategy = loadBalanceStrategy;
+ }
+
+ @ApiModelProperty("The attribute to use for partitioning data as it is
load balanced across the cluster. If the Load Balance Strategy is configured to
use PARTITION_BY_ATTRIBUTE, the value " +
+ "returned by this method is the name of the FlowFile Attribute
that will be used to determine which node in the cluster should receive a given
FlowFile. If the Load Balance Strategy is " +
+ "unset or is set to any other value, the Partitioning
Attribute has no effect.")
+ public String getPartitioningAttribute() {
+ return partitioningAttribute;
+ }
+
+ public void setPartitioningAttribute(final String
partitioningAttribute) {
+ this.partitioningAttribute = partitioningAttribute;
+ }
+
+ @ApiModelProperty("Whether or not compression should be used when
transferring FlowFiles between nodes")
--- End diff --
Is there a list of allowable values for the types of compression?
> Update VersionedConnection to allow for load balancing configuration
> --------------------------------------------------------------------
>
> Key: NIFIREG-194
> URL: https://issues.apache.org/jira/browse/NIFIREG-194
> Project: NiFi Registry
> Issue Type: New Feature
> Reporter: Mark Payne
> Assignee: Mark Payne
> Priority: Major
> Fix For: 0.3.0
>
>
> NIFI-5516 allows data to be load-balanced across a cluster effectively. In
> order for that configuration to be stored in the Flow Registry, we need
> updates to the VersionedConnection object and associated updates to the
> FlowComparator.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
