public class org.apache.nifi.processors.standard.ScanContent extends org.apache.nifi.processor.AbstractProcessor
{
public static final java.lang.String TEXT_ENCODING;
public static final java.lang.String BINARY_ENCODING;
public static final java.lang.String MATCH_ATTRIBUTE_KEY;
public static final org.apache.nifi.components.PropertyDescriptor DICTIONARY;
public static final org.apache.nifi.components.PropertyDescriptor DICTIONARY_ENCODING;
public static final org.apache.nifi.processor.Relationship REL_MATCH;
public static final org.apache.nifi.processor.Relationship REL_NO_MATCH;
public static final java.nio.charset.Charset UTF8;
private final java.util.concurrent.atomic.AtomicReference fileWatcherRef;
private final java.util.concurrent.atomic.AtomicReference searchRef;
private final java.util.concurrent.locks.ReentrantLock dictionaryUpdateLock;
private java.util.List properties;
private java.util.Set relationships;
public void <init>()
{
java.util.concurrent.locks.ReentrantLock v;
org.apache.nifi.processors.standard.ScanContent v;
java.util.concurrent.atomic.AtomicReference v, v;
v := @this: org.apache.nifi.processors.standard.ScanContent;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>()>();
v.<org.apache.nifi.processors.standard.ScanContent: java.util.concurrent.atomic.AtomicReference fileWatcherRef> = v;
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>()>();
v.<org.apache.nifi.processors.standard.ScanContent: java.util.concurrent.atomic.AtomicReference searchRef> = v;
v = new java.util.concurrent.locks.ReentrantLock;
specialinvoke v.<java.util.concurrent.locks.ReentrantLock: void <init>()>();
v.<org.apache.nifi.processors.standard.ScanContent: java.util.concurrent.locks.ReentrantLock dictionaryUpdateLock> = v;
return;
}
protected void init(org.apache.nifi.processor.ProcessorInitializationContext)
{
java.util.Set v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.ArrayList v;
java.util.HashSet v;
java.util.List v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.processors.standard.ScanContent v;
org.apache.nifi.processor.ProcessorInitializationContext v;
v := @this: org.apache.nifi.processors.standard.ScanContent;
v := @parameter: org.apache.nifi.processor.ProcessorInitializationContext;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.components.PropertyDescriptor DICTIONARY>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.components.PropertyDescriptor DICTIONARY_ENCODING>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
v.<org.apache.nifi.processors.standard.ScanContent: java.util.List properties> = v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.processor.Relationship REL_MATCH>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.processor.Relationship REL_NO_MATCH>;
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.ScanContent: java.util.Set relationships> = v;
return;
}
protected java.util.List getSupportedPropertyDescriptors()
{
java.util.List v;
org.apache.nifi.processors.standard.ScanContent v;
v := @this: org.apache.nifi.processors.standard.ScanContent;
v = v.<org.apache.nifi.processors.standard.ScanContent: java.util.List properties>;
return v;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.standard.ScanContent v;
v := @this: org.apache.nifi.processors.standard.ScanContent;
v = v.<org.apache.nifi.processors.standard.ScanContent: java.util.Set relationships>;
return v;
}
public void onPropertyModified(org.apache.nifi.components.PropertyDescriptor, java.lang.String, java.lang.String)
{
org.apache.nifi.util.file.monitor.LastModifiedMonitor v;
org.apache.nifi.util.file.monitor.SynchronousFileWatcher v;
java.lang.String[] v;
java.util.concurrent.atomic.AtomicReference v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.lang.String v, v;
org.apache.nifi.processors.standard.ScanContent v;
java.nio.file.Path v;
boolean v;
v := @this: org.apache.nifi.processors.standard.ScanContent;
v := @parameter: org.apache.nifi.components.PropertyDescriptor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = <org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.components.PropertyDescriptor DICTIONARY>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = v.<org.apache.nifi.processors.standard.ScanContent: java.util.concurrent.atomic.AtomicReference fileWatcherRef>;
v = new org.apache.nifi.util.file.monitor.SynchronousFileWatcher;
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>(v, v);
v = new org.apache.nifi.util.file.monitor.LastModifiedMonitor;
specialinvoke v.<org.apache.nifi.util.file.monitor.LastModifiedMonitor: void <init>()>();
specialinvoke v.<org.apache.nifi.util.file.monitor.SynchronousFileWatcher: void <init>(java.nio.file.Path,org.apache.nifi.util.file.monitor.UpdateMonitor,long)>(v, v, 60000L);
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
label:
return;
}
private boolean reloadDictionary(org.apache.nifi.processor.ProcessContext, boolean, org.apache.nifi.logging.ComponentLog) throws java.io.IOException
{
java.lang.Throwable v, v, v;
java.lang.Object[] v;
org.apache.nifi.logging.ComponentLog v;
java.util.concurrent.atomic.AtomicReference v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processors.standard.ScanContent$TermLoader v;
org.apache.nifi.components.PropertyValue v, v;
java.util.HashSet v;
java.lang.String v;
org.apache.nifi.processors.standard.ScanContent v;
org.apache.nifi.components.resource.ResourceReference v;
boolean v, v;
java.util.concurrent.locks.ReentrantLock v, v, v, v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.util.search.SearchTerm v;
org.apache.nifi.util.search.ahocorasick.AhoCorasick v;
java.io.InputStream v;
v := @this: org.apache.nifi.processors.standard.ScanContent;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: boolean;
v := @parameter: org.apache.nifi.logging.ComponentLog;
if v == 0 goto label;
v = v.<org.apache.nifi.processors.standard.ScanContent: java.util.concurrent.locks.ReentrantLock dictionaryUpdateLock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
v = 1;
goto label;
label:
v = v.<org.apache.nifi.processors.standard.ScanContent: java.util.concurrent.locks.ReentrantLock dictionaryUpdateLock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: boolean tryLock()>();
label:
if v == 0 goto label;
label:
v = new org.apache.nifi.util.search.ahocorasick.AhoCorasick;
specialinvoke v.<org.apache.nifi.util.search.ahocorasick.AhoCorasick: void <init>()>();
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.components.PropertyDescriptor DICTIONARY>;
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.resource.ResourceReference asResource()>();
v = interfaceinvoke v.<org.apache.nifi.components.resource.ResourceReference: java.io.InputStream read()>();
label:
v = specialinvoke v.<org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.processors.standard.ScanContent$TermLoader createTermLoader(org.apache.nifi.processor.ProcessContext,java.io.InputStream)>(v, v);
label:
v = interfaceinvoke v.<org.apache.nifi.processors.standard.ScanContent$TermLoader: org.apache.nifi.util.search.SearchTerm nextTerm()>();
if v == null goto label;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
goto label;
label:
interfaceinvoke v.<org.apache.nifi.util.search.Search: void initializeDictionary(java.util.Set)>(v);
v = v.<org.apache.nifi.processors.standard.ScanContent: java.util.concurrent.atomic.AtomicReference searchRef>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
v = newarray (java.lang.Object)[1];
v = <org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.components.PropertyDescriptor DICTIONARY>;
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[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Loaded search dictionary from {}", v);
label:
interfaceinvoke v.<org.apache.nifi.processors.standard.ScanContent$TermLoader: void close()>();
label:
if v == null goto label;
virtualinvoke v.<java.io.InputStream: void close()>();
label:
v = v.<org.apache.nifi.processors.standard.ScanContent: java.util.concurrent.locks.ReentrantLock dictionaryUpdateLock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
return 1;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = v.<org.apache.nifi.processors.standard.ScanContent: java.util.concurrent.locks.ReentrantLock dictionaryUpdateLock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
label:
return 0;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private org.apache.nifi.processors.standard.ScanContent$TermLoader createTermLoader(org.apache.nifi.processor.ProcessContext, java.io.InputStream)
{
org.apache.nifi.processors.standard.ScanContent$BinaryTermLoader v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.components.PropertyValue v;
org.apache.nifi.processors.standard.ScanContent$TextualTermLoader v;
java.lang.String v;
org.apache.nifi.processors.standard.ScanContent v;
boolean v;
java.io.InputStream v;
v := @this: org.apache.nifi.processors.standard.ScanContent;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: java.io.InputStream;
v = <org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.components.PropertyDescriptor DICTIONARY_ENCODING>;
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 = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>("text");
if v == 0 goto label;
v = new org.apache.nifi.processors.standard.ScanContent$TextualTermLoader;
specialinvoke v.<org.apache.nifi.processors.standard.ScanContent$TextualTermLoader: void <init>(java.io.InputStream)>(v);
return v;
label:
v = new org.apache.nifi.processors.standard.ScanContent$BinaryTermLoader;
specialinvoke v.<org.apache.nifi.processors.standard.ScanContent$BinaryTermLoader: void <init>(java.io.InputStream)>(v);
return v;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException
{
java.lang.Object[] v, v;
org.apache.nifi.logging.ComponentLog v;
java.util.concurrent.atomic.AtomicReference v, v, v, v;
org.apache.nifi.processor.exception.ProcessException v, v;
org.apache.nifi.processors.standard.ScanContent$1 v;
org.apache.nifi.provenance.ProvenanceReporter v, v;
java.nio.charset.Charset v;
org.apache.nifi.processor.Relationship v, v, v, v;
java.lang.String v;
org.apache.nifi.processors.standard.ScanContent v;
boolean v, v;
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processor.ProcessContext v;
java.io.IOException v, v;
org.apache.nifi.processor.ProcessSession v;
java.lang.Object v, v, v;
v := @this: org.apache.nifi.processors.standard.ScanContent;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = virtualinvoke v.<org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.logging.ComponentLog getLogger()>();
v = v.<org.apache.nifi.processors.standard.ScanContent: java.util.concurrent.atomic.AtomicReference fileWatcherRef>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
label:
v = virtualinvoke v.<org.apache.nifi.util.file.monitor.SynchronousFileWatcher: boolean checkAndReset()>();
if v == 0 goto label;
specialinvoke v.<org.apache.nifi.processors.standard.ScanContent: boolean reloadDictionary(org.apache.nifi.processor.ProcessContext,boolean,org.apache.nifi.logging.ComponentLog)>(v, 1, v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.nifi.processor.exception.ProcessException;
specialinvoke v.<org.apache.nifi.processor.exception.ProcessException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = v.<org.apache.nifi.processors.standard.ScanContent: java.util.concurrent.atomic.AtomicReference searchRef>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
label:
if v != null goto label;
v = specialinvoke v.<org.apache.nifi.processors.standard.ScanContent: boolean reloadDictionary(org.apache.nifi.processor.ProcessContext,boolean,org.apache.nifi.logging.ComponentLog)>(v, 0, v);
if v == 0 goto label;
v = v.<org.apache.nifi.processors.standard.ScanContent: java.util.concurrent.atomic.AtomicReference searchRef>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.nifi.processor.exception.ProcessException;
specialinvoke v.<org.apache.nifi.processor.exception.ProcessException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
if v != null goto label;
return;
label:
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile get()>();
if v != null goto label;
return;
label:
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>(null);
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(null);
v = new org.apache.nifi.processors.standard.ScanContent$1;
specialinvoke v.<org.apache.nifi.processors.standard.ScanContent$1: void <init>(org.apache.nifi.processors.standard.ScanContent,org.apache.nifi.util.search.Search,java.util.concurrent.atomic.AtomicReference)>(v, v, v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void read(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.InputStreamCallback)>(v, v);
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
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[])>("Routing {} to \'unmatched\'", v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
v = <org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.processor.Relationship REL_NO_MATCH>;
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void route(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = <org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.processor.Relationship REL_NO_MATCH>;
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.ScanContent: java.nio.charset.Charset UTF8>;
v = virtualinvoke v.<org.apache.nifi.util.search.SearchTerm: java.lang.String toString(java.nio.charset.Charset)>(v);
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[])>("Routing {} to \'matched\' because it matched term {}", v);
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, "matching.term", v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
v = <org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.processor.Relationship REL_MATCH>;
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void route(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = <org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.processor.Relationship REL_MATCH>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
label:
return;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
}
static void <clinit>()
{
org.apache.nifi.components.resource.ResourceType[] v;
java.lang.String[] v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.components.resource.ResourceCardinality v;
java.nio.charset.Charset v;
org.apache.nifi.components.resource.ResourceType v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.processor.Relationship$Builder 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)>("Dictionary File");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The filename of the terms dictionary");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.components.resource.ResourceCardinality: org.apache.nifi.components.resource.ResourceCardinality SINGLE>;
v = <org.apache.nifi.components.resource.ResourceType: org.apache.nifi.components.resource.ResourceType FILE>;
v = newarray (org.apache.nifi.components.resource.ResourceType)[0];
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder identifiesExternalResource(org.apache.nifi.components.resource.ResourceCardinality,org.apache.nifi.components.resource.ResourceType,org.apache.nifi.components.resource.ResourceType[])>(v, v, v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.components.PropertyDescriptor DICTIONARY> = 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)>("Dictionary Encoding");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Indicates how the dictionary is encoded. If \'text\', dictionary terms are new-line delimited and UTF-8 encoded; if \'binary\', dictionary terms are denoted by a 4-byte integer indicating the term length followed by the term itself");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = newarray (java.lang.String)[2];
v[0] = "text";
v[1] = "binary";
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.String[])>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("text");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.components.PropertyDescriptor DICTIONARY_ENCODING> = 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)>("matched");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("FlowFiles that match at least one term in the dictionary are routed to this relationship");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.processor.Relationship REL_MATCH> = 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)>("unmatched");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("FlowFiles that do not match any term in the dictionary are routed to this relationship");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.ScanContent: org.apache.nifi.processor.Relationship REL_NO_MATCH> = v;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
<org.apache.nifi.processors.standard.ScanContent: java.nio.charset.Charset UTF8> = v;
return;
}
}