public class org.apache.nifi.processors.standard.TestUpdateCounter extends java.lang.Object
{
public void <init>()
{
org.apache.nifi.processors.standard.TestUpdateCounter v;
v := @this: org.apache.nifi.processors.standard.TestUpdateCounter;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void testwithFileName()
{
org.apache.nifi.processors.standard.UpdateCounter v;
org.apache.nifi.processors.standard.TestUpdateCounter v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
java.util.HashMap v;
org.apache.nifi.components.PropertyDescriptor v, v;
v := @this: org.apache.nifi.processors.standard.TestUpdateCounter;
v = new org.apache.nifi.processors.standard.UpdateCounter;
specialinvoke v.<org.apache.nifi.processors.standard.UpdateCounter: 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.UpdateCounter: org.apache.nifi.components.PropertyDescriptor COUNTER_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "firewall");
v = <org.apache.nifi.processors.standard.UpdateCounter: org.apache.nifi.components.PropertyDescriptor DELTA>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(java.lang.String,java.util.Map)>("", v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run()>();
v = <org.apache.nifi.processors.standard.UpdateCounter: org.apache.nifi.processor.Relationship SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
public void testExpressionLanguage()
{
byte[] v;
org.apache.nifi.processors.standard.UpdateCounter v;
java.util.HashMap v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.processors.standard.TestUpdateCounter v;
java.lang.Long v, v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
java.util.Optional v, v;
v := @this: org.apache.nifi.processors.standard.TestUpdateCounter;
v = new org.apache.nifi.processors.standard.UpdateCounter;
specialinvoke v.<org.apache.nifi.processors.standard.UpdateCounter: 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.UpdateCounter: org.apache.nifi.components.PropertyDescriptor COUNTER_NAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "${filename}");
v = <org.apache.nifi.processors.standard.UpdateCounter: org.apache.nifi.components.PropertyDescriptor DELTA>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "${num}");
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)>("filename", "test");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("num", "40");
v = newarray (byte)[0];
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 = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.lang.Long getCounterValue(java.lang.String)>("test");
v = staticinvoke <java.util.Optional: java.util.Optional ofNullable(java.lang.Object)>(v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(40L);
v = staticinvoke <java.util.Optional: java.util.Optional ofNullable(java.lang.Object)>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.nifi.processors.standard.UpdateCounter: org.apache.nifi.processor.Relationship SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertAllFlowFilesTransferred(org.apache.nifi.processor.Relationship,int)>(v, 1);
return;
}
}