public class org.apache.nifi.processors.standard.TestControlRate extends java.lang.Object { private static final java.lang.String ONE_SECOND_TIME_PERIOD; private static final long CURRENT_TIME_INCREMENT; private org.apache.nifi.processors.standard.TestControlRate$ConfigurableControlRate controlRate; private org.apache.nifi.util.TestRunner runner; public void () { org.apache.nifi.processors.standard.TestControlRate v; v := @this: org.apache.nifi.processors.standard.TestControlRate; specialinvoke v.()>(); return; } public void setRunner() { org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestControlRate$ConfigurableControlRate v, v; org.apache.nifi.processors.standard.TestControlRate v; v := @this: org.apache.nifi.processors.standard.TestControlRate; v = new org.apache.nifi.processors.standard.TestControlRate$ConfigurableControlRate; specialinvoke v.()>(); v. = v; v = v.; v = staticinvoke (v); v. = v; return; } public void testLimitExceededThenOtherLimitNotExceeded() { long v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.processors.standard.TestControlRate v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v; java.util.Map v, v; int v; java.util.function.Predicate v, v; java.util.List v; java.util.stream.Stream v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestControlRate; v = v.; v = ; interfaceinvoke v.(v, "flowfile count"); v = v.; v = ; interfaceinvoke v.(v, "3"); v = v.; v = ; interfaceinvoke v.(v, "1 min"); v = v.; v = ; interfaceinvoke v.(v, "group"); v = staticinvoke ("group", "1"); v = staticinvoke ("group", "2"); v = 0; label: if v >= 5 goto label; v = v.; interfaceinvoke v.("test data", v); v = v + 1; goto label; label: v = v.; interfaceinvoke v.("test data", v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 4); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (3L, v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (1L, v); return; } public void testFileCountRate() { org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.processors.standard.TestControlRate v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestControlRate; v = v.; v = ; interfaceinvoke v.(v, "flowfile count"); v = v.; v = ; interfaceinvoke v.(v, "3"); v = v.; v = ; interfaceinvoke v.(v, "1 s"); v = v.; interfaceinvoke v.("test data 1"); v = v.; interfaceinvoke v.("test data 2"); v = v.; interfaceinvoke v.("test data 3"); v = v.; interfaceinvoke v.("test data 4"); v = v.; interfaceinvoke v.(4, 0); v = v.; v = ; interfaceinvoke v.(v, 3); v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(50, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; interfaceinvoke v.(); specialinvoke v.(); v = v.; interfaceinvoke v.(5); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; interfaceinvoke v.(); return; } public void testFileCountWithGrouping() { org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.processors.standard.TestControlRate v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestControlRate; v = v.; v = ; interfaceinvoke v.(v, "flowfile count"); v = v.; v = ; interfaceinvoke v.(v, "2"); v = v.; v = ; interfaceinvoke v.(v, "1 s"); v = v.; v = ; interfaceinvoke v.(v, "group"); v = v.; specialinvoke v.(v, "one"); v = v.; specialinvoke v.(v, "two"); v = v.; specialinvoke v.(v, "one"); v = v.; specialinvoke v.(v, "two"); v = v.; specialinvoke v.(v, "one"); v = v.; specialinvoke v.(v, "two"); v = v.; interfaceinvoke v.(6, 0); v = v.; v = ; interfaceinvoke v.(v, 4); v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(50, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; interfaceinvoke v.(); specialinvoke v.(); v = v.; interfaceinvoke v.(2); v = v.; v = ; interfaceinvoke v.(v, 2); v = v.; interfaceinvoke v.(); return; } public void testDataSizeRate() { org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.processors.standard.TestControlRate v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestControlRate; v = v.; v = ; interfaceinvoke v.(v, "data rate"); v = v.; v = ; interfaceinvoke v.(v, "20 b"); v = v.; v = ; interfaceinvoke v.(v, "1 s"); v = v.; interfaceinvoke v.("testdata 1"); v = v.; interfaceinvoke v.("testdata 2"); v = v.; interfaceinvoke v.("testdata 3"); v = v.; interfaceinvoke v.("testdata 4"); v = v.; interfaceinvoke v.(4, 0); v = v.; v = ; interfaceinvoke v.(v, 2); v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(50, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; interfaceinvoke v.(); specialinvoke v.(); v = v.; interfaceinvoke v.(2, 0); v = v.; v = ; interfaceinvoke v.(v, 2); v = v.; interfaceinvoke v.(); return; } public void testViaAttribute() { org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.processors.standard.TestControlRate v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestControlRate; v = v.; v = ; interfaceinvoke v.(v, "attribute value"); v = v.; v = ; interfaceinvoke v.(v, "count"); v = v.; v = ; interfaceinvoke v.(v, "20000"); v = v.; v = ; interfaceinvoke v.(v, "1 s"); v = v.; specialinvoke v.(v, 1000); v = v.; specialinvoke v.(v, 3000); v = v.; specialinvoke v.(v, 5000); v = v.; specialinvoke v.(v, 20000); v = v.; specialinvoke v.(v, 1000); v = v.; interfaceinvoke v.(5, 0); v = v.; v = ; interfaceinvoke v.(v, 4); v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(50, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; interfaceinvoke v.(); specialinvoke v.(1450L); v = v.; interfaceinvoke v.(50, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; interfaceinvoke v.(); specialinvoke v.(600L); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; interfaceinvoke v.(); return; } public void testAttributeDoesNotExist() { org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.processors.standard.TestControlRate v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestControlRate; v = v.; v = ; interfaceinvoke v.(v, "attribute value"); v = v.; v = ; interfaceinvoke v.(v, "no.such.attribute"); v = v.; v = ; interfaceinvoke v.(v, "20000"); v = v.; v = ; interfaceinvoke v.(v, "1 s"); v = v.; specialinvoke v.(v, 1000); v = v.; specialinvoke v.(v, 3000); v = v.; specialinvoke v.(v, 5000); v = v.; specialinvoke v.(v, 20000); v = v.; specialinvoke v.(v, 1000); v = v.; interfaceinvoke v.(5, 0); v = v.; v = ; interfaceinvoke v.(v, 5); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; interfaceinvoke v.(); return; } public void testBadAttributeRate() { byte[] v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.processors.standard.TestControlRate v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestControlRate; v = v.; v = ; interfaceinvoke v.(v, "attribute value"); v = v.; v = ; interfaceinvoke v.(v, "count"); v = v.; v = ; interfaceinvoke v.(v, "20000"); v = v.; v = ; interfaceinvoke v.(v, "1 s"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("count", "bad string"); v = v.; v = newarray (byte)[0]; interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; interfaceinvoke v.(); return; } public void testBatchLimit() { org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.controller.queue.QueueSize v; org.apache.nifi.processors.standard.TestControlRate v; org.apache.nifi.processor.Relationship v, v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v; int v, v; java.lang.String v; v := @this: org.apache.nifi.processors.standard.TestControlRate; v = v.; v = ; interfaceinvoke v.(v, "flowfile count"); v = v.; v = ; interfaceinvoke v.(v, "5555"); v = v.; v = ; interfaceinvoke v.(v, "1 s"); v = 0; label: if v >= 1500 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("test data \u0001"); interfaceinvoke v.(v); v = v + 1; goto label; label: v = v.; interfaceinvoke v.(1, 0); v = v.; v = ; interfaceinvoke v.(v, 1000); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); staticinvoke (500, v); v = v.; interfaceinvoke v.(1, 0); v = v.; v = ; interfaceinvoke v.(v, 1500); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; interfaceinvoke v.(); return; } public void testNonExistingGroupAttribute() { org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.processors.standard.TestControlRate v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestControlRate; v = v.; v = ; interfaceinvoke v.(v, "flowfile count"); v = v.; v = ; interfaceinvoke v.(v, "2"); v = v.; v = ; interfaceinvoke v.(v, "1 s"); v = v.; v = ; interfaceinvoke v.(v, "group"); v = v.; specialinvoke v.(v, "one"); v = v.; specialinvoke v.(v, 1); v = v.; specialinvoke v.(v, "one"); v = v.; specialinvoke v.(v, 2); v = v.; interfaceinvoke v.(4, 0); v = v.; v = ; interfaceinvoke v.(v, 4); v = v.; interfaceinvoke v.(); return; } public void testIncreaseDataRate() { org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.processors.standard.TestControlRate v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestControlRate; v = v.; v = ; interfaceinvoke v.(v, "data rate"); v = v.; v = ; interfaceinvoke v.(v, "11 B"); v = v.; v = ; interfaceinvoke v.(v, "1 s"); v = v.; interfaceinvoke v.("test data 1"); v = v.; interfaceinvoke v.("test data 2"); v = v.; interfaceinvoke v.("test data 3"); v = v.; interfaceinvoke v.("test data 4"); v = v.; interfaceinvoke v.("test data 5"); v = v.; interfaceinvoke v.("test data 6"); v = v.; interfaceinvoke v.(7, 1); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, "33 B"); v = v.; interfaceinvoke v.(7, 0); v = v.; v = ; interfaceinvoke v.(v, 3); v = v.; v = ; interfaceinvoke v.