public class org.apache.nifi.processors.standard.TestSplitText extends java.lang.Object
{
final java.lang.String originalFilename;
final java.nio.file.Path dataPath;
final java.nio.file.Path file;
static final java.lang.String TEST_INPUT_DATA;
public void <init>()
{
java.lang.String[] v;
org.apache.nifi.processors.standard.TestSplitText v;
java.nio.file.Path v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.nifi.processors.standard.TestSplitText: java.lang.String originalFilename> = "original.txt";
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>("src/test/resources/TestSplitText", v);
v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path dataPath> = v;
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path dataPath>;
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path resolve(java.lang.String)>("original.txt");
v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file> = v;
return;
}
public void testLastLineExceedsSizeLimit()
{
org.apache.nifi.components.PropertyDescriptor v, v, v;
java.util.List v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.lang.String v, v;
org.apache.nifi.processors.standard.TestSplitText v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor FRAGMENT_MAX_SIZE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "20 B");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("Line #1\nLine #2\nLine #3\nLong line exceeding limit");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "3");
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_ID>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 3);
return;
}
public void testIncompleteHeader()
{
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestSplitText v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor FRAGMENT_MAX_SIZE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "50 B");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("Header Line #1");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
return;
}
public void testSingleCharacterHeaderMarker() throws java.io.IOException
{
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestSplitText v;
java.nio.file.Path v, v, v;
java.util.List v, v;
org.apache.nifi.processor.Relationship v, v, v, v, v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v;
java.lang.Object v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "7");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_MARKER>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "H");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("fragment.count", "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 2);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("text.line.count", "7");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_SIZE>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "86");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("text.line.count", "3");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_SIZE>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "54");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_ID>;
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: java.lang.String getAttribute(java.lang.String)>(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 = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_INDEX>;
v = v + 1;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_ID>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String SEGMENT_ORIGINAL_FILENAME>;
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path getFileName()>();
v = interfaceinvoke v.<java.nio.file.Path: java.lang.String toString()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = v + 1;
goto label;
label:
return;
}
public void testMultipleHeaderIndicators() throws java.io.IOException
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestSplitText v;
java.nio.file.Path v, v, v;
java.util.List v, v;
org.apache.nifi.processor.Relationship v, v, v, v, v;
int v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Object v, v, v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_MARKER>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "Head");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "5");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("fragment.count", "3");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 3);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("text.line.count", "5");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_SIZE>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "62");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("text.line.count", "5");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_SIZE>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "55");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("text.line.count", "1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_SIZE>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "23");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_ID>;
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: java.lang.String getAttribute(java.lang.String)>(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 = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_INDEX>;
v = v + 1;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_ID>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String SEGMENT_ORIGINAL_FILENAME>;
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path getFileName()>();
v = interfaceinvoke v.<java.nio.file.Path: java.lang.String toString()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = v + 1;
goto label;
label:
return;
}
public void testZeroLinesNoMaxSize()
{
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestSplitText v;
org.apache.nifi.components.PropertyDescriptor v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertNotValid()>();
return;
}
public void testMultipleSplitDirectives()
{
long v, v, v, v, v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v, v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestSplitText v;
java.util.List v, v;
java.lang.Object v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor FRAGMENT_MAX_SIZE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "50 B");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("Header Line #1\nHeader Line #2\nLine #1\nLine #2\nLine #3 This line has additional text added so that it exceeds the maximum fragment size\nLine #4\nLine #5\nLine #6\nLine #7\nLine #8\nLine #9\nLine #10\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("fragment.count", "6");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 6);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: long getSize()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(46L, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: long getSize()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(119L, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: long getSize()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(46L, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(3);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: long getSize()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(46L, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(4);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: long getSize()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(46L, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(5);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: long getSize()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(39L, v);
return;
}
public void testFlowFileIsOnlyHeader()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestSplitText v;
java.util.List v, v, v;
java.lang.Object v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor FRAGMENT_MAX_SIZE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "50 B");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_MARKER>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "Head");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("Header Line #1\nHeaderLine#2\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("fragment.count", "1");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor FRAGMENT_MAX_SIZE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "50 B");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("Header Line #1\nHeaderLine #2\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("fragment.count", "1");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor FRAGMENT_MAX_SIZE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "50 B");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("Header Line #1");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("fragment.count", "1");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
public void testMaxSizeExceeded() throws java.io.IOException
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v;
java.nio.file.Path v, v, v, v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v, v, v;
java.lang.String 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.processors.standard.SplitText v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestSplitText v;
java.util.List v, v, v, v;
int v, v, v, v;
java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor FRAGMENT_MAX_SIZE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "71 B");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 2);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_ID>;
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: java.lang.String getAttribute(java.lang.String)>(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);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("text.line.count", "5");
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_SIZE>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "70");
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_INDEX>;
v = v + 1;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_ID>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String SEGMENT_ORIGINAL_FILENAME>;
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path getFileName()>();
v = interfaceinvoke v.<java.nio.file.Path: java.lang.String toString()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = v + 1;
goto label;
label:
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor FRAGMENT_MAX_SIZE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "71 B");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 2);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_ID>;
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("Header Line #1\nHeader Line #2\nLine #1\nLine #2\nLine #3\nLine #4\nLine #5\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("Line #6\nLine #7\nLine #8\nLine #9\nLine #10");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("text.line.count", "7");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_SIZE>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "70");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_INDEX>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_ID>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "2");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String SEGMENT_ORIGINAL_FILENAME>;
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path getFileName()>();
v = interfaceinvoke v.<java.nio.file.Path: java.lang.String toString()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("text.line.count", "5");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_SIZE>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "40");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_INDEX>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "2");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_ID>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "2");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String SEGMENT_ORIGINAL_FILENAME>;
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path getFileName()>();
v = interfaceinvoke v.<java.nio.file.Path: java.lang.String toString()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
return;
}
public void testSplitWithOnlyCarriageReturn()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v;
org.apache.nifi.processors.standard.TestSplitText v;
java.util.List v, v, v, v;
java.lang.Object v, v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "3");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("H1\rH2\r1\r2\r3\r\r\r\r\r\r\r10\r11\r12\r");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "4");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 4);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1\rH2\r1\r2\r3");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1\rH2");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1\rH2");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(3);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1\rH2\r10\r11\r12");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "3");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("1\r2\r3\r\r\r\r\r\r\r10\r11\r12\r");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 2);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("1\r2\r3");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("10\r11\r12");
return;
}
public void testSplitWithCarriageReturnAndNewLines()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v;
org.apache.nifi.processors.standard.TestSplitText v;
java.util.List v, v, v, v;
java.lang.Object v, v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "3");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("H1\r\nH2\r\n1\r\n2\r\n3\r\n\r\n\r\n\r\n\r\n\r\n\r\n10\r\n11\r\n12\r\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "4");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 4);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1\r\nH2\r\n1\r\n2\r\n3");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1\r\nH2");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1\r\nH2");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(3);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1\r\nH2\r\n10\r\n11\r\n12");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "3");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("1\r\n2\r\n3\r\n\r\n\r\n\r\n\r\n\r\n\r\n10\r\n11\r\n12\r\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 2);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("1\r\n2\r\n3");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("10\r\n11\r\n12");
return;
}
public void testRoutesToFailureIfHeaderLinesNotAllPresent() throws java.io.IOException
{
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestSplitText v;
java.nio.file.Path v;
org.apache.nifi.components.PropertyDescriptor v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "100");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "3");
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
public void testZeroByteOutput() throws java.io.IOException
{
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestSplitText v;
java.nio.file.Path v;
org.apache.nifi.components.PropertyDescriptor v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "3");
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 4);
return;
}
public void testZeroByteInputWithoutHeader() throws java.io.IOException
{
byte[] v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v;
org.apache.nifi.processors.standard.TestSplitText v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = "";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[])>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
return;
}
public void testZeroByteInput() throws java.io.IOException
{
byte[] v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v;
org.apache.nifi.processors.standard.TestSplitText v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = "";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[])>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
return;
}
public void testSplitWithoutHeader() throws java.io.IOException
{
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v;
org.apache.nifi.processors.standard.TestSplitText v;
java.nio.file.Path v;
java.util.List v, v;
java.lang.Object v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "3");
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "4");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 4);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("Header Line #1\nHeader Line #2\nLine #1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("Line #2\nLine #3\nLine #4");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("Line #5\nLine #6\nLine #7");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(3);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("Line #8\nLine #9\nLine #10");
return;
}
public void testOneLineSplitWithoutHeader() throws java.io.IOException
{
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v;
org.apache.nifi.processors.standard.TestSplitText v;
java.util.List v, v;
java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("HeaderLine1\nLine2SpacesAtEnd  \nLine3\nLine4\n\n\nLine8\nLine9\n\n\n13\n14\n    EndofLine15\n16\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\nLastLine\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "11");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 11);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("Line2SpacesAtEnd  ");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("Line3");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(3);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("Line4");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("Line8");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(5);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("Line9");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(6);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("13");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(7);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("14");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(8);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("15    EndofLine15");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(9);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("16");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(10);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("LastLine");
return;
}
public void testFiveLineSplitWithoutHeader() throws java.io.IOException
{
org.apache.nifi.components.PropertyDescriptor v, v;
java.util.List v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v, v, v, v;
org.apache.nifi.processors.standard.TestSplitText v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "5");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("HeaderLine1\nLine2SpacesAtEnd  \nLine3\nLine4\n\n\nLine8\nLine9\n\n\n13\n14\n    EndofLine15\n16\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\nLastLine\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 4);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\nLine2SpacesAtEnd  \nLine3\nLine4");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("\nLine8\nLine9");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("13\n14\n    EndofLine15\n16");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(3);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("\n\nLastLine");
return;
}
public void testFiveLineSplitWithoutHeaderRetainNewline() throws java.io.IOException
{
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestSplitText v;
java.util.List v;
java.lang.Object v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "5");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("HeaderLine1\nLine2SpacesAtEnd  \nLine3\nLine4\n\n\nLine8\nLine9\n\n\n13\n14\n    EndofLine15\n16\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\nLastLine\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 10);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\nLine2SpacesAtEnd  \nLine3\nLine4\n\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("\nLine8\nLine9\n\n\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("13\n14\n    EndofLine15\n16\n\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(3);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("\n\n\n\n\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("\n\n\n\n\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(5);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("\n\n\n\n\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(6);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("\n\n\n\n\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(7);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("\n\n\n\n\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(8);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("\n\n\n\n\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(9);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("\n\nLastLine\n");
return;
}
public void testFiveLineSplitWithHeaderRetainNewline() throws java.io.IOException
{
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestSplitText v;
java.util.List v;
java.lang.Object v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "5");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("HeaderLine1\nLine2SpacesAtEnd  \nLine3\nLine4\n\n\nLine8\nLine9\n\n\n13\n14\n    EndofLine15\n16\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\nLastLine\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 10);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\nLine2SpacesAtEnd  \nLine3\nLine4\n\n\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\nLine8\nLine9\n\n\n13\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\n14\n    EndofLine15\n16\n\n\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(3);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\n\n\n\n\n\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\n\n\n\n\n\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(5);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\n\n\n\n\n\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(6);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\n\n\n\n\n\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(7);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\n\n\n\n\n\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(8);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\n\n\n\n\n\n");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(9);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\n\nLastLine\n");
return;
}
public void testFiveLineSplitWithHeaderNotRetainNewline() throws java.io.IOException
{
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestSplitText v;
java.util.List v;
java.lang.Object v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "5");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("HeaderLine1\nLine2SpacesAtEnd  \nLine3\nLine4\n\n\nLine8\nLine9\n\n\n13\n14\n    EndofLine15\n16\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\nLastLine\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 10);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\nLine2SpacesAtEnd  \nLine3\nLine4");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\nLine8\nLine9\n\n\n13");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\n14\n    EndofLine15\n16");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(3);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(5);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(6);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(7);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(8);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(9);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\n\nLastLine");
return;
}
public void testOneLineSplitWithHeader() throws java.io.IOException
{
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
int v;
org.apache.nifi.processors.standard.TestSplitText v;
java.util.List v;
java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("HeaderLine1\nLine2SpacesAtEnd  \nLine3\nLine4\n\n\nLine8\nLine9\n\n\n13\n14\n    EndofLine15\n16\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\nLastLine\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 47);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\nLine2SpacesAtEnd  ");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\nLine3");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\nLine4");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(3);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(4);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(5);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\nLine8");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(6);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\nLine9");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(7);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(8);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(9);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\n13");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(10);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\n14");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(11);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\n    EndofLine15");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(12);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\n16");
v = 13;
label:
if v >= 46 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1");
v = v + 1;
goto label;
label:
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(46);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("HeaderLine1\nLastLine");
return;
}
public void testSplitWithTwoLineHeader() throws java.io.IOException
{
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
int v, v, v, v;
java.lang.String v, v, v;
org.apache.nifi.processors.standard.TestSplitText v;
java.nio.file.Path v, v, v, v;
java.util.List v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "3");
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 4);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(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 = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path getParent()>();
v = v + 1;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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.txt");
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path resolve(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_INDEX>;
v = v + 1;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = v + 1;
goto label;
label:
return;
}
public void testSplitWithTwoLineHeaderAndEvenMultipleOfLines() throws java.io.IOException
{
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
org.apache.nifi.processors.standard.TestSplitText v;
java.nio.file.Path v, v, v, v, v, v, v;
java.util.List v;
java.lang.Object v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "5");
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 2);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path getParent()>();
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path resolve(java.lang.String)>("5.txt");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_INDEX>;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path getParent()>();
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path resolve(java.lang.String)>("6.txt");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_INDEX>;
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(2);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
return;
}
public void testSplitThenMerge() throws java.io.IOException
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.util.TestRunner v, v;
org.apache.nifi.processors.standard.TestSplitText v;
java.nio.file.Path v, v, v, v;
boolean v;
org.apache.nifi.util.MockFlowFile[] v;
org.apache.nifi.components.AllowableValue v, v;
java.util.List v, v;
java.lang.Object[] v;
long v, v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.MergeContent v;
java.lang.String v, v, v;
java.util.Iterator v;
java.lang.Object v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "3");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 4);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
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()>();
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String SEGMENT_ORIGINAL_FILENAME>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "original.txt");
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "4");
goto label;
label:
v = new org.apache.nifi.processors.standard.MergeContent;
specialinvoke v.<org.apache.nifi.processors.standard.MergeContent: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.MergeContent: org.apache.nifi.components.PropertyDescriptor MERGE_FORMAT>;
v = <org.apache.nifi.processors.standard.MergeContent: org.apache.nifi.components.AllowableValue MERGE_FORMAT_CONCAT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.AllowableValue)>(v, v);
v = <org.apache.nifi.processors.standard.MergeContent: org.apache.nifi.components.PropertyDescriptor MERGE_STRATEGY>;
v = <org.apache.nifi.processors.standard.MergeContent: org.apache.nifi.components.AllowableValue MERGE_STRATEGY_DEFRAGMENT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.AllowableValue)>(v, v);
v = newarray (org.apache.nifi.util.MockFlowFile)[0];
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray(java.lang.Object[])>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void enqueue(org.apache.nifi.flowfile.FlowFile[])>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.MergeContent: org.apache.nifi.processor.Relationship REL_MERGED>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.MergeContent: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 4);
v = <org.apache.nifi.processors.standard.MergeContent: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.MergeContent: org.apache.nifi.processor.Relationship REL_MERGED>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
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()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "original.txt");
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path dataPath>;
v = interfaceinvoke v.<java.nio.file.Path: java.nio.file.Path resolve(java.lang.String)>("original.txt");
v = staticinvoke <java.nio.file.Files: long size(java.nio.file.Path)>(v);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: long getSize()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(long,long)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestSplitText: java.nio.file.Path file>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
return;
}
public void testSplitWithOnlyNewLines()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestSplitText v;
java.util.List v, v;
java.lang.Object v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "3");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("H1\nH2\n1\n2\n3\n\n\n\n\n\n\n10\n11\n12\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 4);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1\nH2\n1\n2\n3");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1\nH2");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1\nH2");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(3);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1\nH2\n10\n11\n12");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "3");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("1\n2\n3\n\n\n\n\n\n\n10\n11\n12\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 2);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("1\n2\n3");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("10\n11\n12");
return;
}
public void testWithLotsOfBlankLinesAtEnd()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestSplitText v;
java.util.List v, v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "10");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("H1\nH2\n1\n\n\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1\nH2\n1");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("1\n2\n\n\n\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("1\n2");
return;
}
public void testAllNewLinesTrimmed()
{
org.apache.nifi.components.PropertyDescriptor v, v, v;
java.util.List v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.lang.String v, v;
org.apache.nifi.processors.standard.TestSplitText v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "3");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("1\n2\n\n\n\n\n\n\n\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("1\n2");
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_INDEX>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("text.line.count", "2");
return;
}
public void testFragmentCountIsActualFlowFileCount()
{
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
org.apache.nifi.processors.standard.TestSplitText v;
java.util.List v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("1\n2\n\n\n\n\n\n\n\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 2);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("1");
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_INDEX>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "2");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("text.line.count", "1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("2");
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_INDEX>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: java.lang.String FRAGMENT_COUNT>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "2");
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>("text.line.count", "1");
return;
}
public void testConsistentTrailingOfNewLines()
{
org.apache.nifi.components.PropertyDescriptor v, v, v;
java.util.List v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v, v, v;
org.apache.nifi.processors.standard.TestSplitText v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "3");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("H1\n1\n\n\n\n\n\n\n\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 3);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1\n1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1");
return;
}
public void testWithSplitThatStartsWithNewLine()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestSplitText v;
java.util.List v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "3");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("H1\n1\n2\n3\n\n\n4\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 2);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1\n1\n2\n3");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("H1\n\n\n4");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("1\n2\n3\n\n\n4\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 2);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("1\n2\n3");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("\n\n4");
return;
}
public void testWithEmptyHeaderLines()
{
org.apache.nifi.components.PropertyDescriptor v, v, v;
java.util.List v;
org.apache.nifi.processors.standard.SplitText v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v, v;
org.apache.nifi.processors.standard.TestSplitText v;
v := @this: org.apache.nifi.processors.standard.TestSplitText;
v = new org.apache.nifi.processors.standard.SplitText;
specialinvoke v.<org.apache.nifi.processors.standard.SplitText: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor HEADER_LINE_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor LINE_SPLIT_COUNT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "3");
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.components.PropertyDescriptor REMOVE_TRAILING_NEWLINES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String)>("\n\n1\n\n\n\n\n");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 2);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_ORIGINAL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = <org.apache.nifi.processors.standard.SplitText: org.apache.nifi.processor.Relationship REL_SPLITS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("\n\n1");
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("\n");
return;
}
}