public class org.apache.hive.service.cli.operation.SQLOperation extends org.apache.hive.service.cli.operation.ExecuteStatementOperation { private org.apache.hadoop.hive.ql.IDriver driver; private java.util.Optional resultSchema; private org.apache.hadoop.hive.serde.AbstractSerDe serde; private boolean fetchStarted; private volatile org.apache.hadoop.hive.common.metrics.common.MetricsScope currentSQLStateScope; private final org.apache.hadoop.hive.ql.QueryInfo queryInfo; private final long queryTimeout; private java.util.concurrent.ScheduledExecutorService timeoutExecutor; private final boolean runAsync; private final long operationLogCleanupDelayMs; private final java.util.ArrayList convey; private static final java.util.Map USER_QUERIES; private static final java.lang.String ACTIVE_SQL_USER; private final java.util.Optional submittedQryScp; public void (org.apache.hive.service.cli.session.HiveSession, java.lang.String, java.util.Map, boolean, long) { org.apache.hive.service.cli.operation.SQLOperation v; java.util.Map v; long v; java.lang.String v; boolean v; org.apache.hive.service.cli.session.HiveSession v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v := @parameter: org.apache.hive.service.cli.session.HiveSession; v := @parameter: java.lang.String; v := @parameter: java.util.Map; v := @parameter: boolean; v := @parameter: long; specialinvoke v.(org.apache.hive.service.cli.session.HiveSession,java.lang.String,java.util.Map,boolean,long,boolean)>(v, v, v, v, v, 0); return; } public void (org.apache.hive.service.cli.session.HiveSession, java.lang.String, java.util.Map, boolean, long, boolean) { org.apache.hadoop.hive.common.metrics.common.Metrics v; byte v, v, v; org.apache.hive.service.cli.HandleIdentifier v, v; java.util.Map v; boolean v, v; org.apache.hadoop.hive.ql.QueryInfo v; org.apache.hive.service.cli.SessionHandle v; org.apache.hive.service.cli.operation.SQLOperation v; org.apache.hadoop.hive.ql.session.SessionState v; org.apache.hive.service.cli.session.HiveSession v, v, v; java.util.Optional v, v; org.apache.hadoop.hive.common.metrics.common.MetricsScope v; org.apache.hive.service.cli.OperationState v; long v, v, v; java.util.ArrayList v; org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v; java.lang.String v, v, v, v, v, v; org.apache.hadoop.hive.ql.QueryState v, v; org.apache.hadoop.hive.conf.HiveConf v, v; java.util.concurrent.TimeUnit v, v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v := @parameter: org.apache.hive.service.cli.session.HiveSession; v := @parameter: java.lang.String; v := @parameter: java.util.Map; v := @parameter: boolean; v := @parameter: long; v := @parameter: boolean; specialinvoke v.(org.apache.hive.service.cli.session.HiveSession,java.lang.String,java.util.Map,boolean,boolean)>(v, v, v, v, v); v. = null; v. = null; v. = 0; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v. = v; v = staticinvoke (); v. = v; v = v.; v = virtualinvoke v.(); v = ; v = ; v = staticinvoke (v, v, v); v = v cmp 0L; if v <= 0 goto label; v = v cmp 0L; if v <= 0 goto label; v = v cmp v; if v >= 0 goto label; label: v. = v; goto label; label: v. = v; label: v = v.; v = virtualinvoke v.(); v = ; v = ; v = staticinvoke (v, v, v); v. = v; v = interfaceinvoke v.(); specialinvoke v.(v); v = new org.apache.hadoop.hive.ql.QueryInfo; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v); v. = v; v = staticinvoke (); if v != null goto label; v = staticinvoke (); goto label; label: v = interfaceinvoke v.("hs2_submitted_queries"); v = staticinvoke (v); label: v. = v; return; } public boolean shouldRunAsync() { org.apache.hive.service.cli.operation.SQLOperation v; boolean v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v = v.; return v; } private void setupSessionIO(org.apache.hadoop.hive.ql.session.SessionState) { java.nio.charset.Charset v, v, v; org.apache.hadoop.hive.common.io.SessionStream v, v, v; java.lang.String v, v, v; java.io.PrintStream v, v, v; org.slf4j.Logger v; org.apache.hive.service.cli.operation.SQLOperation v; org.apache.hadoop.hive.ql.session.SessionState v; java.io.UnsupportedEncodingException v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v := @parameter: org.apache.hadoop.hive.ql.session.SessionState; label: v. = null; v = new org.apache.hadoop.hive.common.io.SessionStream; v = ; v = ; v = virtualinvoke v.(); specialinvoke v.(java.io.OutputStream,boolean,java.lang.String)>(v, 1, v); v. = v; v = new org.apache.hadoop.hive.common.io.SessionStream; v = ; v = ; v = virtualinvoke v.(); specialinvoke v.(java.io.OutputStream,boolean,java.lang.String)>(v, 1, v); v. = v; v = new org.apache.hadoop.hive.common.io.SessionStream; v = ; v = ; v = virtualinvoke v.(); specialinvoke v.(java.io.OutputStream,boolean,java.lang.String)>(v, 1, v); v. = v; label: goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.("Error creating PrintStream", v); v. = null; v. = null; v. = null; label: return; catch java.io.UnsupportedEncodingException from label to label with label; } private void prepare(org.apache.hadoop.hive.ql.QueryState) throws org.apache.hive.service.cli.HiveSQLException { byte[] v; byte v; org.apache.hive.service.cli.HandleIdentifier v; org.apache.hadoop.hive.ql.IDriver v, v, v, v, v; boolean v, v; org.apache.hadoop.hive.ql.QueryInfo v, v, v; org.apache.hive.service.cli.operation.SQLOperation v; org.apache.hive.service.cli.session.HiveSession v; org.apache.hadoop.hive.ql.session.OperationLog v, v; java.lang.Throwable v, v; org.apache.hive.service.cli.OperationState v, v, v; java.util.concurrent.Callable v; long v, v; java.util.concurrent.ScheduledExecutorService v, v; java.lang.String v, v, v, v, v, v, v; org.apache.hadoop.hive.ql.QueryState v; org.apache.hive.service.cli.HiveSQLException v, v; java.util.Base64$Encoder v, v; java.util.concurrent.TimeUnit v; org.apache.hive.service.rpc.thrift.THandleIdentifier v; org.apache.hive.service.cli.OperationHandle v; org.apache.hadoop.hive.ql.QueryDisplay v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v := @parameter: org.apache.hadoop.hive.ql.QueryState; v = ; virtualinvoke v.(v); label: v = v.; v = staticinvoke (v, v); v. = v; v = v.; v = v cmp 0L; if v <= 0 goto label; v = staticinvoke (); v. = v; v = v.; v = staticinvoke (v, v); v = v.; v = ; interfaceinvoke v.(v, v, v); label: v = v.; v = v.; v = interfaceinvoke v.(); virtualinvoke v.(v); v = v.; if v == null goto label; v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = staticinvoke (); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; v = v.; interfaceinvoke v.(v); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v); label: v = v.; v = interfaceinvoke v.(); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; virtualinvoke v.(v); v = virtualinvoke v.("Error while compiling statement", v); throw v; label: v := @caughtexception; v = ; virtualinvoke v.(v); v = v instanceof java.lang.OutOfMemoryError; if v == 0 goto label; throw v; label: v = new org.apache.hive.service.cli.HiveSQLException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Error running query", v); throw v; label: return; catch org.apache.hadoop.hive.ql.processors.CommandProcessorException from label to label with label; catch java.lang.Throwable from label to label with label; } private void runQuery() throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.OperationState v, v, v, v, v; java.lang.String v; org.apache.hadoop.hive.ql.IDriver v; boolean v, v, v, v, v; org.apache.hive.service.cli.HiveSQLException v, v; org.slf4j.Logger v, v; org.apache.hive.service.cli.operation.SQLOperation v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Not running the query. Operation is already in terminal state: \u, perhaps cancelled due to query timeout or by another thread."); interfaceinvoke v.(v); label: return; label: v = v.; interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("Ignore exception in terminal state: {}", v, v); return; label: v = ; virtualinvoke v.(v); v = v instanceof org.apache.hadoop.hive.ql.processors.CommandProcessorException; if v == 0 goto label; v = virtualinvoke v.("Error while compiling statement", v); throw v; label: v = v instanceof org.apache.hive.service.cli.HiveSQLException; if v == 0 goto label; throw v; label: v = v instanceof java.lang.OutOfMemoryError; if v == 0 goto label; throw v; label: v = new org.apache.hive.service.cli.HiveSQLException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Error running query", v); throw v; label: v = ; virtualinvoke v.(v); return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void runInternal() throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.cli.OperationState v, v; java.util.concurrent.Future v; java.util.concurrent.RejectedExecutionException v; org.apache.hive.service.cli.operation.SQLOperation$BackgroundWork v; org.apache.hadoop.hive.conf.HiveConf$ConfVars v; org.apache.hadoop.security.UserGroupInformation v; org.apache.hadoop.hive.ql.QueryState v, v; boolean v, v, v, v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hadoop.hive.ql.metadata.Hive v; org.apache.hive.service.cli.operation.SQLOperation v; org.apache.hadoop.hive.conf.HiveConf v; org.apache.hadoop.hive.ql.session.SessionState v; org.apache.hive.service.cli.session.HiveSession v, v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v = ; virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = ; v = staticinvoke (v, v); if v == 0 goto label; v = 1; goto label; label: v = 0; label: v = v; if v != 0 goto label; v = v.; specialinvoke v.(v); label: if v != 0 goto label; specialinvoke v.(); goto label; label: v = new org.apache.hive.service.cli.operation.SQLOperation$BackgroundWork; v = specialinvoke v.(); v = v.; v = interfaceinvoke v.(); v = staticinvoke (); specialinvoke v.(org.apache.hive.service.cli.operation.SQLOperation,org.apache.hadoop.security.UserGroupInformation,org.apache.hadoop.hive.ql.metadata.Hive,org.apache.hadoop.hive.ql.session.SessionState,boolean)>(v, v, v, v, v); label: v = virtualinvoke v.(); v = interfaceinvoke v.(v); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; virtualinvoke v.(v); v = new org.apache.hive.service.cli.HiveSQLException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("The background threadpool cannot accept new task for execution, please retry the operation", v); throw v; label: return; catch java.util.concurrent.RejectedExecutionException from label to label with label; } private org.apache.hadoop.security.UserGroupInformation getCurrentUGI() throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.operation.SQLOperation v; org.apache.hadoop.security.UserGroupInformation v; java.lang.Exception v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; label: v = staticinvoke (); label: return v; label: v := @caughtexception; v = new org.apache.hive.service.cli.HiveSQLException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Unable to get current user", v); throw v; catch java.lang.Exception from label to label with label; } private synchronized void cleanup(org.apache.hive.service.cli.OperationState) throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.cli.OperationState v, v, v, v; java.util.concurrent.Future v; java.util.concurrent.ScheduledExecutorService v, v; java.lang.String v; org.apache.hadoop.hive.ql.QueryState v; org.apache.hadoop.hive.ql.IDriver v, v, v; boolean v, v, v, v; org.slf4j.Logger v, v, v, v; org.apache.hive.service.cli.operation.SQLOperation v; org.apache.hadoop.hive.ql.session.SessionState v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v := @parameter: org.apache.hive.service.cli.OperationState; virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = ; if v == v goto label; v = ; if v == v goto label; v = virtualinvoke v.(); if v == null goto label; v = interfaceinvoke v.(1); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.("The running operation has been successfully interrupted: {}", v); goto label; label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.("The running operation could not be cancelled, typically because it has already completed normally: {}", v); label: v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(); label: v. = null; v = staticinvoke (); if v != null goto label; v = v.; interfaceinvoke v.("Operation seems to be in invalid state, SessionState is null"); goto label; label: virtualinvoke v.(); virtualinvoke v.(); label: v = v.; if v == null goto label; v = ; if v == v goto label; v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.(); label: return; } public void cancel(org.apache.hive.service.cli.OperationState) throws org.apache.hive.service.cli.HiveSQLException { org.slf4j.Logger v, v; org.apache.hive.service.cli.operation.SQLOperation v; org.apache.hive.service.cli.OperationState v, v, v; long v; java.lang.String v; org.apache.hadoop.hive.ql.QueryState v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v := @parameter: org.apache.hive.service.cli.OperationState; v = null; v = ; if v != v goto label; v = v.; v = virtualinvoke v.(); v = v.; interfaceinvoke v.("Cancelling the query execution: {}", v); label: specialinvoke v.(v); v = v.; virtualinvoke v.(v); v = ; if v != v goto label; v = v.; interfaceinvoke v.("Successfully cancelled the query: {}", v); label: return; } public void close() throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.cli.operation.SQLOperation v; org.apache.hive.service.cli.OperationState v; boolean v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v = v.; if v != 0 goto label; v = ; specialinvoke v.(v); virtualinvoke v.(0L); label: return; } public org.apache.hive.service.cli.TableSchema getResultSetSchema() throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.cli.operation.SQLOperation v; org.apache.hive.service.cli.OperationState v, v; org.apache.hive.service.cli.TableSchema v; org.apache.hadoop.hive.metastore.api.Schema v; org.apache.hive.service.cli.OperationState[] v; java.util.List v; java.util.Optional v, v, v; java.lang.Object v; org.apache.hadoop.hive.ql.IDriver v; boolean v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v = newarray (org.apache.hive.service.cli.OperationState)[2]; v = ; v[0] = v; v = ; v[1] = v; v = staticinvoke (v); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = new org.apache.hive.service.cli.TableSchema; v = v.; v = interfaceinvoke v.(); specialinvoke v.(org.apache.hadoop.hive.metastore.api.Schema)>(v); v = staticinvoke (v); v. = v; label: v = v.; v = virtualinvoke v.(); return v; } public org.apache.hive.service.cli.RowSet getNextRowSet(org.apache.hive.service.cli.FetchOrientation, long) throws org.apache.hive.service.cli.HiveSQLException { java.lang.Integer v; org.apache.hive.service.cli.FetchOrientation v, v; org.apache.hadoop.hive.ql.exec.FetchTask v; org.apache.hadoop.hive.ql.IDriver v, v, v, v; boolean v, v, v, v, v; org.apache.hive.service.cli.operation.SQLOperation v; java.util.Set v; java.lang.Exception v; java.io.Serializable v; java.lang.Throwable v; org.apache.hive.service.cli.OperationState v; org.apache.hive.service.cli.RowSet v, v; org.apache.hive.service.cli.TableSchema v; long v; java.util.ArrayList v, v, v, v, v, v, v; int v, v; java.lang.String v, v; org.apache.hive.service.rpc.thrift.TProtocolVersion v; org.apache.hive.service.cli.HiveSQLException v; org.slf4j.Logger v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v := @parameter: org.apache.hive.service.cli.FetchOrientation; v := @parameter: long; virtualinvoke v.(v); v = ; v = staticinvoke (v); virtualinvoke v.(v); v = v.; v = interfaceinvoke v.(); v = 0; if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = 1L; v = 1; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v, v); label: v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = v.; if v == 0 goto label; v = v.; interfaceinvoke v.(); label: v. = 1; v = staticinvoke (v); v = v.; virtualinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v != v goto label; v = v.; v = staticinvoke (v); interfaceinvoke v.("Result set buffer filled to capacity [{}]", v); label: v = v.; v = specialinvoke v.(v, v); label: v = v.; virtualinvoke v.(); return v; label: v = v.; virtualinvoke v.(); return v; label: v := @caughtexception; v = new org.apache.hive.service.cli.HiveSQLException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Unable to get the next row set with exception: \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: v := @caughtexception; v = v.; virtualinvoke v.(); throw v; catch java.lang.Exception from label to label with label; catch java.lang.Throwable from label to label with label; } public java.lang.String getTaskStatus() throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.HiveSQLException v; java.io.ByteArrayOutputStream v; org.apache.hive.service.cli.operation.SQLOperation v; java.lang.Exception v; java.util.List v; java.nio.charset.Charset v; java.lang.String v, v; org.apache.hadoop.hive.ql.QueryDisplay v; org.apache.hadoop.hive.ql.IDriver v, v; org.apache.hive.com.fasterxml.jackson.databind.ObjectMapper v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == null goto label; label: v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); label: v = ; virtualinvoke v.(v, v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); label: virtualinvoke v.(); label: return v; label: v := @caughtexception; throw v; label: v := @caughtexception; v = new org.apache.hive.service.cli.HiveSQLException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: return null; catch java.lang.Throwable from label to label with label; catch java.lang.Exception from label to label with label; } private org.apache.hive.service.cli.RowSet decode(java.util.List, org.apache.hive.service.cli.RowSet) throws java.lang.Exception { java.util.List v; org.apache.hive.service.cli.operation.SQLOperation v; org.apache.hive.service.cli.RowSet v, v; org.apache.hadoop.hive.ql.IDriver v; boolean v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v := @parameter: java.util.List; v := @parameter: org.apache.hive.service.cli.RowSet; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = specialinvoke v.(v, v); goto label; label: v = specialinvoke v.(v, v); label: return v; } private org.apache.hive.service.cli.RowSet prepareFromRow(java.util.List, org.apache.hive.service.cli.RowSet) throws java.lang.Exception { java.util.function.Consumer v; java.util.List v; org.apache.hive.service.cli.operation.SQLOperation v; org.apache.hive.service.cli.RowSet v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v := @parameter: java.util.List; v := @parameter: org.apache.hive.service.cli.RowSet; v = staticinvoke (v); interfaceinvoke v.(v); return v; } private org.apache.hive.service.cli.RowSet decodeFromString(java.util.List, org.apache.hive.service.cli.RowSet) throws java.sql.SQLException, org.apache.hadoop.hive.serde.SerDeException { byte[] v; java.lang.Object[] v; org.apache.hive.service.cli.RowSet v; org.apache.hadoop.hive.serde.AbstractSerDe v, v; java.nio.charset.Charset v; int v, v, v, v; org.apache.hadoop.io.BytesWritable v; org.apache.hadoop.hive.serde.objectinspector.ObjectInspector v, v; boolean v; org.apache.hive.service.rpc.thrift.TProtocolVersion v; java.util.Iterator v; org.apache.hive.service.cli.operation.SQLOperation v; java.util.List v, v; java.lang.Object v, v, v, v, v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v := @parameter: java.util.List; v := @parameter: org.apache.hive.service.cli.RowSet; specialinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = newarray (java.lang.Object)[v]; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = new org.apache.hadoop.io.BytesWritable; v = ; v = virtualinvoke v.(v); specialinvoke v.(byte[])>(v); v = virtualinvoke v.(v); v = 0; label: v = interfaceinvoke v.(); if v >= v goto label; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(v, v); v = staticinvoke (v, v, v); v[v] = v; v = v + 1; goto label; label: interfaceinvoke v.(v); goto label; label: return v; } private org.apache.hadoop.hive.serde.AbstractSerDe getSerDe() throws java.sql.SQLException { org.apache.hadoop.hive.metastore.api.Schema v; java.util.function.Function v, v; org.apache.hadoop.hive.serde.AbstractSerDe v, v, v; java.sql.SQLException v; java.lang.String v, v; java.util.stream.Collector v, v; org.apache.hadoop.hive.ql.QueryState v; org.apache.hadoop.hive.ql.IDriver v; boolean v; java.util.Properties v; org.slf4j.Logger v, v; org.apache.hive.service.cli.operation.SQLOperation v; org.apache.hadoop.hive.conf.HiveConf v; org.apache.hadoop.hive.serde.lazy.LazySimpleSerDe v; java.lang.Exception v; java.util.List v; java.util.stream.Stream v, v, v, v; java.lang.Object v, v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v = v.; if v != null goto label; label: v = new org.apache.hadoop.hive.serde.lazy.LazySimpleSerDe; specialinvoke v.()>(); v. = v; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = new java.util.Properties; specialinvoke v.()>(); v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (","); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (","); v = interfaceinvoke v.(v); v = v.; interfaceinvoke v.("Column names: {}", v); v = v.; interfaceinvoke v.("Column types: {}", v); virtualinvoke v.("columns", v); virtualinvoke v.("columns.types", v); label: v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, null); label: goto label; label: v := @caughtexception; v = new java.sql.SQLException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not create ResultSet: \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: v = v.; return v; catch java.lang.Exception from label to label with label; } public org.apache.hadoop.hive.ql.QueryInfo getQueryInfo() { org.apache.hadoop.hive.ql.QueryInfo v; org.apache.hive.service.cli.operation.SQLOperation v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v = v.; return v; } protected void onNewState(org.apache.hive.service.cli.OperationState, org.apache.hive.service.cli.OperationState) { org.apache.hadoop.hive.common.metrics.common.Metrics v, v, v; int[] v; boolean v, v, v, v, v, v, v; org.apache.hadoop.hive.ql.QueryInfo v, v, v, v, v, v, v, v; org.apache.hive.service.cli.operation.SQLOperation v; java.util.Optional v, v, v, v, v, v, v; org.apache.hadoop.hive.common.metrics.common.MetricsScope v, v; org.apache.hive.service.cli.OperationState v, v, v, v; long v, v, v, v, v, v, v, v, v; int v, v; java.lang.String v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v := @parameter: org.apache.hive.service.cli.OperationState; v := @parameter: org.apache.hive.service.cli.OperationState; specialinvoke v.(v, v); v = v.; v = virtualinvoke v.(v, "hs2_sql_operation_", "hs2_completed_sql_operation_", v); v. = v; v = staticinvoke (); v = staticinvoke (v); v = virtualinvoke v.(); if v == 0 goto label; v = ; if v != v goto label; if v == v goto label; v = virtualinvoke v.(); specialinvoke v.(v); label: v = ; if v != v goto label; if v == v goto label; v = virtualinvoke v.(); specialinvoke v.(v); label: v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; case 6: goto label; case 7: goto label; case 8: goto label; case 9: goto label; default: goto label; }; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; virtualinvoke v.(); goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = staticinvoke (); specialinvoke v.(v, "hs2_failed_queries"); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = staticinvoke (); specialinvoke v.(v, "hs2_succeeded_queries"); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: return; } private void incrementUserQueries(org.apache.hadoop.hive.common.metrics.common.Metrics) { org.apache.hadoop.hive.common.metrics.common.Metrics v; org.apache.hive.service.cli.operation.SQLOperation v; java.util.Map v; java.util.function.BiFunction v; java.lang.String v; boolean v; org.apache.hive.service.cli.session.HiveSession v; v := @this: org.apache.hive.service.cli.operation.SQLOperation; v := @parameter: org.apache.hadoop.hive.common.metrics.common.Metrics; v = v.; v = interfaceinvoke v.(); v = staticinvoke