public class org.apache.nifi.processors.standard.merge.AttributeStrategyUtil extends java.lang.Object
{
public static final org.apache.nifi.components.AllowableValue ATTRIBUTE_STRATEGY_ALL_COMMON;
public static final org.apache.nifi.components.AllowableValue ATTRIBUTE_STRATEGY_ALL_UNIQUE;
public static final org.apache.nifi.components.PropertyDescriptor ATTRIBUTE_STRATEGY;
public void <init>()
{
org.apache.nifi.processors.standard.merge.AttributeStrategyUtil v;
v := @this: org.apache.nifi.processors.standard.merge.AttributeStrategyUtil;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static org.apache.nifi.processors.standard.merge.AttributeStrategy strategyFor(org.apache.nifi.processor.ProcessContext)
{
org.apache.nifi.processors.standard.merge.KeepUniqueAttributeStrategy v;
org.apache.nifi.processors.standard.merge.KeepCommonAttributeStrategy v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.components.AllowableValue v, v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.components.PropertyValue v;
java.lang.String v, v, v;
boolean v, v;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = <org.apache.nifi.processors.standard.merge.AttributeStrategyUtil: org.apache.nifi.components.PropertyDescriptor ATTRIBUTE_STRATEGY>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = <org.apache.nifi.processors.standard.merge.AttributeStrategyUtil: org.apache.nifi.components.AllowableValue ATTRIBUTE_STRATEGY_ALL_UNIQUE>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = new org.apache.nifi.processors.standard.merge.KeepUniqueAttributeStrategy;
specialinvoke v.<org.apache.nifi.processors.standard.merge.KeepUniqueAttributeStrategy: void <init>()>();
return v;
label:
v = <org.apache.nifi.processors.standard.merge.AttributeStrategyUtil: org.apache.nifi.components.AllowableValue ATTRIBUTE_STRATEGY_ALL_COMMON>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = new org.apache.nifi.processors.standard.merge.KeepCommonAttributeStrategy;
specialinvoke v.<org.apache.nifi.processors.standard.merge.KeepCommonAttributeStrategy: void <init>()>();
return v;
label:
return null;
}
static void <clinit>()
{
org.apache.nifi.components.AllowableValue[] v;
org.apache.nifi.components.AllowableValue v, v, v, v, v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v;
java.lang.String v;
v = new org.apache.nifi.components.AllowableValue;
specialinvoke v.<org.apache.nifi.components.AllowableValue: void <init>(java.lang.String,java.lang.String,java.lang.String)>("Keep Only Common Attributes", "Keep Only Common Attributes", "Any attribute that is not the same on all FlowFiles in a bin will be dropped. Those that are the same across all FlowFiles will be retained.");
<org.apache.nifi.processors.standard.merge.AttributeStrategyUtil: org.apache.nifi.components.AllowableValue ATTRIBUTE_STRATEGY_ALL_COMMON> = v;
v = new org.apache.nifi.components.AllowableValue;
specialinvoke v.<org.apache.nifi.components.AllowableValue: void <init>(java.lang.String,java.lang.String,java.lang.String)>("Keep All Unique Attributes", "Keep All Unique Attributes", "Any attribute that has the same value for all FlowFiles in a bin, or has no value for a FlowFile, will be kept. For example, if a bin consists of 3 FlowFiles and 2 of them have a value of \'hello\' for the \'greeting\' attribute and the third FlowFile has no \'greeting\' attribute then the outbound FlowFile will get a \'greeting\' attribute with the value \'hello\'.");
<org.apache.nifi.processors.standard.merge.AttributeStrategyUtil: org.apache.nifi.components.AllowableValue ATTRIBUTE_STRATEGY_ALL_UNIQUE> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Attribute Strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Determines which FlowFile attributes should be added to the bundle. If \'Keep All Unique Attributes\' is selected, any attribute on any FlowFile that gets bundled will be kept unless its value conflicts with the value from another FlowFile. If \'Keep Only Common Attributes\' is selected, only the attributes that exist on all FlowFiles in the bundle, with the same value, will be preserved.");
v = newarray (org.apache.nifi.components.AllowableValue)[2];
v = <org.apache.nifi.processors.standard.merge.AttributeStrategyUtil: org.apache.nifi.components.AllowableValue ATTRIBUTE_STRATEGY_ALL_COMMON>;
v[0] = v;
v = <org.apache.nifi.processors.standard.merge.AttributeStrategyUtil: org.apache.nifi.components.AllowableValue ATTRIBUTE_STRATEGY_ALL_UNIQUE>;
v[1] = v;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(org.apache.nifi.components.AllowableValue[])>(v);
v = <org.apache.nifi.processors.standard.merge.AttributeStrategyUtil: org.apache.nifi.components.AllowableValue ATTRIBUTE_STRATEGY_ALL_COMMON>;
v = virtualinvoke v.<org.apache.nifi.components.AllowableValue: java.lang.String getValue()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.merge.AttributeStrategyUtil: org.apache.nifi.components.PropertyDescriptor ATTRIBUTE_STRATEGY> = v;
return;
}
}