public class org.apache.drill.exec.store.http.HttpXMLBatchReader extends org.apache.drill.exec.store.http.HttpBatchReader
{
private static final org.slf4j.Logger logger;
private final org.apache.drill.exec.store.http.HttpSubScan subScan;
private final int maxRecords;
private final int dataLevel;
private java.io.InputStream inStream;
private org.apache.drill.exec.store.xml.XMLReader xmlReader;
private org.apache.drill.exec.physical.resultSet.ResultSetLoader resultLoader;
public void <init>(org.apache.drill.exec.store.http.HttpSubScan)
{
org.apache.drill.exec.store.http.HttpSubScan v;
org.apache.drill.exec.store.http.HttpScanSpec v, v, v;
org.apache.drill.exec.store.http.HttpXmlOptions v, v;
org.apache.drill.exec.store.http.HttpApiConfig v, v, v;
int v, v, v;
org.apache.drill.exec.store.http.HttpXMLBatchReader v;
v := @this: org.apache.drill.exec.store.http.HttpXMLBatchReader;
v := @parameter: org.apache.drill.exec.store.http.HttpSubScan;
specialinvoke v.<org.apache.drill.exec.store.http.HttpBatchReader: void <init>(org.apache.drill.exec.store.http.HttpSubScan)>(v);
v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.http.HttpSubScan subScan> = v;
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpSubScan: int maxRecords()>();
v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: int maxRecords> = v;
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpSubScan: org.apache.drill.exec.store.http.HttpScanSpec tableSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpScanSpec: org.apache.drill.exec.store.http.HttpApiConfig connectionConfig()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpApiConfig: org.apache.drill.exec.store.http.HttpXmlOptions xmlOptions()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpSubScan: org.apache.drill.exec.store.http.HttpScanSpec tableSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpScanSpec: org.apache.drill.exec.store.http.HttpApiConfig connectionConfig()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpApiConfig: int xmlDataLevel()>();
v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: int dataLevel> = v;
goto label;
label:
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpSubScan: org.apache.drill.exec.store.http.HttpScanSpec tableSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpScanSpec: org.apache.drill.exec.store.http.HttpApiConfig connectionConfig()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpApiConfig: org.apache.drill.exec.store.http.HttpXmlOptions xmlOptions()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpXmlOptions: int getDataLevel()>();
v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: int dataLevel> = v;
label:
return;
}
public void <init>(org.apache.drill.exec.store.http.HttpSubScan, org.apache.drill.exec.store.http.paginator.Paginator)
{
org.apache.drill.exec.store.http.HttpSubScan v;
org.apache.drill.exec.store.http.HttpScanSpec v, v, v;
org.apache.drill.exec.store.http.HttpXmlOptions v, v;
org.apache.drill.exec.store.http.HttpApiConfig v, v, v;
org.apache.drill.exec.store.http.paginator.Paginator v;
int v, v, v;
org.apache.drill.exec.store.http.HttpXMLBatchReader v;
v := @this: org.apache.drill.exec.store.http.HttpXMLBatchReader;
v := @parameter: org.apache.drill.exec.store.http.HttpSubScan;
v := @parameter: org.apache.drill.exec.store.http.paginator.Paginator;
specialinvoke v.<org.apache.drill.exec.store.http.HttpBatchReader: void <init>(org.apache.drill.exec.store.http.HttpSubScan,org.apache.drill.exec.store.http.paginator.Paginator)>(v, v);
v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.http.HttpSubScan subScan> = v;
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpSubScan: int maxRecords()>();
v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: int maxRecords> = v;
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpSubScan: org.apache.drill.exec.store.http.HttpScanSpec tableSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpScanSpec: org.apache.drill.exec.store.http.HttpApiConfig connectionConfig()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpApiConfig: org.apache.drill.exec.store.http.HttpXmlOptions xmlOptions()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpSubScan: org.apache.drill.exec.store.http.HttpScanSpec tableSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpScanSpec: org.apache.drill.exec.store.http.HttpApiConfig connectionConfig()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpApiConfig: int xmlDataLevel()>();
v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: int dataLevel> = v;
goto label;
label:
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpSubScan: org.apache.drill.exec.store.http.HttpScanSpec tableSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpScanSpec: org.apache.drill.exec.store.http.HttpApiConfig connectionConfig()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpApiConfig: org.apache.drill.exec.store.http.HttpXmlOptions xmlOptions()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpXmlOptions: int getDataLevel()>();
v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: int dataLevel> = v;
label:
return;
}
public boolean open(org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator)
{
org.apache.drill.exec.store.http.HttpSubScan v;
org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator v;
org.apache.drill.common.exceptions.UserException v;
javax.xml.stream.XMLStreamException v;
boolean v;
org.apache.drill.exec.store.http.util.SimpleHttp v;
org.apache.drill.exec.store.xml.XMLReader v, v, v;
org.apache.drill.exec.store.http.util.SimpleHttp$SimpleHttpBuilder v, v, v, v, v, v, v;
org.apache.drill.exec.record.metadata.TupleMetadata v;
okhttp.HttpUrl v;
org.apache.drill.exec.store.http.HttpXMLBatchReader v;
org.apache.drill.exec.store.http.util.HttpProxyConfig v;
java.lang.Object[] v;
org.apache.drill.common.exceptions.CustomErrorContext v;
org.apache.drill.common.exceptions.UserException$Builder v, v, v;
org.apache.drill.exec.store.ImplicitColumnUtils$ImplicitColumns v, v;
org.apache.drill.exec.physical.resultSet.RowSetLoader v, v;
int v;
java.lang.String v, v, v;
org.slf4j.Logger v;
org.apache.drill.exec.physical.resultSet.ResultSetLoader v, v, v;
com.typesafe.config.Config v, v;
org.apache.drill.exec.store.http.paginator.Paginator v;
java.io.File v;
org.apache.drill.exec.store.http.HttpXMLBatchReader$1 v;
java.io.InputStream v, v;
v := @this: org.apache.drill.exec.store.http.HttpXMLBatchReader;
v := @parameter: org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator;
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: okhttp.HttpUrl buildUrl()>();
v = interfaceinvoke v.<org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator: com.typesafe.config.Config drillConfig()>();
v = interfaceinvoke v.<com.typesafe.config.Config: java.lang.String getString(java.lang.String)>("drill.tmp-dir");
v = new org.apache.drill.exec.store.http.HttpXMLBatchReader$1;
v = interfaceinvoke v.<org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator: org.apache.drill.common.exceptions.CustomErrorContext parentErrorContext()>();
specialinvoke v.<org.apache.drill.exec.store.http.HttpXMLBatchReader$1: void <init>(org.apache.drill.exec.store.http.HttpXMLBatchReader,org.apache.drill.common.exceptions.CustomErrorContext,okhttp.HttpUrl)>(v, v, v);
interfaceinvoke v.<org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator: void setErrorContext(org.apache.drill.common.exceptions.CustomErrorContext)>(v);
v = staticinvoke <org.apache.drill.exec.store.http.util.SimpleHttp: org.apache.drill.exec.store.http.util.SimpleHttp$SimpleHttpBuilder builder()>();
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.http.HttpSubScan subScan>;
v = virtualinvoke v.<org.apache.drill.exec.store.http.util.SimpleHttp$SimpleHttpBuilder: org.apache.drill.exec.store.http.util.SimpleHttp$SimpleHttpBuilder scanDefn(org.apache.drill.exec.store.http.HttpSubScan)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.http.util.SimpleHttp$SimpleHttpBuilder: org.apache.drill.exec.store.http.util.SimpleHttp$SimpleHttpBuilder url(okhttp.HttpUrl)>(v);
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.http.util.SimpleHttp$SimpleHttpBuilder: org.apache.drill.exec.store.http.util.SimpleHttp$SimpleHttpBuilder tempDir(java.io.File)>(v);
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.http.paginator.Paginator paginator>;
v = virtualinvoke v.<org.apache.drill.exec.store.http.util.SimpleHttp$SimpleHttpBuilder: org.apache.drill.exec.store.http.util.SimpleHttp$SimpleHttpBuilder paginator(org.apache.drill.exec.store.http.paginator.Paginator)>(v);
v = interfaceinvoke v.<org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator: com.typesafe.config.Config drillConfig()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.http.util.HttpProxyConfig proxySettings(com.typesafe.config.Config,okhttp.HttpUrl)>(v, v);
v = virtualinvoke v.<org.apache.drill.exec.store.http.util.SimpleHttp$SimpleHttpBuilder: org.apache.drill.exec.store.http.util.SimpleHttp$SimpleHttpBuilder proxyConfig(org.apache.drill.exec.store.http.util.HttpProxyConfig)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.http.util.SimpleHttp$SimpleHttpBuilder: org.apache.drill.exec.store.http.util.SimpleHttp$SimpleHttpBuilder errorContext(org.apache.drill.common.exceptions.CustomErrorContext)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.http.util.SimpleHttp$SimpleHttpBuilder: org.apache.drill.exec.store.http.util.SimpleHttp build()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.util.SimpleHttp: java.io.InputStream getInputStream()>();
v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: java.io.InputStream inStream> = v;
label:
v = specialinvoke v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.record.metadata.TupleMetadata getSchema(org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator)>(v);
if v == null goto label;
interfaceinvoke v.<org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator: void tableSchema(org.apache.drill.exec.record.metadata.TupleMetadata,boolean)>(v, 0);
label:
v = new org.apache.drill.exec.store.xml.XMLReader;
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: java.io.InputStream inStream>;
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: int dataLevel>;
specialinvoke v.<org.apache.drill.exec.store.xml.XMLReader: void <init>(java.io.InputStream,int)>(v, v);
v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.xml.XMLReader xmlReader> = v;
v = interfaceinvoke v.<org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator: org.apache.drill.exec.physical.resultSet.ResultSetLoader build()>();
v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.physical.resultSet.ResultSetLoader resultLoader> = v;
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: boolean implicitColumnsAreProjected()>();
if v == 0 goto label;
v = new org.apache.drill.exec.store.ImplicitColumnUtils$ImplicitColumns;
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.physical.resultSet.ResultSetLoader resultLoader>;
v = interfaceinvoke v.<org.apache.drill.exec.physical.resultSet.ResultSetLoader: org.apache.drill.exec.physical.resultSet.RowSetLoader writer()>();
specialinvoke v.<org.apache.drill.exec.store.ImplicitColumnUtils$ImplicitColumns: void <init>(org.apache.drill.exec.physical.resultSet.RowSetLoader)>(v);
v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.ImplicitColumnUtils$ImplicitColumns implicitColumns> = v;
virtualinvoke v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: void buildImplicitColumns()>();
virtualinvoke v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: void populateImplicitFieldMap(org.apache.drill.exec.store.http.util.SimpleHttp)>(v);
label:
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.physical.resultSet.ResultSetLoader resultLoader>;
v = interfaceinvoke v.<org.apache.drill.exec.physical.resultSet.ResultSetLoader: org.apache.drill.exec.physical.resultSet.RowSetLoader writer()>();
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.xml.XMLReader xmlReader>;
virtualinvoke v.<org.apache.drill.exec.store.xml.XMLReader: void open(org.apache.drill.exec.physical.resultSet.RowSetLoader,org.apache.drill.common.exceptions.CustomErrorContext)>(v, v);
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.xml.XMLReader xmlReader>;
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.ImplicitColumnUtils$ImplicitColumns implicitColumns>;
virtualinvoke v.<org.apache.drill.exec.store.xml.XMLReader: void implicitFields(org.apache.drill.exec.store.ImplicitColumnUtils$ImplicitColumns)>(v);
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <org.apache.drill.common.exceptions.UserException: org.apache.drill.common.exceptions.UserException$Builder dataReadError(java.lang.Throwable)>(v);
v = virtualinvoke v.<javax.xml.stream.XMLStreamException: java.lang.String getMessage()>();
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[])>("Error opening XML stream: \u0001");
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder message(java.lang.String,java.lang.Object[])>(v, v);
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder addContext(org.apache.drill.common.exceptions.CustomErrorContext)>(v);
v = <org.apache.drill.exec.store.http.HttpXMLBatchReader: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException build(org.slf4j.Logger)>(v);
throw v;
label:
virtualinvoke v.<org.apache.drill.exec.store.http.util.SimpleHttp: void close()>();
return 1;
catch javax.xml.stream.XMLStreamException from label to label with label;
}
private org.apache.drill.exec.record.metadata.TupleMetadata getSchema(org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator)
{
org.apache.drill.exec.store.http.HttpSubScan v, v, v;
org.apache.drill.exec.store.http.HttpScanSpec v, v, v;
org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator v;
org.apache.drill.exec.store.http.HttpXmlOptions v, v, v;
boolean v, v;
org.apache.drill.exec.store.http.HttpApiConfig v, v, v;
org.apache.drill.exec.record.metadata.TupleMetadata v, v, v, v, v;
org.apache.drill.exec.store.http.HttpXMLBatchReader v;
v := @this: org.apache.drill.exec.store.http.HttpXMLBatchReader;
v := @parameter: org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator;
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.http.HttpSubScan subScan>;
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpSubScan: org.apache.drill.exec.store.http.HttpScanSpec tableSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpScanSpec: org.apache.drill.exec.store.http.HttpApiConfig connectionConfig()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpApiConfig: org.apache.drill.exec.store.http.HttpXmlOptions xmlOptions()>();
if v == null goto label;
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.http.HttpSubScan subScan>;
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpSubScan: org.apache.drill.exec.store.http.HttpScanSpec tableSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpScanSpec: org.apache.drill.exec.store.http.HttpApiConfig connectionConfig()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpApiConfig: org.apache.drill.exec.store.http.HttpXmlOptions xmlOptions()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpXmlOptions: org.apache.drill.exec.record.metadata.TupleMetadata schema()>();
if v == null goto label;
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.http.HttpSubScan subScan>;
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpSubScan: org.apache.drill.exec.store.http.HttpScanSpec tableSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpScanSpec: org.apache.drill.exec.store.http.HttpApiConfig connectionConfig()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpApiConfig: org.apache.drill.exec.store.http.HttpXmlOptions xmlOptions()>();
v = virtualinvoke v.<org.apache.drill.exec.store.http.HttpXmlOptions: org.apache.drill.exec.record.metadata.TupleMetadata schema()>();
v = interfaceinvoke v.<org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator: boolean hasProvidedSchema()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator: org.apache.drill.exec.record.metadata.TupleMetadata providedSchema()>();
v = staticinvoke <org.apache.drill.exec.physical.impl.scan.v.FixedReceiver$Builder: org.apache.drill.exec.record.metadata.TupleMetadata mergeSchemas(org.apache.drill.exec.record.metadata.TupleMetadata,org.apache.drill.exec.record.metadata.TupleMetadata)>(v, v);
return v;
label:
return v;
label:
v = interfaceinvoke v.<org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator: boolean hasProvidedSchema()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator: org.apache.drill.exec.record.metadata.TupleMetadata providedSchema()>();
return v;
label:
return null;
}
public boolean next()
{
java.lang.Throwable v;
org.apache.drill.exec.physical.resultSet.ResultSetLoader v;
long v;
org.apache.drill.exec.store.xml.XMLReader v;
org.apache.drill.exec.store.http.paginator.Paginator v, v, v;
byte v;
int v, v;
java.lang.String v;
boolean v, v;
org.apache.drill.exec.store.http.HttpXMLBatchReader v;
v := @this: org.apache.drill.exec.store.http.HttpXMLBatchReader;
label:
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.xml.XMLReader xmlReader>;
v = virtualinvoke v.<org.apache.drill.exec.store.xml.XMLReader: boolean next()>();
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException: java.lang.String getMessage()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("EOF");
if v == 0 goto label;
return 0;
label:
throw v;
label:
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.http.paginator.Paginator paginator>;
if v == null goto label;
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: int maxRecords>;
if v >= 0 goto label;
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.physical.resultSet.ResultSetLoader resultLoader>;
v = interfaceinvoke v.<org.apache.drill.exec.physical.resultSet.ResultSetLoader: long totalRowCount()>();
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.http.paginator.Paginator paginator>;
v = virtualinvoke v.<org.apache.drill.exec.store.http.paginator.Paginator: int getPageSize()>();
v = v cmp v;
if v >= 0 goto label;
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.http.paginator.Paginator paginator>;
virtualinvoke v.<org.apache.drill.exec.store.http.paginator.Paginator: void notifyPartialPage()>();
label:
return v;
catch org.apache.drill.common.exceptions.UserException from label to label with label;
}
public void close()
{
java.lang.AutoCloseable[] v;
java.lang.Object[] v;
org.apache.drill.exec.store.xml.XMLReader v;
java.io.InputStream v;
org.apache.drill.exec.store.http.HttpXMLBatchReader v;
v := @this: org.apache.drill.exec.store.http.HttpXMLBatchReader;
v = newarray (java.lang.AutoCloseable)[1];
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.apache.drill.exec.store.xml.XMLReader xmlReader>;
v[0] = v;
staticinvoke <org.apache.drill.common.AutoCloseables: void closeSilently(java.lang.AutoCloseable[])>(v);
v = newarray (java.lang.AutoCloseable)[1];
v = v.<org.apache.drill.exec.store.http.HttpXMLBatchReader: java.io.InputStream inStream>;
v[0] = v;
staticinvoke <org.apache.drill.common.AutoCloseables: void closeSilently(java.lang.AutoCloseable[])>(v);
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/drill/exec/store/http/HttpXMLBatchReader;");
<org.apache.drill.exec.store.http.HttpXMLBatchReader: org.slf4j.Logger logger> = v;
return;
}
}