public class org.apache.nifi.processors.standard.SplitText extends org.apache.nifi.processor.AbstractProcessor
{
public static final java.lang.String SPLIT_LINE_COUNT;
public static final java.lang.String FRAGMENT_SIZE;
public static final java.lang.String FRAGMENT_ID;
public static final java.lang.String FRAGMENT_INDEX;
public static final java.lang.String FRAGMENT_COUNT;
public static final java.lang.String SEGMENT_ORIGINAL_FILENAME;
public static final org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT;
public static final org.apache.nifi.components.PropertyDescriptor FRAGMENT_MAX_SIZE;
public static final org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT;
public static final org.apache.nifi.components.PropertyDescriptor HEADER_MARKER;
public static final org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES;
public static final org.apache.nifi.processor.Relationship REL_ORIGINAL;
public static final org.apache.nifi.processor.Relationship REL_SPLITS;
public static final org.apache.nifi.processor.Relationship REL_FAILURE;
private static final java.util.List properties;
private static final java.util.Set relationships;
private volatile boolean removeTrailingNewLines;
private volatile long maxSplitSize;
private volatile int lineCount;
private volatile int headerLineCount;
private volatile java.lang.String headerMarker;
public void <init>()
{
org.apache.nifi.processors.standard.SplitText v;
v := @this: org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
return;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.standard.SplitText v;
v := @this: org.apache.nifi.processors.standard.SplitText;
v = <org.apache.nifi.processors.standard.SplitText: java.util.Set relationships>;
return v;
}
public void onSchedule(org.apache.nifi.processor.ProcessContext)
{
java.lang.Double v;
long v;
java.lang.Integer v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v;
org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.SplitText v;
int v, v;
java.lang.Boolean v;
java.lang.String v;
boolean v, v, v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processor.DataUnit v;
v := @this: org.apache.nifi.processors.standard.SplitText;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
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.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
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.Boolean asBoolean()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
goto label;
label:
v = 0;
label:
v.<org.apache.nifi.processors.standard.SplitText: boolean removeTrailingNewLines> = v;
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor FRAGMENT_MAX_SIZE>;
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.SplitText: org.apache.nifi.components.PropertyDescriptor FRAGMENT_MAX_SIZE>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <org.apache.nifi.processor.DataUnit: org.apache.nifi.processor.DataUnit B>;
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.Double asDataSize(org.apache.nifi.processor.DataUnit)>(v);
v = virtualinvoke v.<java.lang.Double: long longValue()>();
goto label;
label:
v = 9223372036854775807L;
label:
v.<org.apache.nifi.processors.standard.SplitText: long maxSplitSize> = v;
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
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.<org.apache.nifi.processors.standard.SplitText: int lineCount> = v;
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
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.<org.apache.nifi.processors.standard.SplitText: int headerLineCount> = v;
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_MARKER>;
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.SplitText: java.lang.String headerMarker> = v;
return;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException
{
java.util.concurrent.atomic.AtomicBoolean v;
java.util.concurrent.atomic.AtomicReference v;
java.util.ArrayList v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v;
int v;
java.lang.String v;
boolean v, v;
org.apache.nifi.processors.standard.SplitText$1 v;
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processor.ProcessSession v;
java.util.UUID v;
java.util.List v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.SplitText;
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 = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>()>();
v = new org.apache.nifi.processors.standard.SplitText$1;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText$1: void <init>(org.apache.nifi.processors.standard.SplitText,java.util.concurrent.atomic.AtomicBoolean,org.apache.nifi.flowfile.FlowFile,java.util.concurrent.atomic.AtomicReference,java.util.List)>(v, v, 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.AtomicBoolean: boolean get()>();
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.SplitText: 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);
goto label;
label:
v = staticinvoke <java.util.UUID: java.util.UUID randomUUID()>();
v = virtualinvoke v.<java.util.UUID: java.lang.String toString()>();
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.SplitText: java.util.List generateSplitFlowFiles(java.lang.String,org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processors.standard.SplitText$SplitInfo,java.util.List,org.apache.nifi.processor.ProcessSession)>(v, v, v, v, v);
v = interfaceinvoke v.<java.util.List: int size()>();
v = staticinvoke <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.FlowFile copyAttributesToOriginal(org.apache.nifi.processor.ProcessSession,org.apache.nifi.flowfile.FlowFile,java.lang.String,int)>(v, v, v, v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(java.util.Collection,org.apache.nifi.processor.Relationship)>(v, v);
label:
return;
}
protected java.util.Collection customValidate(org.apache.nifi.components.ValidationContext)
{
org.apache.nifi.components.ValidationContext v;
java.lang.Integer v;
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.ArrayList v;
org.apache.nifi.components.PropertyValue v, v;
org.apache.nifi.processors.standard.SplitText v;
int v;
org.apache.nifi.components.ValidationResult v;
boolean v, v, v;
org.apache.nifi.components.ValidationResult$Builder v, v, v, v;
v := @this: org.apache.nifi.processors.standard.SplitText;
v := @parameter: org.apache.nifi.components.ValidationContext;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
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: java.lang.Integer asInteger()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v != 0 goto label;
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor FRAGMENT_MAX_SIZE>;
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 = 1;
goto label;
label:
v = 0;
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 subject(java.lang.String)>("Maximum Fragment Size");
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder valid(boolean)>(v);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder explanation(java.lang.String)>("Property must be specified when Line Split Count is 0");
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);
return v;
}
protected java.util.List getSupportedPropertyDescriptors()
{
java.util.List v;
org.apache.nifi.processors.standard.SplitText v;
v := @this: org.apache.nifi.processors.standard.SplitText;
v = <org.apache.nifi.processors.standard.SplitText: java.util.List properties>;
return v;
}
private java.util.List generateSplitFlowFiles(java.lang.String, org.apache.nifi.flowfile.FlowFile, org.apache.nifi.processors.standard.SplitText$SplitInfo, java.util.List, org.apache.nifi.processor.ProcessSession)
{
java.util.ListIterator v;
org.apache.nifi.flowfile.FlowFile[] v;
java.lang.Integer v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processors.standard.SplitText$SplitInfo v;
byte v, v;
boolean v, v, v, v;
org.apache.nifi.flowfile.FlowFile v, v, v, v, v, v, v, v;
java.util.List v;
java.lang.Object[] v;
long v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.logging.ComponentLog v;
java.util.ArrayList v;
int v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v;
java.util.Iterator v;
org.apache.nifi.processor.ProcessSession v;
java.lang.Object v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v, v;
v := @this: org.apache.nifi.processors.standard.SplitText;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.flowfile.FlowFile;
v := @parameter: org.apache.nifi.processors.standard.SplitText$SplitInfo;
v := @parameter: java.util.List;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = null;
v = 0L;
if v == null goto label;
v = v.<org.apache.nifi.processors.standard.SplitText$SplitInfo: long startOffset>;
v = v.<org.apache.nifi.processors.standard.SplitText$SplitInfo: long length>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile clone(org.apache.nifi.flowfile.FlowFile,long,long)>(v, v, v);
v = v.<org.apache.nifi.processors.standard.SplitText$SplitInfo: long trimmedLength>;
label:
v = 1;
v = interfaceinvoke v.<java.util.List: int size()>();
if v != 0 goto label;
if v == null goto label;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = v - v;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile clone(org.apache.nifi.flowfile.FlowFile,long,long)>(v, 0L, v);
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v = specialinvoke v.<org.apache.nifi.processors.standard.SplitText: org.apache.nifi.flowfile.FlowFile updateAttributes(org.apache.nifi.processor.ProcessSession,org.apache.nifi.flowfile.FlowFile,long,long,java.lang.String,int,java.lang.String)>(v, v, 0L, v, v, 1, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = interfaceinvoke v.<java.util.List: 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()>();
interfaceinvoke v.<java.util.Iterator: void remove()>();
v = v.<org.apache.nifi.processors.standard.SplitText: boolean removeTrailingNewLines>;
if v == 0 goto label;
v = v.<org.apache.nifi.processors.standard.SplitText$SplitInfo: long trimmedLength>;
goto label;
label:
v = v.<org.apache.nifi.processors.standard.SplitText$SplitInfo: long length>;
label:
v = v;
if v != null goto label;
v = v cmp 0L;
if v <= 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
if v == 0 goto label;
if v == null goto label;
v = v cmp 0L;
if v <= 0 goto label;
v = v.<org.apache.nifi.processors.standard.SplitText$SplitInfo: long startOffset>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile clone(org.apache.nifi.flowfile.FlowFile,long,long)>(v, v, v);
v = newarray (org.apache.nifi.flowfile.FlowFile)[2];
v[0] = v;
v[1] = v;
v = specialinvoke v.<org.apache.nifi.processors.standard.SplitText: org.apache.nifi.flowfile.FlowFile concatenateContents(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.ProcessSession,org.apache.nifi.flowfile.FlowFile[])>(v, v, v);
goto label;
label:
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = v - v;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile clone(org.apache.nifi.flowfile.FlowFile,long,long)>(v, 0L, v);
goto label;
label:
v = v.<org.apache.nifi.processors.standard.SplitText$SplitInfo: long startOffset>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile clone(org.apache.nifi.flowfile.FlowFile,long,long)>(v, v, v);
label:
v = v.<org.apache.nifi.processors.standard.SplitText$SplitInfo: long lineCount>;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = v;
v = v + 1;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v = specialinvoke v.<org.apache.nifi.processors.standard.SplitText: org.apache.nifi.flowfile.FlowFile updateAttributes(org.apache.nifi.processor.ProcessSession,org.apache.nifi.flowfile.FlowFile,long,long,java.lang.String,int,java.lang.String)>(v, v, v, v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v - 1;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
v = interfaceinvoke v.<java.util.List: java.util.ListIterator listIterator()>();
label:
v = interfaceinvoke v.<java.util.ListIterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.ListIterator: java.lang.Object next()>();
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
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);
interfaceinvoke v.<java.util.ListIterator: void set(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.SplitText: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[3];
v[0] = v;
v = interfaceinvoke v.<java.util.List: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
if v != null goto label;
v = " containing headers.";
goto label;
label:
v = ".";
label:
v[2] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("Split {} into {} FlowFiles{}", v);
if v == null goto label;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void remove(org.apache.nifi.flowfile.FlowFile)>(v);
label:
return v;
}
private transient org.apache.nifi.flowfile.FlowFile concatenateContents(org.apache.nifi.flowfile.FlowFile, org.apache.nifi.processor.ProcessSession, org.apache.nifi.flowfile.FlowFile[])
{
org.apache.nifi.flowfile.FlowFile v, v, v, v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.processors.standard.SplitText v;
int v, v;
org.apache.nifi.processors.standard.SplitText$2 v;
v := @this: org.apache.nifi.processors.standard.SplitText;
v := @parameter: org.apache.nifi.flowfile.FlowFile;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v := @parameter: org.apache.nifi.flowfile.FlowFile[];
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile create(org.apache.nifi.flowfile.FlowFile)>(v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = new org.apache.nifi.processors.standard.SplitText$2;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText$2: void <init>(org.apache.nifi.processors.standard.SplitText,org.apache.nifi.processor.ProcessSession,org.apache.nifi.flowfile.FlowFile)>(v, v, v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile append(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.OutputStreamCallback)>(v, v);
v = v + 1;
goto label;
label:
v = v[1];
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void remove(org.apache.nifi.flowfile.FlowFile)>(v);
return v;
}
private org.apache.nifi.flowfile.FlowFile updateAttributes(org.apache.nifi.processor.ProcessSession, org.apache.nifi.flowfile.FlowFile, long, long, java.lang.String, int, java.lang.String)
{
java.util.HashMap v;
long v, v, v;
org.apache.nifi.processors.standard.SplitText v;
int v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processor.ProcessSession v;
v := @this: org.apache.nifi.processors.standard.SplitText;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v := @parameter: org.apache.nifi.flowfile.FlowFile;
v := @parameter: long;
v := @parameter: long;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: java.lang.String;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("text.line.count", v);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_SIZE>;
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_ID>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_INDEX>;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String SEGMENT_ORIGINAL_FILENAME>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAllAttributes(org.apache.nifi.flowfile.FlowFile,java.util.Map)>(v, v);
return v;
}
private org.apache.nifi.processors.standard.SplitText$SplitInfo computeHeader(org.apache.nifi.stream.io.util.TextLineDemarcator, long, long, byte[], org.apache.nifi.processors.standard.SplitText$SplitInfo) throws java.io.IOException
{
byte[] v;
java.lang.IllegalStateException v;
long v, v, v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processors.standard.SplitText$SplitInfo v, v, v;
byte v, v, v;
int v, v, v;
java.lang.String v;
boolean v;
org.apache.nifi.stream.io.util.TextLineDemarcator v;
org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo v, v;
v := @this: org.apache.nifi.processors.standard.SplitText;
v := @parameter: org.apache.nifi.stream.io.util.TextLineDemarcator;
v := @parameter: long;
v := @parameter: long;
v := @parameter: byte[];
v := @parameter: org.apache.nifi.processors.standard.SplitText$SplitInfo;
v = 0L;
v = 0L;
v = null;
v = null;
label:
v = virtualinvoke v.<org.apache.nifi.stream.io.util.TextLineDemarcator: org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo nextOffsetInfo(byte[])>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo: int getCrlfLength()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo: boolean isStartsWithMatch()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo: int getCrlfLength()>();
v = (int) -1;
if v == v goto label;
v = v;
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo: long getLength()>();
v = v + v;
v = v.<org.apache.nifi.processors.standard.SplitText: long maxSplitSize>;
v = v cmp v;
if v <= 0 goto label;
v = new java.lang.IllegalStateException;
v = v.<org.apache.nifi.processors.standard.SplitText: long maxSplitSize>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(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[])>("Computing header resulted in header size being > MAX split size of \u.");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo: long getLength()>();
v = v + v;
v = v + 1L;
v = v cmp v;
if v != 0 goto label;
label:
v = v cmp 0L;
if v <= 0 goto label;
v = new org.apache.nifi.processors.standard.SplitText$SplitInfo;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText$SplitInfo: void <init>(org.apache.nifi.processors.standard.SplitText,long,long,long,long,org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo)>(v, v, v, v, v, v);
v = v;
label:
return v;
}
private org.apache.nifi.processors.standard.SplitText$SplitInfo nextSplit(org.apache.nifi.stream.io.util.TextLineDemarcator, long, long, org.apache.nifi.processors.standard.SplitText$SplitInfo, long) throws java.io.IOException
{
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processors.standard.SplitText$SplitInfo v, v, v;
byte v, v, v, v, v, v, v, v;
org.apache.nifi.stream.io.util.TextLineDemarcator v;
org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo v, v, v, v;
long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
int v, v, v, v;
v := @this: org.apache.nifi.processors.standard.SplitText;
v := @parameter: org.apache.nifi.stream.io.util.TextLineDemarcator;
v := @parameter: long;
v := @parameter: long;
v := @parameter: org.apache.nifi.processors.standard.SplitText$SplitInfo;
v := @parameter: long;
v = 0L;
v = 0L;
v = 0L;
v = 0L;
v = null;
if v == null goto label;
v = v.<org.apache.nifi.processors.standard.SplitText$SplitInfo: org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo remaningOffsetInfo>;
if v == null goto label;
v = v.<org.apache.nifi.processors.standard.SplitText$SplitInfo: org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo remaningOffsetInfo>;
v = virtualinvoke v.<org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo: long getLength()>();
v = 0L + v;
v = 1L;
label:
v = null;
label:
v = virtualinvoke v.<org.apache.nifi.stream.io.util.TextLineDemarcator: org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo nextOffsetInfo()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo: int getCrlfLength()>();
v = virtualinvoke v.<org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo: long getLength()>();
v = v + v;
v = v + v;
v = v.<org.apache.nifi.processors.standard.SplitText: long maxSplitSize>;
v = v cmp v;
if v <= 0 goto label;
v = v cmp 0L;
if v != 0 goto label;
v = virtualinvoke v.<org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo: long getLength()>();
v = v + v;
v = v + 1L;
goto label;
label:
v = v;
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo: long getLength()>();
v = virtualinvoke v.<org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo: int getCrlfLength()>();
v = v cmp v;
if v != 0 goto label;
v = virtualinvoke v.<org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo: int getCrlfLength()>();
v = v + v;
v = v + 1L;
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo: long getLength()>();
v = virtualinvoke v.<org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo: int getCrlfLength()>();
v = v cmp v;
if v <= 0 goto label;
v = 0L;
label:
v = virtualinvoke v.<org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo: long getLength()>();
v = v + v;
v = v + 1L;
v = v cmp 0L;
if v <= 0 goto label;
v = v cmp v;
if v < 0 goto label;
label:
v = v cmp 0L;
if v <= 0 goto label;
v = v - v;
v = v cmp v;
if v < 0 goto label;
v = v + v;
label:
v = v - v;
v = new org.apache.nifi.processors.standard.SplitText$SplitInfo;
v = v - v;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText$SplitInfo: void <init>(org.apache.nifi.processors.standard.SplitText,long,long,long,long,org.apache.nifi.stream.io.util.TextLineDemarcator$OffsetInfo)>(v, v, v, v, v, v);
v = v;
label:
return v;
}
static void <clinit>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v, v, v, v, v;
java.util.Set v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v;
java.lang.String v, v, v, v, v;
org.apache.nifi.components.PropertyDescriptor[] 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;
java.util.List v, v, v;
org.apache.nifi.processor.Relationship[] v;
java.lang.String[] v;
java.util.HashSet v;
org.apache.nifi.components.Validator v, v, v, v, v;
org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v, v, v, v;
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_SIZE>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
<org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_SIZE> = v;
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_ID>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
<org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_ID> = v;
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_INDEX>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
<org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_INDEX> = v;
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
<org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT> = v;
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes SEGMENT_ORIGINAL_FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
<org.apache.nifi.processors.standard.SplitText: java.lang.String SEGMENT_ORIGINAL_FILENAME> = 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)>("Line Split Count");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The number of lines that will be added to each split file, excluding header lines. A value of zero requires Maximum Fragment Size to be set, and line count will not be considered in determining splits.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_NEGATIVE_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 build()>();
<org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT> = 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)>("Maximum Fragment Size");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The maximum size of each split file, including header lines. NOTE: in the case where a single line exceeds this property (including headers, if applicable), that line will be output in a split of its own which exceeds this Maximum Fragment Size setting.");
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 DATA_SIZE_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 build()>();
<org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor FRAGMENT_MAX_SIZE> = 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)>("Header Line Count");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The number of lines that should be considered part of the header; the header lines will be duplicated to all split files");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_NEGATIVE_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)>("0");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT> = 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)>("Header Line Marker Characters");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("The first character(s) on the line of the datafile which signifies a header line. This value is ignored when Header Line Count is non-zero. The first line not containing the Header Line Marker Characters and all subsequent lines are considered non-header");
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 NON_EMPTY_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 build()>();
<org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_MARKER> = 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)>("Remove Trailing Newlines");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Whether to remove newlines at the end of each split file. This should be false if you intend to merge the split files later. If this is set to \'true\' and a FlowFile is generated that contains only \'empty lines\' (i.e., consists only of \\r and \\n characters), the FlowFile will not be emitted. Note, however, that if header lines are specified, the resultant FlowFile will never be empty as it will consist of the header lines, so a FlowFile may be emitted that contains only the header lines.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator BOOLEAN_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = newarray (java.lang.String)[2];
v[0] = "true";
v[1] = "false";
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)>("true");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES> = 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)>("original");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("The original input file will be routed to this destination when it has been successfully split into 1 or more files");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL> = 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)>("splits");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("The split files will be routed to this destination when an input file is successfully split into 1 or more split files");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS> = 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 a file cannot be split for some reason, the original file will be routed to this destination and nothing will be routed elsewhere");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE> = v;
v = newarray (org.apache.nifi.components.PropertyDescriptor)[5];
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
v[0] = v;
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor FRAGMENT_MAX_SIZE>;
v[1] = v;
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
v[2] = v;
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_MARKER>;
v[3] = v;
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
v[4] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
<org.apache.nifi.processors.standard.SplitText: java.util.List properties> = v;
v = new java.util.HashSet;
v = newarray (org.apache.nifi.processor.Relationship)[3];
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v[0] = v;
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v[1] = v;
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
v[2] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
<org.apache.nifi.processors.standard.SplitText: java.util.Set relationships> = v;
return;
}
}