public class org.apache.nifi.processors.standard.TestAttributesToJSON extends java.lang.Object
{
private static final java.lang.String TEST_ATTRIBUTE_KEY;
private static final java.lang.String TEST_ATTRIBUTE_VALUE;
public void <init>()
{
org.apache.nifi.processors.standard.TestAttributesToJSON v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void testInvalidUserSuppliedAttributeList()
{
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processors.standard.TestAttributesToJSON 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.util.TestRunner v;
org.junit.jupiter.api.function.Executable v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_LIST>;
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 = 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);
v = staticinvoke <org.apache.nifi.processors.standard.TestAttributesToJSON$lambda_testInvalidUserSuppliedAttributeList_0__44: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.util.TestRunner)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/lang/AssertionError;", v);
return;
}
public void testInvalidIncludeCoreAttributesProperty()
{
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processors.standard.TestAttributesToJSON 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, v, v;
org.apache.nifi.util.TestRunner v;
org.junit.jupiter.api.function.Executable v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_LIST>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "val,val2");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-attribute");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor INCLUDE_CORE_ATTRIBUTES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "maybe");
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 = 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);
v = staticinvoke <org.apache.nifi.processors.standard.TestAttributesToJSON$lambda_testInvalidIncludeCoreAttributesProperty_1__45: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.util.TestRunner)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/lang/AssertionError;", v);
return;
}
public void testNullValueForEmptyAttribute() throws java.lang.Exception
{
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processors.standard.TestAttributesToJSON v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.util.List v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-attribute");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_LIST>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "NonExistingAttributeKey");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor NULL_VALUE_FOR_EMPTY_STRING>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
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 = 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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 assertAttributeExists(java.lang.String)>("JSONAttributes");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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: java.lang.String getAttribute(java.lang.String)>("JSONAttributes");
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,java.lang.Class)>(v, class "Ljava/util/HashMap;");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("NonExistingAttributeKey");
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
return;
}
public void testEmptyStringValueForEmptyAttribute() throws java.lang.Exception
{
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processors.standard.TestAttributesToJSON v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.util.List v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-attribute");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_LIST>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "NonExistingAttributeKey");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor NULL_VALUE_FOR_EMPTY_STRING>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
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 = 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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 assertAttributeExists(java.lang.String)>("JSONAttributes");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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: java.lang.String getAttribute(java.lang.String)>("JSONAttributes");
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,java.lang.Class)>(v, class "Ljava/util/HashMap;");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("NonExistingAttributeKey");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, "");
return;
}
public void testInvalidJSONValueInAttribute() throws java.lang.Exception
{
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processors.standard.TestAttributesToJSON 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.processor.Relationship v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-attribute");
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 = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, "TestAttribute", "\'badjson\'");
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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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 assertAttributeExists(java.lang.String)>("JSONAttributes");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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 testAttributes_emptyListUserSpecifiedAttributes() throws java.lang.Exception
{
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v;
boolean v;
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processors.standard.TestAttributesToJSON v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.util.List v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-attribute");
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 = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, "TestAttribute", "TestValue");
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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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 assertAttributeExists(java.lang.String)>("JSONAttributes");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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: java.lang.String getAttribute(java.lang.String)>("JSONAttributes");
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,java.lang.Class)>(v, class "Ljava/util/HashMap;");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("TestAttribute");
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("TestValue");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testContent_emptyListUserSpecifiedAttributes() throws java.lang.Exception
{
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processors.standard.TestAttributesToJSON v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.util.List v, v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-content");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor INCLUDE_CORE_ATTRIBUTES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
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 = 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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 assertAttributeNotExists(java.lang.String)>("JSONAttributes");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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)>("{}");
return;
}
public void testAttribute_singleUserDefinedAttribute() throws java.lang.Exception
{
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
int v;
java.lang.String v;
boolean v, v;
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processors.standard.TestAttributesToJSON v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.util.List v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_LIST>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "TestAttribute");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-attribute");
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 = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, "TestAttribute", "TestValue");
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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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 assertAttributeExists(java.lang.String)>("JSONAttributes");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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: java.lang.String getAttribute(java.lang.String)>("JSONAttributes");
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,java.lang.Class)>(v, class "Ljava/util/HashMap;");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("TestAttribute");
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("TestValue");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: int size()>();
if v != 1 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testAttribute_singleUserDefinedAttributeWithWhiteSpace() throws java.lang.Exception
{
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
int v;
java.lang.String v;
boolean v, v;
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processors.standard.TestAttributesToJSON v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.util.List v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_LIST>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, " TestAttribute ");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-attribute");
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 = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, "TestAttribute", "TestValue");
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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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 assertAttributeExists(java.lang.String)>("JSONAttributes");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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: java.lang.String getAttribute(java.lang.String)>("JSONAttributes");
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,java.lang.Class)>(v, class "Ljava/util/HashMap;");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("TestAttribute");
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("TestValue");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: int size()>();
if v != 1 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testAttribute_singleNonExistingUserDefinedAttribute() throws java.lang.Exception
{
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
int v;
java.lang.String v;
boolean v, v;
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processors.standard.TestAttributesToJSON v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.util.List v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_LIST>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "NonExistingAttribute");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-attribute");
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 = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, "TestAttribute", "TestValue");
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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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 assertAttributeExists(java.lang.String)>("JSONAttributes");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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: java.lang.String getAttribute(java.lang.String)>("JSONAttributes");
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,java.lang.Class)>(v, class "Ljava/util/HashMap;");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("NonExistingAttribute");
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: int size()>();
if v != 1 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testAttribute_noIncludeCoreAttributesUserDefined() throws java.io.IOException
{
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.util.TestRunner v;
org.apache.nifi.flowfile.FlowFile v, v, v;
org.apache.nifi.processors.standard.TestAttributesToJSON v;
java.util.List v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
int v;
java.lang.String v, v, v, v, v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.lang.Object v, v, v, v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v, v, v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_LIST>;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes PATH>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>(" TestAttribute , \u ");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor INCLUDE_CORE_ATTRIBUTES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
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 = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, "TestAttribute", "TestValue");
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes PATH>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, v, "TestValue");
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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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 assertAttributeExists(java.lang.String)>("JSONAttributes");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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: java.lang.String getAttribute(java.lang.String)>("JSONAttributes");
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,java.lang.Class)>(v, class "Ljava/util/HashMap;");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("TestAttribute");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("TestValue", v);
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes PATH>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("TestValue", v);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(2, v);
return;
}
public void testAttribute_noIncludeCoreAttributesRegex() throws java.io.IOException
{
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
int v;
java.lang.String v, v, v, v, v;
org.apache.nifi.flowfile.FlowFile v, v, v;
org.apache.nifi.processors.standard.TestAttributesToJSON v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.util.List v, v;
java.lang.Object v, v, v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v, v, v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_REGEX>;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes PATH>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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.*");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor INCLUDE_CORE_ATTRIBUTES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
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 = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, "TestAttribute", "TestValue");
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes PATH>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, v, "TestValue");
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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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 assertAttributeExists(java.lang.String)>("JSONAttributes");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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: java.lang.String getAttribute(java.lang.String)>("JSONAttributes");
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,java.lang.Class)>(v, class "Ljava/util/HashMap;");
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes PATH>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("TestValue", v);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
return;
}
public void testAttribute_noIncludeCoreAttributesContent() throws java.io.IOException
{
byte[] v;
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.util.TestRunner v;
int v;
java.lang.String v;
org.apache.nifi.flowfile.FlowFile v, v, v;
org.apache.nifi.processors.standard.TestAttributesToJSON v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.util.List v;
java.lang.Object v, v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor INCLUDE_CORE_ATTRIBUTES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "false");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-content");
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 = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, "TestAttribute", "TestValue");
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes PATH>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, v, "TestValue");
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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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 = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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: byte[] toByteArray()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(byte[],java.lang.Class)>(v, class "Ljava/util/HashMap;");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("TestAttribute");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("TestValue", v);
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(1, v);
return;
}
public void testAttribute_includeCoreAttributesContent() throws java.io.IOException
{
byte[] v;
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile[] v;
java.util.function.Function v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.util.TestRunner v;
int v;
java.lang.String v, v;
java.util.stream.Collector v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processors.standard.TestAttributesToJSON v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.util.Set v;
org.apache.nifi.flowfile.attributes.CoreAttributes[] v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.util.function.Consumer v;
java.util.List v;
java.util.stream.Stream v, v;
java.lang.Object v, v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-content");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor INCLUDE_CORE_ATTRIBUTES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
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 = 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
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 MIME_TYPE>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: java.lang.String getAttribute(java.lang.String)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("application/json", v);
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(byte[],java.lang.Class)>(v, class "Ljava/util/HashMap;");
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(3, v);
v = staticinvoke <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes[] values()>();
v = staticinvoke <java.util.Arrays: java.util.stream.Stream stream(java.lang.Object[])>(v);
v = staticinvoke <org.apache.nifi.processors.standard.TestAttributesToJSON$key__46: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toSet()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = staticinvoke <org.apache.nifi.processors.standard.TestAttributesToJSON$lambda_testAttribute_includeCoreAttributesContent_2__47: java.util.function.Consumer bootstrap$(java.util.Set)>(v);
interfaceinvoke v.<java.util.Set: void forEach(java.util.function.Consumer)>(v);
return;
}
public void testAttribute_includeCoreAttributesAttribute() throws java.io.IOException
{
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile[] v;
java.util.function.Function v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.util.TestRunner v;
int v;
java.lang.String v, v, v;
java.util.stream.Collector v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processors.standard.TestAttributesToJSON v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.util.Set v;
org.apache.nifi.flowfile.attributes.CoreAttributes[] v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.util.function.Consumer v;
java.util.List v;
java.util.stream.Stream v, v;
java.lang.Object v, v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor INCLUDE_CORE_ATTRIBUTES>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
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 = 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
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 MIME_TYPE>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: java.lang.String getAttribute(java.lang.String)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertNull(java.lang.Object)>(v);
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: java.lang.String getAttribute(java.lang.String)>("JSONAttributes");
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,java.lang.Class)>(v, class "Ljava/util/HashMap;");
v = interfaceinvoke v.<java.util.Map: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(3, v);
v = staticinvoke <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes[] values()>();
v = staticinvoke <java.util.Arrays: java.util.stream.Stream stream(java.lang.Object[])>(v);
v = staticinvoke <org.apache.nifi.processors.standard.TestAttributesToJSON$key__48: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toSet()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = staticinvoke <org.apache.nifi.processors.standard.TestAttributesToJSON$lambda_testAttribute_includeCoreAttributesAttribute_3__49: java.util.function.Consumer bootstrap$(java.util.Set)>(v);
interfaceinvoke v.<java.util.Set: void forEach(java.util.function.Consumer)>(v);
return;
}
public void testAttributesRegex() throws java.io.IOException
{
byte[] v;
org.apache.nifi.processors.standard.AttributesToJSON v;
java.util.HashMap v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v;
boolean v, v, v, v, v, v, v, v;
org.apache.nifi.processors.standard.TestAttributesToJSON v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.util.Set v, v, v, v, v, v, v;
java.util.List v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: void <init>()>();
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void setVariable(java.lang.String,java.lang.String)>("regex", "delimited\\.header\\.column\\.[0-9]+");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_REGEX>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "${regex}");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor ATTRIBUTES_LIST>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "test, test1");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("delimited.header.column.1", "Registry");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("delimited.header.column.2", "Assignment");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("delimited.header.column.3", "Organization Name");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("delimited.header.column.4", "Organization Address");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("delimited.footer.column.1", "not included");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("test", "test");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("test1", "test1");
v = "";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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 = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: java.lang.String getAttribute(java.lang.String)>("JSONAttributes");
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,java.lang.Class)>(v, class "Ljava/util/HashMap;");
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>("delimited.header.column.1");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>("delimited.header.column.2");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>("delimited.header.column.3");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>("delimited.header.column.4");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>("delimited.footer.column.1");
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>("test");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>("test1");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testAttributeWithNestedJsonOutputAsJsonInContent(java.lang.String, java.lang.Class) throws java.io.IOException
{
byte[] v;
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.Relationship v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v, v;
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processors.standard.TestAttributesToJSON v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.util.List v;
java.lang.Class v;
java.lang.Object v, v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Class;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-content");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor JSON_HANDLING_STRATEGY>;
v = <org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy: org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy NESTED>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy: java.lang.String getValue()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, 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 = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, "TestAttribute", 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.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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 MIME_TYPE>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: java.lang.String getAttribute(java.lang.String)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>("application/json", v);
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(byte[],java.lang.Class)>(v, class "Ljava/util/Map;");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("TestAttribute");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object assertInstanceOf(java.lang.Class,java.lang.Object)>(v, v);
return;
}
private static java.util.stream.Stream getNestedJson() throws java.io.IOException
{
byte[] v, v;
java.lang.Object[] v, v;
java.lang.String[] v, v;
org.junit.jupiter.params.provider.Arguments v, v;
java.util.stream.Stream v;
java.lang.String v, v;
java.nio.file.Path v, v;
org.junit.jupiter.params.provider.Arguments[] v;
v = newarray (org.junit.jupiter.params.provider.Arguments)[2];
v = newarray (java.lang.Object)[2];
v = new java.lang.String;
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);
v = staticinvoke <java.nio.file.Files: byte[] readAllBytes(java.nio.file.Path)>(v);
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
v[0] = v;
v[1] = class "Ljava/util/List;";
v = staticinvoke <org.junit.jupiter.params.provider.Arguments: org.junit.jupiter.params.provider.Arguments of(java.lang.Object[])>(v);
v[0] = v;
v = newarray (java.lang.Object)[2];
v = new java.lang.String;
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/TestJoltTransformJson/input.json", v);
v = staticinvoke <java.nio.file.Files: byte[] readAllBytes(java.nio.file.Path)>(v);
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
v[0] = v;
v[1] = class "Ljava/util/Map;";
v = staticinvoke <org.junit.jupiter.params.provider.Arguments: org.junit.jupiter.params.provider.Arguments of(java.lang.Object[])>(v);
v[1] = v;
v = staticinvoke <java.util.stream.Stream: java.util.stream.Stream of(java.lang.Object[])>(v);
return v;
}
public void testAttributeWithNestedJsonOutputAsJsonInAttribute(java.lang.String, java.lang.Class) throws java.io.IOException
{
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v;
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processors.standard.TestAttributesToJSON v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.util.List v, v;
java.lang.Class v;
java.lang.Object v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Class;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-attribute");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor JSON_HANDLING_STRATEGY>;
v = <org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy: org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy NESTED>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy: java.lang.String getValue()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, 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 = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, "TestAttribute", 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.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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 assertAttributeExists(java.lang.String)>("JSONAttributes");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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: java.lang.String getAttribute(java.lang.String)>("JSONAttributes");
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,java.lang.Class)>(v, class "Ljava/util/Map;");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("TestAttribute");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object assertInstanceOf(java.lang.Class,java.lang.Object)>(v, v);
return;
}
public void testAttributesWithLookALikeJson(java.lang.String)
{
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v, v;
boolean v;
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processors.standard.TestAttributesToJSON v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.util.List v;
java.lang.Object v;
org.apache.nifi.util.MockComponentLog v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v := @parameter: java.lang.String;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-content");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor JSON_HANDLING_STRATEGY>;
v = <org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy: org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy NESTED>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON$JsonHandlingStrategy: java.lang.String getValue()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, 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 = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, "TestAttribute", 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.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockComponentLog getLogger()>();
v = virtualinvoke v.<org.apache.nifi.util.MockComponentLog: java.util.List getErrorMessages()>();
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = virtualinvoke v.<org.apache.nifi.util.LogMessage: java.lang.String getMsg()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("expecting");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testAttributeWithNestedJsonOutputAsStringInAttribute(java.lang.String) throws java.io.IOException
{
org.apache.nifi.processors.standard.AttributesToJSON v;
org.apache.nifi.flowfile.FlowFile[] v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.processor.Relationship v, v, v, v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v;
org.apache.nifi.flowfile.FlowFile v, v;
org.apache.nifi.processors.standard.TestAttributesToJSON v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.util.List v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestAttributesToJSON;
v := @parameter: java.lang.String;
v = new org.apache.nifi.processors.standard.AttributesToJSON;
specialinvoke v.<org.apache.nifi.processors.standard.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.components.PropertyDescriptor DESTINATION>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "flowfile-attribute");
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 = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, "TestAttribute", 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.AttributesToJSON: 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.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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 assertAttributeExists(java.lang.String)>("JSONAttributes");
v = <org.apache.nifi.processors.standard.AttributesToJSON: org.apache.nifi.processor.Relationship REL_SUCCESS>;
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: java.lang.String getAttribute(java.lang.String)>("JSONAttributes");
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,java.lang.Class)>(v, class "Ljava/util/Map;");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("TestAttribute");
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object assertInstanceOf(java.lang.Class,java.lang.Object)>(class "Ljava/lang/String;", v);
return;
}
}