public class org.apache.nifi.processors.standard.TestFetchDistributedMapCache extends java.lang.Object { private org.apache.nifi.util.TestRunner runner; private org.apache.nifi.processors.standard.TestFetchDistributedMapCache$MockCacheClient service; public void () { org.apache.nifi.processors.standard.TestFetchDistributedMapCache v; v := @this: org.apache.nifi.processors.standard.TestFetchDistributedMapCache; specialinvoke v.()>(); return; } public void setup() throws org.apache.nifi.reporting.InitializationException { org.apache.nifi.processors.standard.TestFetchDistributedMapCache v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.util.TestRunner v, v, v, v; org.apache.nifi.processors.standard.TestFetchDistributedMapCache$MockCacheClient v, v, v; v := @this: org.apache.nifi.processors.standard.TestFetchDistributedMapCache; v = staticinvoke (class "Lorg/apache/nifi/processors/standard/FetchDistributedMapCache;"); v. = v; v = new org.apache.nifi.processors.standard.TestFetchDistributedMapCache$MockCacheClient; specialinvoke v.(org.apache.nifi.processors.standard.TestFetchDistributedMapCache)>(v); v. = v; v = v.; v = v.; interfaceinvoke v.("service", v); v = v.; v = v.; interfaceinvoke v.(v); v = v.; v = ; interfaceinvoke v.(v, "service"); return; } public void testNoCacheKey() { byte[] v; java.util.HashMap v; org.apache.nifi.processors.standard.TestFetchDistributedMapCache v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestFetchDistributedMapCache; v = v.; v = ; interfaceinvoke v.(v, "${cacheKeyAttribute}"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("cacheKeyAttribute", "1"); v = v.; v = newarray (byte)[0]; interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; interfaceinvoke v.(); return; } public void testNoCacheKeyValue() { byte[] v; org.apache.nifi.processors.standard.TestFetchDistributedMapCache v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestFetchDistributedMapCache; v = v.; v = ; interfaceinvoke v.(v, "${cacheKeyAttribute}"); v = v.; v = newarray (byte)[0]; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; interfaceinvoke v.(); return; } public void testFailingCacheService() { byte[] v; java.util.HashMap v; org.apache.nifi.processors.standard.TestFetchDistributedMapCache v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v, v, v, v, v; org.apache.nifi.processors.standard.TestFetchDistributedMapCache$MockCacheClient v, v; v := @this: org.apache.nifi.processors.standard.TestFetchDistributedMapCache; v = v.; virtualinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, "${cacheKeyAttribute}"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("cacheKeyAttribute", "2"); v = v.; v = newarray (byte)[0]; interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; virtualinvoke v.(0); return; } public void testSingleFlowFile() throws java.io.IOException { byte[] v; org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer v, v; java.util.HashMap v; org.apache.nifi.processors.standard.TestFetchDistributedMapCache v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v; java.lang.String v; java.util.List v; java.lang.Object v; org.apache.nifi.processors.standard.TestFetchDistributedMapCache$MockCacheClient v; v := @this: org.apache.nifi.processors.standard.TestFetchDistributedMapCache; v = v.; v = new org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer; specialinvoke v.()>(); v = new org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer; specialinvoke v.()>(); virtualinvoke v.("key", "value", v, v); v = v.; v = ; interfaceinvoke v.(v, "${cacheKeyAttribute}"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("cacheKeyAttribute", "key"); v = "content"; v = v.; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("value"); v = v.; interfaceinvoke v.(); return; } public void testSingleFlowFileToAttribute() throws java.io.IOException { byte[] v; org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer v, v; java.util.HashMap v; org.apache.nifi.processors.standard.TestFetchDistributedMapCache v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v; java.lang.String v; java.util.List v; java.lang.Object v; org.apache.nifi.processors.standard.TestFetchDistributedMapCache$MockCacheClient v; v := @this: org.apache.nifi.processors.standard.TestFetchDistributedMapCache; v = v.; v = new org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer; specialinvoke v.()>(); v = new org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer; specialinvoke v.()>(); virtualinvoke v.("key", "value", v, v); v = v.; v = ; interfaceinvoke v.(v, "${cacheKeyAttribute}"); v = v.; v = ; interfaceinvoke v.(v, "test"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("cacheKeyAttribute", "key"); v = "content"; v = v.; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("test", "value"); v = v.; interfaceinvoke v.(); return; } public void testToAttributeTooLong() throws java.io.IOException { byte[] v; org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer v, v; java.util.HashMap v; org.apache.nifi.processors.standard.TestFetchDistributedMapCache v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v; java.lang.String v; java.util.List v; java.lang.Object v; org.apache.nifi.processors.standard.TestFetchDistributedMapCache$MockCacheClient v; v := @this: org.apache.nifi.processors.standard.TestFetchDistributedMapCache; v = v.; v = new org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer; specialinvoke v.()>(); v = new org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer; specialinvoke v.()>(); virtualinvoke v.("key", "value", v, v); v = v.; v = ; interfaceinvoke v.(v, "${cacheKeyAttribute}"); v = v.; v = ; interfaceinvoke v.(v, "test"); v = v.; v = ; interfaceinvoke v.(v, "3"); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("cacheKeyAttribute", "key"); v = "content"; v = v.; v = virtualinvoke v.("UTF-8"); interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("test", "val"); v = v.; interfaceinvoke v.(); return; } public void testMultipleKeysToAttributes() throws java.io.IOException { byte[] v; org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer v, v, v, v; java.util.HashMap v; org.apache.nifi.processors.standard.TestFetchDistributedMapCache v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v; java.util.List v; java.lang.Object v; org.apache.nifi.processors.standard.TestFetchDistributedMapCache$MockCacheClient v, v; v := @this: org.apache.nifi.processors.standard.TestFetchDistributedMapCache; v = v.; v = new org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer; specialinvoke v.()>(); v = new org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer; specialinvoke v.()>(); virtualinvoke v.("key1", "value1", v, v); v = v.; v = new org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer; specialinvoke v.()>(); v = new org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer; specialinvoke v.()>(); virtualinvoke v.("key2", "value2", v, v); v = v.; v = ; interfaceinvoke v.(v, "key, key2"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, "test"); v = v.; interfaceinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); v = v.; v = newarray (byte)[0]; interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("test.key1", "value1"); virtualinvoke v.("test.key2", "value2"); return; } public void testMultipleKeysOneNotFound() throws java.io.IOException { byte[] v; org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer v, v; java.util.HashMap v; org.apache.nifi.processors.standard.TestFetchDistributedMapCache v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v; java.util.List v; java.lang.Object v; org.apache.nifi.processors.standard.TestFetchDistributedMapCache$MockCacheClient v; v := @this: org.apache.nifi.processors.standard.TestFetchDistributedMapCache; v = v.; v = new org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer; specialinvoke v.()>(); v = new org.apache.nifi.processors.standard.FetchDistributedMapCache$StringSerializer; specialinvoke v.()>(); virtualinvoke v.("key1", "value1", v, v); v = v.; v = ; interfaceinvoke v.(v, "key, key2"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, "test"); v = v.; interfaceinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); v = v.; v = newarray (byte)[0]; interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("test.key1", "value1"); return; } }