public class org.apache.nifi.processors.standard.FetchDistributedMapCache extends org.apache.nifi.processor.AbstractProcessor
{
public static final org.apache.nifi.components.PropertyDescriptor PROP_DISTRIBUTED_CACHE_SERVICE;
public static final org.apache.nifi.components.PropertyDescriptor PROP_CACHE_ENTRY_IDENTIFIER;
public static final org.apache.nifi.components.PropertyDescriptor PROP_PUT_CACHE_VALUE_IN_ATTRIBUTE;
public static final org.apache.nifi.components.PropertyDescriptor PROP_PUT_ATTRIBUTE_MAX_LENGTH;
public static final org.apache.nifi.components.PropertyDescriptor PROP_CHARACTER_SET;
public static final org.apache.nifi.processor.Relationship REL_SUCCESS;
public static final org.apache.nifi.processor.Relationship REL_NOT_FOUND;
public static final org.apache.nifi.processor.Relationship REL_FAILURE;
private final java.util.Set relationships;
private final org.apache.nifi.distributed.cache.client.Serializer keySerializer;
private final org.apache.nifi.distributed.cache.client.Deserializer valueDeserializer;
public void <init>()
{
org.apache.nifi.processors.standard.FetchDistributedMapCache v;
org.apache.nifi.processors.standard.FetchDistributedMapCache$CacheValueDeserializer v;
org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer v;
java.util.Set v;
java.util.HashSet v;
org.apache.nifi.processor.Relationship v, v, v;
v := @this: org.apache.nifi.processors.standard.FetchDistributedMapCache;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
v = new org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer;
specialinvoke v.<org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer: void <init>()>();
v.<org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.distributed.cache.client.Serializer keySerializer> = v;
v = new org.apache.nifi.processors.standard.FetchDistributedMapCache$CacheValueDeserializer;
specialinvoke v.<org.apache.nifi.processors.standard.FetchDistributedMapCache$CacheValueDeserializer: void <init>()>();
v.<org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.distributed.cache.client.Deserializer valueDeserializer> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.processor.Relationship REL_NOT_FOUND>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
v.<org.apache.nifi.processors.standard.FetchDistributedMapCache: java.util.Set relationships> = v;
return;
}
protected java.util.List getSupportedPropertyDescriptors()
{
org.apache.nifi.processors.standard.FetchDistributedMapCache v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
java.util.ArrayList v;
v := @this: org.apache.nifi.processors.standard.FetchDistributedMapCache;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_CACHE_ENTRY_IDENTIFIER>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_DISTRIBUTED_CACHE_SERVICE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_PUT_CACHE_VALUE_IN_ATTRIBUTE>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_PUT_ATTRIBUTE_MAX_LENGTH>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_CHARACTER_SET>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return v;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.standard.FetchDistributedMapCache v;
v := @this: org.apache.nifi.processors.standard.FetchDistributedMapCache;
v = v.<org.apache.nifi.processors.standard.FetchDistributedMapCache: java.util.Set relationships>;
return v;
}
protected java.util.Collection customValidate(org.apache.nifi.components.ValidationContext)
{
org.apache.nifi.processors.standard.FetchDistributedMapCache v;
org.apache.nifi.components.ValidationContext v;
java.lang.NullPointerException v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.ArrayList v;
org.apache.nifi.components.PropertyValue v, v;
java.lang.String v;
org.apache.nifi.components.ValidationResult v, v;
boolean v, v, v;
org.apache.nifi.components.ValidationResult$Builder v, v, v, v, v, v;
java.util.Collection v;
v := @this: org.apache.nifi.processors.standard.FetchDistributedMapCache;
v := @parameter: org.apache.nifi.components.ValidationContext;
v = new java.util.ArrayList;
v = specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: java.util.Collection customValidate(org.apache.nifi.components.ValidationContext)>(v);
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_CACHE_ENTRY_IDENTIFIER>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = 0;
label:
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: boolean isExpressionLanguagePresent()>();
label:
goto label;
label:
v := @caughtexception;
label:
if v == 0 goto label;
v = new org.apache.nifi.components.ValidationResult$Builder;
specialinvoke v.<org.apache.nifi.components.ValidationResult$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder valid(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder explanation(java.lang.String)>("Contains Expression Language");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult build()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_PUT_CACHE_VALUE_IN_ATTRIBUTE>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: boolean isSet()>();
if v != 0 goto label;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>(",");
if v == 0 goto label;
v = new org.apache.nifi.components.ValidationResult$Builder;
specialinvoke v.<org.apache.nifi.components.ValidationResult$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder valid(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder explanation(java.lang.String)>("Multiple Cache Entry Identifiers specified without Put Cache Value In Attribute set");
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult build()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return v;
catch java.lang.NullPointerException from label to label with label;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException
{
org.apache.nifi.processor.io.OutputStreamCallback v;
java.lang.Integer v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v;
java.util.Map v;
java.util.stream.Collector v;
java.util.Set v;
java.util.stream.Stream v, v, v;
org.apache.nifi.controller.ControllerService v;
java.lang.Object[] v, v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v, v;
java.lang.String v, v, v, v, v;
java.io.IOException v, v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.distributed.cache.client.Serializer v, v;
org.apache.nifi.processors.standard.FetchDistributedMapCache v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v;
boolean v, v, v, v, v, v, v;
org.apache.nifi.flowfile.FlowFile v, v, v, v;
java.util.function.Predicate v;
java.lang.String[] v;
java.util.HashMap v;
org.apache.nifi.logging.ComponentLog v;
java.util.function.Function v;
java.util.HashSet v;
int v, v, v, v, v, v;
java.util.Iterator v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.distributed.cache.client.Deserializer v, v;
java.lang.Object v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.FetchDistributedMapCache;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile get()>();
if v != null goto label;
return;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.logging.ComponentLog getLogger()>();
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_CACHE_ENTRY_IDENTIFIER>;
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: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isBlank(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("FlowFile {} has no attribute for given Cache Entry Identifier", v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
return;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(",");
v = staticinvoke <java.util.Arrays: java.util.stream.Stream stream(java.lang.Object[])>(v);
v = staticinvoke <org.apache.nifi.processors.standard.FetchDistributedMapCache$lambda_onTrigger_0__80: java.util.function.Predicate bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <org.apache.nifi.processors.standard.FetchDistributedMapCache$trim__81: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v = 0;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
if v >= v goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isBlank(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = newarray (java.lang.Object)[2];
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("FlowFile {} has no attribute for Cache Entry Identifier in position {}", v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
return;
label:
v = v + 1;
goto label;
label:
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_DISTRIBUTED_CACHE_SERVICE>;
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: org.apache.nifi.controller.ControllerService asControllerService(java.lang.Class)>(class "Lorg/apache/nifi/distributed/cache/client/DistributedMapCacheClient;");
label:
v = interfaceinvoke v.<java.util.List: int size()>();
if v != 1 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
if v == 0 goto label;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(int)>(1);
v = v;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = v.<org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.distributed.cache.client.Serializer keySerializer>;
v = v.<org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.distributed.cache.client.Deserializer valueDeserializer>;
v = interfaceinvoke v.<org.apache.nifi.distributed.cache.client.DistributedMapCacheClient: java.lang.Object get(java.lang.Object,org.apache.nifi.distributed.cache.client.Serializer,org.apache.nifi.distributed.cache.client.Deserializer)>(v, v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
v = v.<org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.distributed.cache.client.Serializer keySerializer>;
v = v.<org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.distributed.cache.client.Deserializer valueDeserializer>;
v = interfaceinvoke v.<org.apache.nifi.distributed.cache.client.DistributedMapCacheClient: java.util.Map subMap(java.util.Set,org.apache.nifi.distributed.cache.client.Serializer,org.apache.nifi.distributed.cache.client.Deserializer)>(v, v, v);
label:
v = 0;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
if v != null goto label;
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Could not find an entry in cache for {}; routing to not-found", v);
v = 1;
goto label;
label:
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_PUT_CACHE_VALUE_IN_ATTRIBUTE>;
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: boolean isSet()>();
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_PUT_CACHE_VALUE_IN_ATTRIBUTE>;
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: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
if v != 0 goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.Object)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u.\u0001");
label:
v = new java.lang.String;
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_CHARACTER_SET>;
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()>();
specialinvoke v.<java.lang.String: void <init>(byte[],java.lang.String)>(v, v);
v = v;
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_PUT_ATTRIBUTE_MAX_LENGTH>;
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.Integer asInteger()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = virtualinvoke v.<java.lang.String: int length()>();
if v >= v goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
label:
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, v, v);
goto label;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= 1 goto label;
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.String)>("Multiple Cache Value Identifiers specified without Put Cache Value In Attribute set");
throw v;
label:
v = staticinvoke <org.apache.nifi.processors.standard.FetchDistributedMapCache$lambda_onTrigger_1__82: org.apache.nifi.processor.io.OutputStreamCallback bootstrap$(byte[])>(v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile write(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.OutputStreamCallback)>(v, v);
label:
if v == 0 goto label;
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Found a cache key of {} and added an attribute to {} with it\'s value.", v);
goto label;
label:
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Found a cache key of {} and replaced the contents of {} with it\'s value.", v);
goto label;
label:
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.processor.Relationship REL_NOT_FOUND>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
goto label;
label:
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile penalize(org.apache.nifi.flowfile.FlowFile)>(v);
v = <org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Unable to communicate with cache when processing {} due to {}", v);
label:
return;
catch java.io.IOException from label to label with label;
}
static void <clinit>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v;
org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.expression.AttributeExpression$ResultType v, v;
org.apache.nifi.expression.ExpressionLanguageScope v, v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.components.Validator v, v, v, v;
org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v, v, v, 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 name(java.lang.String)>("Distributed Cache Service");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The Controller Service that is used to get the cached values.");
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 identifiesControllerService(java.lang.Class)>(class "Lorg/apache/nifi/distributed/cache/client/DistributedMapCacheClient;");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_DISTRIBUTED_CACHE_SERVICE> = 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 name(java.lang.String)>("Cache Entry Identifier");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("A comma-delimited list of FlowFile attributes, or the results of Attribute Expression Language statements, which will be evaluated against a FlowFile in order to determine the value(s) used to identify duplicates; it is these values that are cached. NOTE: Only a single Cache Entry Identifier is allowed unless Put Cache Value In Attribute is specified. Multiple cache lookups are only supported when the destination is a set of attributes (see the documentation for \'Put Cache Value In Attribute\' for more details including naming convention.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.expression.AttributeExpression$ResultType: org.apache.nifi.expression.AttributeExpression$ResultType STRING>;
v = staticinvoke <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator createAttributeExpressionLanguageValidator(org.apache.nifi.expression.AttributeExpression$ResultType,boolean)>(v, 1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("${hash.value}");
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope FLOWFILE_ATTRIBUTES>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder expressionLanguageSupported(org.apache.nifi.expression.ExpressionLanguageScope)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_CACHE_ENTRY_IDENTIFIER> = 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 name(java.lang.String)>("Put Cache Value In Attribute");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If set, the cache value received will be put into an attribute of the FlowFile instead of a the content of theFlowFile. The attribute key to put to is determined by evaluating value of this property. If multiple Cache Entry Identifiers are selected, multiple attributes will be written, using the evaluated value of this property, appended by a period (.) and the name of the cache entry identifier.");
v = <org.apache.nifi.expression.AttributeExpression$ResultType: org.apache.nifi.expression.AttributeExpression$ResultType STRING>;
v = staticinvoke <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator createAttributeExpressionLanguageValidator(org.apache.nifi.expression.AttributeExpression$ResultType)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope FLOWFILE_ATTRIBUTES>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder expressionLanguageSupported(org.apache.nifi.expression.ExpressionLanguageScope)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_PUT_CACHE_VALUE_IN_ATTRIBUTE> = 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 name(java.lang.String)>("Max Length To Put In Attribute");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("If routing the cache value to an attribute of the FlowFile (by setting the \"Put Cache Value in attribute\" property), the number of characters put to the attribute value will be at most this amount. This is important because attributes are held in memory and large attributes will quickly cause out of memory issues. If the output goes longer than this value, it will be truncated to fit. Consider making this smaller if able.");
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator POSITIVE_INTEGER_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("256");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_PUT_ATTRIBUTE_MAX_LENGTH> = 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 name(java.lang.String)>("Character Set");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The Character Set in which the cached value is encoded. This will only be used when routing to an attribute.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(0);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator CHARACTER_SET_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("UTF-8");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.components.PropertyDescriptor PROP_CHARACTER_SET> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("success");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("If the cache was successfully communicated with it will be routed to this relationship");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.processor.Relationship REL_SUCCESS> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("not-found");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("If a FlowFile\'s Cache Entry Identifier was not found in the cache, it will be routed to this relationship");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.processor.Relationship REL_NOT_FOUND> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("failure");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("If unable to communicate with the cache or if the cache entry is evaluated to be blank, the FlowFile will be penalized and routed to this relationship");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.FetchDistributedMapCache: org.apache.nifi.processor.Relationship REL_FAILURE> = v;
return;
}
}