public class org.apache.nifi.processors.standard.TestSplitJson extends java.lang.Object
{
private static final java.nio.file.Path JSON_SNIPPET;
private static final java.nio.file.Path XML_SNIPPET;
public void <init>()
{
org.apache.nifi.processors.standard.TestSplitJson v;
v := @this: org.apache.nifi.processors.standard.TestSplitJson;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void testInvalidJsonPath()
{
org.apache.nifi.processors.standard.SplitJson v;
org.apache.nifi.processors.standard.TestSplitJson v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.components.PropertyDescriptor v;
v := @this: org.apache.nifi.processors.standard.TestSplitJson;
v = new org.apache.nifi.processors.standard.SplitJson;
specialinvoke v.<org.apache.nifi.processors.standard.SplitJson: 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.SplitJson: org.apache.nifi.components.PropertyDescriptor ARRAY_JSON_PATH_EXPRESSION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "$..");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertNotValid()>();
return;
}
public void testInvalidJsonDocument() throws java.lang.Exception
{
org.apache.nifi.components.PropertyDescriptor v;
java.util.List v;
org.apache.nifi.processors.standard.SplitJson v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.processors.standard.TestSplitJson v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.nio.file.Path v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitJson;
v = new org.apache.nifi.processors.standard.SplitJson;
specialinvoke v.<org.apache.nifi.processors.standard.SplitJson: 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.SplitJson: org.apache.nifi.components.PropertyDescriptor ARRAY_JSON_PATH_EXPRESSION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "$");
v = <org.apache.nifi.processors.standard.TestSplitJson: java.nio.file.Path XML_SNIPPET>;
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.SplitJson: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitJson: org.apache.nifi.processor.Relationship REL_FAILURE>;
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.TestSplitJson: java.nio.file.Path XML_SNIPPET>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
return;
}
public void testSplit_nonArrayResult() throws java.lang.Exception
{
org.apache.nifi.components.PropertyDescriptor v;
java.util.List v;
org.apache.nifi.processors.standard.SplitJson v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.processors.standard.TestSplitJson v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.nio.file.Path v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitJson;
v = new org.apache.nifi.processors.standard.SplitJson;
specialinvoke v.<org.apache.nifi.processors.standard.SplitJson: 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.SplitJson: org.apache.nifi.components.PropertyDescriptor ARRAY_JSON_PATH_EXPRESSION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "$[0]._id");
v = <org.apache.nifi.processors.standard.TestSplitJson: java.nio.file.Path JSON_SNIPPET>;
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.SplitJson: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
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.TestSplitJson: java.nio.file.Path JSON_SNIPPET>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
return;
}
public void testSplit_arrayResult_oneValue() throws java.lang.Exception
{
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.processors.standard.SplitJson v;
org.apache.nifi.processor.Relationship v, v, v, v, v;
org.apache.nifi.processors.standard.TestSplitJson v;
org.apache.nifi.util.TestRunner v;
java.lang.String v;
java.nio.file.Path v, v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
java.util.List v, v, v;
java.lang.Object v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitJson;
v = new org.apache.nifi.processors.standard.SplitJson;
specialinvoke v.<org.apache.nifi.processors.standard.SplitJson: 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.SplitJson: org.apache.nifi.components.PropertyDescriptor ARRAY_JSON_PATH_EXPRESSION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "$[0].range[?(@ == 0)]");
v = <org.apache.nifi.processors.standard.TestSplitJson: java.nio.file.Path JSON_SNIPPET>;
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.SplitJson: 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.SplitJson: 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.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "1");
v = <org.apache.nifi.processors.standard.SplitJson: org.apache.nifi.processor.Relationship REL_SPLIT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.SplitJson: 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.TestSplitJson: java.nio.file.Path JSON_SNIPPET>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
v = <org.apache.nifi.processors.standard.SplitJson: org.apache.nifi.processor.Relationship REL_SPLIT>;
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)>("0");
return;
}
public void testSplit_arrayResult_multipleValues() throws java.lang.Exception
{
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.processors.standard.SplitJson v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.processors.standard.TestSplitJson v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v;
java.nio.file.Path v, v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v;
java.util.List v, v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitJson;
v = new org.apache.nifi.processors.standard.SplitJson;
specialinvoke v.<org.apache.nifi.processors.standard.SplitJson: 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.SplitJson: org.apache.nifi.components.PropertyDescriptor ARRAY_JSON_PATH_EXPRESSION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "$[0].range");
v = <org.apache.nifi.processors.standard.TestSplitJson: java.nio.file.Path JSON_SNIPPET>;
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.SplitJson: 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.SplitJson: 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.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(10);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.SplitJson: org.apache.nifi.processor.Relationship REL_SPLIT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 10);
v = <org.apache.nifi.processors.standard.SplitJson: 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.TestSplitJson: java.nio.file.Path JSON_SNIPPET>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
return;
}
public void testSplit_change_jsonpath() throws java.lang.Exception
{
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.util.TestRunner v;
java.util.Map v;
java.nio.file.Path v, v, v, v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v, v, v;
java.util.List v, v, v, v;
org.apache.nifi.processors.standard.SplitJson v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.TestSplitJson v;
java.lang.String v, v, v, v, v;
java.lang.Object v, v, v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.TestSplitJson;
v = new org.apache.nifi.processors.standard.SplitJson;
specialinvoke v.<org.apache.nifi.processors.standard.SplitJson: 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.SplitJson: org.apache.nifi.components.PropertyDescriptor ARRAY_JSON_PATH_EXPRESSION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "$[0].range");
v = <org.apache.nifi.processors.standard.TestSplitJson: java.nio.file.Path JSON_SNIPPET>;
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.SplitJson: 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.SplitJson: 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.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
v = staticinvoke <java.lang.String: java.lang.String valueOf(int)>(10);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.SplitJson: org.apache.nifi.processor.Relationship REL_SPLIT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 10);
v = <org.apache.nifi.processors.standard.SplitJson: 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.TestSplitJson: java.nio.file.Path JSON_SNIPPET>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void clearTransferState()>();
v = <org.apache.nifi.processors.standard.SplitJson: org.apache.nifi.components.PropertyDescriptor ARRAY_JSON_PATH_EXPRESSION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "$[*].name");
v = <org.apache.nifi.processors.standard.TestSplitJson: java.nio.file.Path JSON_SNIPPET>;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>(v, "test.json");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path,java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitJson: 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.SplitJson: 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.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_ID>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>(v);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "7");
v = <org.apache.nifi.processors.standard.TestSplitJson: java.nio.file.Path JSON_SNIPPET>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
v = <org.apache.nifi.processors.standard.SplitJson: org.apache.nifi.processor.Relationship REL_SPLIT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 7);
v = <org.apache.nifi.processors.standard.SplitJson: org.apache.nifi.processor.Relationship REL_SPLIT>;
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)>("{\"first\":\"Shaffer\",\"last\":\"Pearson\"}");
return;
}
public void testSplit_arrayResult_nonScalarValues() throws java.lang.Exception
{
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.util.TestRunner v;
java.nio.file.Path v, v;
org.apache.nifi.flowfile.attributes.FragmentAttributes v, v, v, v, v, v, v, v;
java.util.List v, v, v;
org.apache.nifi.processors.standard.SplitJson v;
org.apache.nifi.processor.Relationship v, v, v, v, v;
org.apache.nifi.processors.standard.TestSplitJson v;
java.lang.String v, v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.TestSplitJson$1 v;
java.lang.Object v, v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitJson;
v = new org.apache.nifi.processors.standard.SplitJson;
specialinvoke v.<org.apache.nifi.processors.standard.SplitJson: 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.SplitJson: org.apache.nifi.components.PropertyDescriptor ARRAY_JSON_PATH_EXPRESSION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "$[*].name");
v = <org.apache.nifi.processors.standard.TestSplitJson: java.nio.file.Path JSON_SNIPPET>;
v = new org.apache.nifi.processors.standard.TestSplitJson$1;
specialinvoke v.<org.apache.nifi.processors.standard.TestSplitJson$1: void <init>(org.apache.nifi.processors.standard.TestSplitJson)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.nio.file.Path,java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.SplitJson: 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.SplitJson: 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.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_ID>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeExists(java.lang.String)>(v);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "7");
v = <org.apache.nifi.processors.standard.TestSplitJson: java.nio.file.Path JSON_SNIPPET>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
v = <org.apache.nifi.processors.standard.SplitJson: org.apache.nifi.processor.Relationship REL_SPLIT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 7);
v = <org.apache.nifi.processors.standard.SplitJson: org.apache.nifi.processor.Relationship REL_SPLIT>;
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)>("{\"first\":\"Shaffer\",\"last\":\"Pearson\"}");
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "7");
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_INDEX>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "0");
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes SEGMENT_ORIGINAL_FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "test.json");
v = <org.apache.nifi.processors.standard.SplitJson: org.apache.nifi.processor.Relationship REL_SPLIT>;
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)>(6);
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_COUNT>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "7");
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes FRAGMENT_INDEX>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "6");
v = <org.apache.nifi.flowfile.attributes.FragmentAttributes: org.apache.nifi.flowfile.attributes.FragmentAttributes SEGMENT_ORIGINAL_FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.FragmentAttributes: java.lang.String key()>();
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertAttributeEquals(java.lang.String,java.lang.String)>(v, "test.json");
return;
}
public void testSplit_pathNotFound() throws java.lang.Exception
{
org.apache.nifi.components.PropertyDescriptor v;
java.util.List v;
org.apache.nifi.processors.standard.SplitJson v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.processors.standard.TestSplitJson v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
java.nio.file.Path v, v;
v := @this: org.apache.nifi.processors.standard.TestSplitJson;
v = new org.apache.nifi.processors.standard.SplitJson;
specialinvoke v.<org.apache.nifi.processors.standard.SplitJson: 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.SplitJson: org.apache.nifi.components.PropertyDescriptor ARRAY_JSON_PATH_EXPRESSION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "$.nonexistent");
v = <org.apache.nifi.processors.standard.TestSplitJson: java.nio.file.Path JSON_SNIPPET>;
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.SplitJson: 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.SplitJson: org.apache.nifi.processor.Relationship REL_FAILURE>;
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.TestSplitJson: java.nio.file.Path JSON_SNIPPET>;
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.nio.file.Path)>(v);
return;
}
public void testSplit_pathToNullValue()
{
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.processor.ProcessSessionFactory v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.processors.standard.SplitJson v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.processors.standard.TestSplitJson v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestSplitJson$2 v;
v := @this: org.apache.nifi.processors.standard.TestSplitJson;
v = new org.apache.nifi.processors.standard.SplitJson;
specialinvoke v.<org.apache.nifi.processors.standard.SplitJson: 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.SplitJson: org.apache.nifi.components.PropertyDescriptor ARRAY_JSON_PATH_EXPRESSION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "$.nullField");
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.processor.ProcessSessionFactory getProcessSessionFactory()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSessionFactory: org.apache.nifi.processor.ProcessSession createSession()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile create()>();
v = new org.apache.nifi.processors.standard.TestSplitJson$2;
specialinvoke v.<org.apache.nifi.processors.standard.TestSplitJson$2: void <init>(org.apache.nifi.processors.standard.TestSplitJson)>(v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile write(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.OutputStreamCallback)>(v, v);
v = newarray (org.apache.nifi.flowfile.FlowFile)[1];
v[0] = 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.SplitJson: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
public void testSplit_pathToArrayWithNulls_emptyStringRepresentation()
{
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.processor.ProcessSessionFactory v;
org.apache.nifi.components.PropertyDescriptor v;
java.util.List v;
org.apache.nifi.processors.standard.SplitJson v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.processors.standard.TestSplitJson v;
org.apache.nifi.util.TestRunner v;
int v;
java.lang.Object v;
org.apache.nifi.processors.standard.TestSplitJson$3 v;
v := @this: org.apache.nifi.processors.standard.TestSplitJson;
v = new org.apache.nifi.processors.standard.SplitJson;
specialinvoke v.<org.apache.nifi.processors.standard.SplitJson: 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.SplitJson: org.apache.nifi.components.PropertyDescriptor ARRAY_JSON_PATH_EXPRESSION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "$.arrayOfNulls");
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.processor.ProcessSessionFactory getProcessSessionFactory()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSessionFactory: org.apache.nifi.processor.ProcessSession createSession()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile create()>();
v = new org.apache.nifi.processors.standard.TestSplitJson$3;
specialinvoke v.<org.apache.nifi.processors.standard.TestSplitJson$3: void <init>(org.apache.nifi.processors.standard.TestSplitJson)>(v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile write(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.OutputStreamCallback)>(v, v);
v = newarray (org.apache.nifi.flowfile.FlowFile)[1];
v[0] = 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.SplitJson: org.apache.nifi.processor.Relationship REL_SPLIT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 3);
v = 0;
label:
if v >= 3 goto label;
v = <org.apache.nifi.processors.standard.SplitJson: org.apache.nifi.processor.Relationship REL_SPLIT>;
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)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("");
v = v + 1;
goto label;
label:
return;
}
public void testSplit_pathToArrayWithNulls_nullStringRepresentation()
{
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processors.standard.SplitJson v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.processors.standard.TestSplitJson v;
org.apache.nifi.util.TestRunner v;
int v;
org.apache.nifi.processors.standard.TestSplitJson$4 v;
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.util.List v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.TestSplitJson;
v = new org.apache.nifi.processors.standard.SplitJson;
specialinvoke v.<org.apache.nifi.processors.standard.SplitJson: 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.SplitJson: org.apache.nifi.components.PropertyDescriptor ARRAY_JSON_PATH_EXPRESSION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "$.arrayOfNulls");
v = <org.apache.nifi.processors.standard.SplitJson: org.apache.nifi.components.PropertyDescriptor NULL_VALUE_DEFAULT_REPRESENTATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "the string \'null\'");
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.processor.ProcessSessionFactory getProcessSessionFactory()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSessionFactory: org.apache.nifi.processor.ProcessSession createSession()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile create()>();
v = new org.apache.nifi.processors.standard.TestSplitJson$4;
specialinvoke v.<org.apache.nifi.processors.standard.TestSplitJson$4: void <init>(org.apache.nifi.processors.standard.TestSplitJson)>(v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile write(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.OutputStreamCallback)>(v, v);
v = newarray (org.apache.nifi.flowfile.FlowFile)[1];
v[0] = 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.SplitJson: org.apache.nifi.processor.Relationship REL_SPLIT>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 3);
v = 0;
label:
if v >= 3 goto label;
v = <org.apache.nifi.processors.standard.SplitJson: org.apache.nifi.processor.Relationship REL_SPLIT>;
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)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>("null");
v = v + 1;
goto label;
label:
return;
}
public void testSplit_pathToInputStringNullValue()
{
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.processor.ProcessSessionFactory v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.processors.standard.SplitJson v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.processors.standard.TestSplitJson v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.processors.standard.TestSplitJson$5 v;
v := @this: org.apache.nifi.processors.standard.TestSplitJson;
v = new org.apache.nifi.processors.standard.SplitJson;
specialinvoke v.<org.apache.nifi.processors.standard.SplitJson: 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.SplitJson: org.apache.nifi.components.PropertyDescriptor ARRAY_JSON_PATH_EXPRESSION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "$.*");
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.processor.ProcessSessionFactory getProcessSessionFactory()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSessionFactory: org.apache.nifi.processor.ProcessSession createSession()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile create()>();
v = new org.apache.nifi.processors.standard.TestSplitJson$5;
specialinvoke v.<org.apache.nifi.processors.standard.TestSplitJson$5: void <init>(org.apache.nifi.processors.standard.TestSplitJson)>(v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile write(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.io.OutputStreamCallback)>(v, v);
v = newarray (org.apache.nifi.flowfile.FlowFile)[1];
v[0] = 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.SplitJson: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
static void <clinit>()
{
java.lang.String[] v, v;
java.nio.file.Path v, v;
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/TestJson/json-sample.json", v);
<org.apache.nifi.processors.standard.TestSplitJson: java.nio.file.Path JSON_SNIPPET> = v;
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/TestXml/xml-snippet.xml", v);
<org.apache.nifi.processors.standard.TestSplitJson: java.nio.file.Path XML_SNIPPET> = v;
return;
}
}