class org.apache.nifi.processors.standard.ConvertJSONToSQL$1 extends java.lang.Object implements org.apache.nifi.processor.io.InputStreamCallback
{
final java.util.concurrent.atomic.AtomicReference val$rootNodeRef;
final com.fasterxml.jackson.databind.ObjectMapper val$mapper;
final org.apache.nifi.processors.standard.ConvertJSONToSQL this$0;
void <init>(org.apache.nifi.processors.standard.ConvertJSONToSQL, java.util.concurrent.atomic.AtomicReference, com.fasterxml.jackson.databind.ObjectMapper)
{
org.apache.nifi.processors.standard.ConvertJSONToSQL v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processors.standard.ConvertJSONToSQL$1 v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: org.apache.nifi.processors.standard.ConvertJSONToSQL$1;
v := @parameter: org.apache.nifi.processors.standard.ConvertJSONToSQL;
v := @parameter: java.util.concurrent.atomic.AtomicReference;
v := @parameter: com.fasterxml.jackson.databind.ObjectMapper;
v.<org.apache.nifi.processors.standard.ConvertJSONToSQL$1: org.apache.nifi.processors.standard.ConvertJSONToSQL this$0> = v;
v.<org.apache.nifi.processors.standard.ConvertJSONToSQL$1: java.util.concurrent.atomic.AtomicReference val$rootNodeRef> = v;
v.<org.apache.nifi.processors.standard.ConvertJSONToSQL$1: com.fasterxml.jackson.databind.ObjectMapper val$mapper> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void process(java.io.InputStream) throws java.io.IOException
{
java.lang.Throwable v;
java.io.BufferedInputStream v;
com.fasterxml.jackson.databind.ObjectMapper v;
com.fasterxml.jackson.databind.JsonNode v;
org.apache.nifi.processors.standard.ConvertJSONToSQL$1 v;
java.util.concurrent.atomic.AtomicReference v;
java.io.InputStream v;
v := @this: org.apache.nifi.processors.standard.ConvertJSONToSQL$1;
v := @parameter: java.io.InputStream;
v = new java.io.BufferedInputStream;
specialinvoke v.<java.io.BufferedInputStream: void <init>(java.io.InputStream)>(v);
label:
v = v.<org.apache.nifi.processors.standard.ConvertJSONToSQL$1: java.util.concurrent.atomic.AtomicReference val$rootNodeRef>;
v = v.<org.apache.nifi.processors.standard.ConvertJSONToSQL$1: com.fasterxml.jackson.databind.ObjectMapper val$mapper>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode readTree(java.io.InputStream)>(v);
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
label:
virtualinvoke v.<java.io.InputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
}