public abstract class org.apache.hive.service.cli.thrift.ThriftCLIService extends org.apache.hive.service.AbstractService implements org.apache.hive.service.rpc.thrift.TCLIService$Iface, java.lang.Runnable
{
protected static final org.slf4j.Logger LOG;
protected org.apache.hive.service.cli.CLIService cliService;
private static final org.apache.hive.service.rpc.thrift.TStatus OK_STATUS;
protected org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory;
protected int portNum;
protected java.net.InetAddress serverIPAddress;
protected java.lang.String hiveHost;
private boolean isStarted;
protected boolean isEmbedded;
protected org.apache.hadoop.hive.conf.HiveConf hiveConf;
protected int minWorkerThreads;
protected int maxWorkerThreads;
protected long workerKeepAliveTime;
private java.lang.Thread serverThread;
protected java.lang.ThreadLocal currentServerContext;
public void <init>(org.apache.hive.service.cli.CLIService, java.lang.String)
{
java.lang.ThreadLocal v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
java.lang.String v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.cli.CLIService;
v := @parameter: java.lang.String;
specialinvoke v.<org.apache.hive.service.AbstractService: void <init>(java.lang.String)>(v);
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: boolean isStarted> = 0;
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: boolean isEmbedded> = 0;
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService> = v;
v = new java.lang.ThreadLocal;
specialinvoke v.<java.lang.ThreadLocal: void <init>()>();
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.ThreadLocal currentServerContext> = v;
return;
}
public synchronized void init(org.apache.hadoop.hive.conf.HiveConf)
{
org.apache.hive.service.ServiceException v;
long v, v;
java.net.InetAddress v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v, v, v, v, v, v;
int v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v;
org.apache.hadoop.hive.conf.HiveServer2TransportMode v, v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hadoop.hive.conf.HiveConf v;
java.net.UnknownHostException v;
java.util.concurrent.TimeUnit v, v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf;
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hadoop.hive.conf.HiveConf hiveConf> = v;
v = staticinvoke <java.lang.System: java.lang.String getenv(java.lang.String)>("HIVE_SERVER2_THRIFT_BIND_HOST");
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.String hiveHost> = v;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.String hiveHost>;
if v != null goto label;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_BIND_HOST>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.String hiveHost> = v;
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.String hiveHost>;
v = staticinvoke <org.apache.hadoop.hive.common.ServerUtils: java.net.InetAddress getHostAddress(java.lang.String)>(v);
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.net.InetAddress serverIPAddress> = v;
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.service.ServiceException;
specialinvoke v.<org.apache.hive.service.ServiceException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = virtualinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hadoop.hive.conf.HiveServer2TransportMode getTransportMode()>();
v = <org.apache.hadoop.hive.conf.HiveServer2TransportMode: org.apache.hadoop.hive.conf.HiveServer2TransportMode http>;
if v != v goto label;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_HTTP_WORKER_KEEPALIVE_TIME>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: long getTimeVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars,java.util.concurrent.TimeUnit)>(v, v);
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: long workerKeepAliveTime> = v;
v = staticinvoke <java.lang.System: java.lang.String getenv(java.lang.String)>("HIVE_SERVER2_THRIFT_HTTP_PORT");
if v == null goto label;
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: int portNum> = v;
goto label;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_HTTP_PORT>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: int getIntVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: int portNum> = v;
goto label;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_WORKER_KEEPALIVE_TIME>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: long getTimeVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars,java.util.concurrent.TimeUnit)>(v, v);
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: long workerKeepAliveTime> = v;
v = staticinvoke <java.lang.System: java.lang.String getenv(java.lang.String)>("HIVE_SERVER2_THRIFT_PORT");
if v == null goto label;
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: int portNum> = v;
goto label;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_PORT>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: int getIntVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: int portNum> = v;
label:
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_MIN_WORKER_THREADS>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: int getIntVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: int minWorkerThreads> = v;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_MAX_WORKER_THREADS>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: int getIntVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: int maxWorkerThreads> = v;
specialinvoke v.<org.apache.hive.service.AbstractService: void init(org.apache.hadoop.hive.conf.HiveConf)>(v);
return;
catch java.net.UnknownHostException from label to label with label;
}
protected abstract void initServer();
public synchronized void start()
{
org.apache.hive.service.cli.thrift.ThriftCLIService v;
java.lang.Thread v, v, v;
boolean v, v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
specialinvoke v.<org.apache.hive.service.AbstractService: void start()>();
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: boolean isStarted>;
if v != 0 goto label;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: boolean isEmbedded>;
if v != 0 goto label;
virtualinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: void initServer()>();
v = new java.lang.Thread;
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.Thread serverThread> = v;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.Thread serverThread>;
virtualinvoke v.<java.lang.Thread: void setName(java.lang.String)>("Thrift Server");
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.Thread serverThread>;
virtualinvoke v.<java.lang.Thread: void start()>();
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: boolean isStarted> = 1;
label:
return;
}
protected abstract void stopServer();
public synchronized void stop()
{
org.apache.hive.service.cli.thrift.ThriftCLIService v;
java.lang.Thread v, v;
boolean v, v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: boolean isStarted>;
if v == 0 goto label;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: boolean isEmbedded>;
if v != 0 goto label;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.Thread serverThread>;
if v == null goto label;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.Thread serverThread>;
virtualinvoke v.<java.lang.Thread: void interrupt()>();
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.Thread serverThread> = null;
label:
virtualinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: void stopServer()>();
v.<org.apache.hive.service.cli.thrift.ThriftCLIService: boolean isStarted> = 0;
label:
specialinvoke v.<org.apache.hive.service.AbstractService: void stop()>();
return;
}
public int getPortNumber()
{
int v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: int portNum>;
return v;
}
public java.net.InetAddress getServerIPAddress()
{
java.net.InetAddress v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.net.InetAddress serverIPAddress>;
return v;
}
public org.apache.hive.service.rpc.thrift.TGetDelegationTokenResp GetDelegationToken(org.apache.hive.service.rpc.thrift.TGetDelegationTokenReq) throws org.apache.thrift.TException
{
org.apache.hive.service.rpc.thrift.TGetDelegationTokenReq v;
org.apache.hive.service.rpc.thrift.TStatus v, v, v;
java.lang.String v, v, v;
boolean v;
org.apache.hive.service.cli.HiveSQLException v;
org.apache.hive.service.cli.SessionHandle v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.auth.HiveAuthFactory v, v, v;
org.apache.hive.service.rpc.thrift.TGetDelegationTokenResp v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TGetDelegationTokenReq;
v = new org.apache.hive.service.rpc.thrift.TGetDelegationTokenResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TGetDelegationTokenResp: void <init>()>();
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory>;
if v == null goto label;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory>;
v = virtualinvoke v.<org.apache.hive.service.auth.HiveAuthFactory: boolean isSASLKerberosUser()>();
if v != 0 goto label;
label:
v = specialinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus unsecureTokenErrorStatus()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetDelegationTokenResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
goto label;
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetDelegationTokenReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory>;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetDelegationTokenReq: java.lang.String getOwner()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetDelegationTokenReq: java.lang.String getRenewer()>();
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: java.lang.String getDelegationToken(org.apache.hive.service.cli.SessionHandle,org.apache.hive.service.auth.HiveAuthFactory,java.lang.String,java.lang.String)>(v, v, v, v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetDelegationTokenResp: void setDelegationToken(java.lang.String)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetDelegationTokenResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to get delegation token [request: {}]", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TStatus: void setSqlState(java.lang.String)>("42000");
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetDelegationTokenResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch org.apache.hive.service.cli.HiveSQLException from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TCancelDelegationTokenResp CancelDelegationToken(org.apache.hive.service.rpc.thrift.TCancelDelegationTokenReq) throws org.apache.thrift.TException
{
org.apache.hive.service.rpc.thrift.TStatus v, v, v;
java.lang.String v;
org.apache.hive.service.rpc.thrift.TCancelDelegationTokenReq v;
org.apache.hive.service.rpc.thrift.TCancelDelegationTokenResp v;
boolean v;
org.apache.hive.service.cli.HiveSQLException v;
org.apache.hive.service.cli.SessionHandle v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.auth.HiveAuthFactory v, v, v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TCancelDelegationTokenReq;
v = new org.apache.hive.service.rpc.thrift.TCancelDelegationTokenResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TCancelDelegationTokenResp: void <init>()>();
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory>;
if v == null goto label;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory>;
v = virtualinvoke v.<org.apache.hive.service.auth.HiveAuthFactory: boolean isSASLKerberosUser()>();
if v != 0 goto label;
label:
v = specialinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus unsecureTokenErrorStatus()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TCancelDelegationTokenResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
goto label;
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TCancelDelegationTokenReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory>;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TCancelDelegationTokenReq: java.lang.String getDelegationToken()>();
virtualinvoke v.<org.apache.hive.service.cli.CLIService: void cancelDelegationToken(org.apache.hive.service.cli.SessionHandle,org.apache.hive.service.auth.HiveAuthFactory,java.lang.String)>(v, v, v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TCancelDelegationTokenResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to cancel delegation token [request: {}]", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TCancelDelegationTokenResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch org.apache.hive.service.cli.HiveSQLException from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TRenewDelegationTokenResp RenewDelegationToken(org.apache.hive.service.rpc.thrift.TRenewDelegationTokenReq) throws org.apache.thrift.TException
{
org.apache.hive.service.rpc.thrift.TStatus v, v, v;
java.lang.String v;
boolean v;
org.apache.hive.service.cli.HiveSQLException v;
org.apache.hive.service.cli.SessionHandle v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.auth.HiveAuthFactory v, v, v;
org.apache.hive.service.rpc.thrift.TRenewDelegationTokenResp v;
org.apache.hive.service.rpc.thrift.TRenewDelegationTokenReq v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TRenewDelegationTokenReq;
v = new org.apache.hive.service.rpc.thrift.TRenewDelegationTokenResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TRenewDelegationTokenResp: void <init>()>();
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory>;
if v == null goto label;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory>;
v = virtualinvoke v.<org.apache.hive.service.auth.HiveAuthFactory: boolean isSASLKerberosUser()>();
if v != 0 goto label;
label:
v = specialinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus unsecureTokenErrorStatus()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TRenewDelegationTokenResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
goto label;
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TRenewDelegationTokenReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory>;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TRenewDelegationTokenReq: java.lang.String getDelegationToken()>();
virtualinvoke v.<org.apache.hive.service.cli.CLIService: void renewDelegationToken(org.apache.hive.service.cli.SessionHandle,org.apache.hive.service.auth.HiveAuthFactory,java.lang.String)>(v, v, v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TRenewDelegationTokenResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Failed to renew delegation token [request: {}]", v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TRenewDelegationTokenResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch org.apache.hive.service.cli.HiveSQLException from label to label with label;
}
private org.apache.hive.service.rpc.thrift.TStatus unsecureTokenErrorStatus()
{
org.apache.hive.service.rpc.thrift.TStatusCode v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.rpc.thrift.TStatus v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v = new org.apache.hive.service.rpc.thrift.TStatus;
v = <org.apache.hive.service.rpc.thrift.TStatusCode: org.apache.hive.service.rpc.thrift.TStatusCode ERROR_STATUS>;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TStatus: void <init>(org.apache.hive.service.rpc.thrift.TStatusCode)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TStatus: void setErrorMessage(java.lang.String)>("Delegation token only supported over remote client with kerberos authentication");
return v;
}
public org.apache.hive.service.rpc.thrift.TOpenSessionResp OpenSession(org.apache.hive.service.rpc.thrift.TOpenSessionReq) throws org.apache.thrift.TException
{
java.util.HashMap v;
org.apache.hive.service.rpc.thrift.TOpenSessionResp v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v, v, v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
int v;
java.lang.String v, v, v, v, v, v, v;
boolean v;
org.apache.hive.service.rpc.thrift.TProtocolVersion v;
org.apache.hive.service.cli.SessionHandle v;
java.lang.ThreadLocal v;
org.slf4j.Logger v, v, v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.rpc.thrift.TOpenSessionReq v;
org.apache.hadoop.hive.conf.HiveConf v, v;
java.lang.Exception v;
java.lang.Object v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TOpenSessionReq;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TOpenSessionReq: org.apache.hive.service.rpc.thrift.TProtocolVersion getClient_protocol()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.service.rpc.thrift.TProtocolVersion)>(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[])>("Client protocol version: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = new org.apache.hive.service.rpc.thrift.TOpenSessionResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TOpenSessionResp: void <init>()>();
v = null;
label:
v = specialinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.String getUserName(org.apache.hive.service.rpc.thrift.TOpenSessionReq)>(v);
v = specialinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.SessionHandle getSessionHandle(org.apache.hive.service.rpc.thrift.TOpenSessionReq,org.apache.hive.service.rpc.thrift.TOpenSessionResp,java.lang.String)>(v, v, v);
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hadoop.hive.conf.HiveConf hiveConf>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_RESULTSET_DEFAULT_FETCH_SIZE>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: int getIntVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_RESULTSET_DEFAULT_FETCH_SIZE>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_DEFAULT_NULLS_LAST>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: java.lang.String varname>;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hadoop.hive.conf.HiveConf hiveConf>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_DEFAULT_NULLS_LAST>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = staticinvoke <java.lang.String: java.lang.String valueOf(boolean)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.hive.service.cli.SessionHandle: org.apache.hive.service.rpc.thrift.TSessionHandle toTSessionHandle()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TOpenSessionResp: void setSessionHandle(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TOpenSessionResp: void setConfiguration(java.util.Map)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TOpenSessionResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.ThreadLocal currentServerContext>;
v = virtualinvoke v.<java.lang.ThreadLocal: java.lang.Object get()>();
if v == null goto label;
virtualinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService$ThriftCLIServerContext: void setSessionHandle(org.apache.hive.service.cli.SessionHandle)>(v);
label:
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
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[])>("Login attempt is successful for user : \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Login attempt failed for user : {}", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TOpenSessionResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TSetClientInfoResp SetClientInfo(org.apache.hive.service.rpc.thrift.TSetClientInfoReq) throws org.apache.thrift.TException
{
org.apache.hive.service.rpc.thrift.TStatus v, v;
java.util.Map v;
java.lang.String v;
boolean v, v, v;
org.apache.hive.service.rpc.thrift.TSetClientInfoReq v;
org.apache.hive.service.cli.SessionHandle v, v;
org.slf4j.Logger v, v;
java.util.Iterator v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
java.util.Set v;
java.lang.Exception v;
java.lang.Object v, v, v, v, v;
java.lang.StringBuilder v, v, v, v, v;
org.apache.hive.service.rpc.thrift.TSetClientInfoResp v, v, v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TSetClientInfoReq;
v = null;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TSetClientInfoReq: boolean isSetConfiguration()>();
if v == 0 goto label;
v = null;
v = null;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TSetClientInfoReq: java.util.Map getConfiguration()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
if v != null goto label;
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TSetClientInfoReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = v;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>(java.lang.String)>("Client information for ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(": ");
goto label;
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", ");
label:
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(" = ");
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = "ApplicationName";
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
virtualinvoke v.<org.apache.hive.service.cli.CLIService: void setApplicationName(org.apache.hive.service.cli.SessionHandle,java.lang.String)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Failed setting application name", v);
v = new org.apache.hive.service.rpc.thrift.TSetClientInfoResp;
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
specialinvoke v.<org.apache.hive.service.rpc.thrift.TSetClientInfoResp: void <init>(org.apache.hive.service.rpc.thrift.TStatus)>(v);
v = v;
goto label;
label:
if v == null goto label;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("{}", v);
label:
if v != null goto label;
v = new org.apache.hive.service.rpc.thrift.TSetClientInfoResp;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TSetClientInfoResp: void <init>(org.apache.hive.service.rpc.thrift.TStatus)>(v);
goto label;
label:
v = v;
label:
return v;
catch java.lang.Exception from label to label with label;
}
private java.lang.String getIpAddress()
{
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.auth.HiveAuthFactory v, v, v;
java.lang.String v;
org.apache.hadoop.hive.conf.HiveServer2TransportMode v, v;
boolean v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v = virtualinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hadoop.hive.conf.HiveServer2TransportMode getTransportMode()>();
v = <org.apache.hadoop.hive.conf.HiveServer2TransportMode: org.apache.hadoop.hive.conf.HiveServer2TransportMode http>;
if v != v goto label;
v = staticinvoke <org.apache.hive.service.cli.session.SessionManager: java.lang.String getIpAddress()>();
goto label;
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory>;
if v == null goto label;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory>;
v = virtualinvoke v.<org.apache.hive.service.auth.HiveAuthFactory: boolean isSASLWithKerberizedHadoop()>();
if v == 0 goto label;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory>;
v = virtualinvoke v.<org.apache.hive.service.auth.HiveAuthFactory: java.lang.String getIpAddress()>();
goto label;
label:
v = staticinvoke <org.apache.hive.service.auth.TSetIpAddressProcessor: java.lang.String getUserIpAddress()>();
label:
return v;
}
private java.lang.String getUserName(org.apache.hive.service.rpc.thrift.TOpenSessionReq) throws org.apache.hive.service.cli.HiveSQLException, java.io.IOException
{
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
java.util.Map v;
java.lang.String v, v, v;
org.apache.hadoop.hive.conf.HiveServer2TransportMode v, v;
boolean v, v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.rpc.thrift.TOpenSessionReq v;
org.apache.hadoop.hive.conf.HiveConf v;
org.apache.hive.service.auth.HiveAuthFactory v, v, v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TOpenSessionReq;
v = null;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory>;
if v == null goto label;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory>;
v = virtualinvoke v.<org.apache.hive.service.auth.HiveAuthFactory: boolean isSASLWithKerberizedHadoop()>();
if v == 0 goto label;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory>;
v = virtualinvoke v.<org.apache.hive.service.auth.HiveAuthFactory: java.lang.String getRemoteUser()>();
label:
if v != null goto label;
v = staticinvoke <org.apache.hive.service.auth.TSetIpAddressProcessor: java.lang.String getUserName()>();
label:
v = virtualinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hadoop.hive.conf.HiveServer2TransportMode getTransportMode()>();
v = <org.apache.hadoop.hive.conf.HiveServer2TransportMode: org.apache.hadoop.hive.conf.HiveServer2TransportMode http>;
if v != v goto label;
v = staticinvoke <org.apache.hive.service.cli.session.SessionManager: java.lang.String getUserName()>();
label:
if v != null goto label;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TOpenSessionReq: java.lang.String getUsername()>();
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hadoop.hive.conf.HiveConf getHiveConf()>();
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_AUTHORIZATION_KERBEROS_USE_SHORTNAME>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == 0 goto label;
v = specialinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.String getShortName(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TOpenSessionReq: java.util.Map getConfiguration()>();
v = specialinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.String getIpAddress()>();
v = specialinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.String getProxyUser(java.lang.String,java.util.Map,java.lang.String)>(v, v, v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Client\'s username: {}", v);
return v;
}
private java.lang.String getShortName(java.lang.String) throws java.io.IOException
{
org.apache.hadoop.hive.shims.HadoopShims v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hadoop.hive.shims.HadoopShims$KerberosNameShim v;
org.apache.hive.service.auth.HiveAuthFactory v, v;
int v;
java.lang.String v, v, v;
boolean v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: java.lang.String;
v = null;
if v == null goto label;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory>;
if v == null goto label;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.auth.HiveAuthFactory hiveAuthFactory>;
v = virtualinvoke v.<org.apache.hive.service.auth.HiveAuthFactory: boolean isSASLKerberosUser()>();
if v == 0 goto label;
v = staticinvoke <org.apache.hadoop.hive.shims.ShimLoader: org.apache.hadoop.hive.shims.HadoopShims getHadoopShims()>();
v = interfaceinvoke v.<org.apache.hadoop.hive.shims.HadoopShims: org.apache.hadoop.hive.shims.HadoopShims$KerberosNameShim getKerberosNameShim(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.hadoop.hive.shims.HadoopShims$KerberosNameShim: java.lang.String getShortName()>();
goto label;
label:
v = staticinvoke <org.apache.hive.service.ServiceUtils: int indexOfDomainMatch(java.lang.String)>(v);
if v > 0 goto label;
v = v;
goto label;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
label:
v = v;
label:
return v;
}
private org.apache.hive.service.cli.SessionHandle getSessionHandle(org.apache.hive.service.rpc.thrift.TOpenSessionReq, org.apache.hive.service.rpc.thrift.TOpenSessionResp, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException, javax.security.auth.login.LoginException, java.io.IOException
{
org.apache.hive.service.rpc.thrift.TOpenSessionResp v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
java.util.Map v, v;
java.lang.String v, v, v, v, v, v;
boolean v;
org.apache.hive.service.rpc.thrift.TProtocolVersion v, v, v;
org.apache.hive.service.cli.SessionHandle v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v, v, v;
org.apache.hive.service.rpc.thrift.TOpenSessionReq v;
org.apache.hadoop.hive.conf.HiveConf v;
org.apache.hive.service.rpc.thrift.TProtocolVersion[] v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TOpenSessionReq;
v := @parameter: org.apache.hive.service.rpc.thrift.TOpenSessionResp;
v := @parameter: java.lang.String;
v = specialinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.String getIpAddress()>();
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TOpenSessionReq: java.lang.String getUsername()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Creating Hive session handle for user [{}] from IP {}", v, v);
v = newarray (org.apache.hive.service.rpc.thrift.TProtocolVersion)[2];
v = <org.apache.hive.service.cli.CLIService: org.apache.hive.service.rpc.thrift.TProtocolVersion SERVER_VERSION>;
v[0] = v;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TOpenSessionReq: org.apache.hive.service.rpc.thrift.TProtocolVersion getClient_protocol()>();
v[1] = v;
v = specialinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TProtocolVersion getMinVersion(org.apache.hive.service.rpc.thrift.TProtocolVersion[])>(v);
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hadoop.hive.conf.HiveConf getHiveConf()>();
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_ENABLE_DOAS>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == 0 goto label;
if v == null goto label;
v = specialinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.String getDelegationToken(java.lang.String)>(v);
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TOpenSessionReq: java.lang.String getPassword()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TOpenSessionReq: java.util.Map getConfiguration()>();
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.SessionHandle openSessionWithImpersonation(org.apache.hive.service.rpc.thrift.TProtocolVersion,java.lang.String,java.lang.String,java.lang.String,java.util.Map,java.lang.String)>(v, v, v, v, v, v);
goto label;
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TOpenSessionReq: java.lang.String getPassword()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TOpenSessionReq: java.util.Map getConfiguration()>();
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.SessionHandle openSession(org.apache.hive.service.rpc.thrift.TProtocolVersion,java.lang.String,java.lang.String,java.lang.String,java.util.Map)>(v, v, v, v, v);
label:
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TOpenSessionResp: void setServerProtocolVersion(org.apache.hive.service.rpc.thrift.TProtocolVersion)>(v);
return v;
}
private double getProgressedPercentage(org.apache.hive.service.cli.OperationHandle) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.session.SessionManager v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.cli.OperationType v, v;
org.apache.hadoop.hive.ql.session.SessionState v;
org.apache.hive.service.cli.operation.Operation v;
org.apache.hive.service.cli.session.HiveSession v;
org.apache.hive.service.cli.operation.OperationManager v;
org.apache.hadoop.hive.common.log.ProgressMonitor v;
org.apache.hive.service.cli.OperationHandle v;
boolean v;
double v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.cli.OperationHandle;
v = <org.apache.hive.service.cli.OperationType: org.apache.hive.service.cli.OperationType EXECUTE_STATEMENT>;
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.cli.OperationType getOperationType()>();
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <com.google.common.base.Preconditions: void checkArgument(boolean)>(v);
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.session.SessionManager getSessionManager()>();
v = virtualinvoke v.<org.apache.hive.service.cli.session.SessionManager: org.apache.hive.service.cli.operation.OperationManager getOperationManager()>();
v = virtualinvoke v.<org.apache.hive.service.cli.operation.OperationManager: org.apache.hive.service.cli.operation.Operation getOperation(org.apache.hive.service.cli.OperationHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.session.HiveSession getParentSession()>();
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: org.apache.hadoop.hive.ql.session.SessionState getSessionState()>();
v = virtualinvoke v.<org.apache.hadoop.hive.ql.session.SessionState: org.apache.hadoop.hive.common.log.ProgressMonitor getProgressMonitor()>();
if v != null goto label;
v = 0.0;
goto label;
label:
v = interfaceinvoke v.<org.apache.hadoop.hive.common.log.ProgressMonitor: double progressedPercentage()>();
label:
return v;
}
private java.lang.String getDelegationToken(java.lang.String) throws org.apache.hive.service.cli.HiveSQLException, javax.security.auth.login.LoginException, java.io.IOException
{
java.lang.UnsupportedOperationException v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
java.lang.String v, v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: java.lang.String;
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: java.lang.String getDelegationTokenFromMetaStore(java.lang.String)>(v);
label:
return v;
label:
v := @caughtexception;
return null;
catch java.lang.UnsupportedOperationException from label to label with label;
}
private transient org.apache.hive.service.rpc.thrift.TProtocolVersion getMinVersion(org.apache.hive.service.rpc.thrift.TProtocolVersion[])
{
int v, v, v, v, v, v, v, v, v;
org.apache.hive.service.rpc.thrift.TProtocolVersion v, v, v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
java.lang.IllegalArgumentException v;
org.apache.hive.service.rpc.thrift.TProtocolVersion[] v, v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TProtocolVersion[];
v = staticinvoke <org.apache.hive.service.rpc.thrift.TProtocolVersion: org.apache.hive.service.rpc.thrift.TProtocolVersion[] values()>();
v = lengthof v;
v = v - 1;
v = v[v];
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TProtocolVersion: int getValue()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TProtocolVersion: int getValue()>();
if v <= v goto label;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TProtocolVersion: int getValue()>();
label:
v = v + 1;
goto label;
label:
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TProtocolVersion: int getValue()>();
if v != v goto label;
return v;
label:
v = v + 1;
goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("never");
throw v;
}
public org.apache.hive.service.rpc.thrift.TCloseSessionResp CloseSession(org.apache.hive.service.rpc.thrift.TCloseSessionReq) throws org.apache.thrift.TException
{
org.apache.hive.service.cli.SessionHandle v;
java.lang.ThreadLocal v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
java.lang.Exception v;
org.apache.hive.service.rpc.thrift.TCloseSessionResp v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
org.apache.hive.service.rpc.thrift.TCloseSessionReq v;
java.lang.Object v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TCloseSessionReq;
v = new org.apache.hive.service.rpc.thrift.TCloseSessionResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TCloseSessionResp: void <init>()>();
label:
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TCloseSessionReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
virtualinvoke v.<org.apache.hive.service.cli.CLIService: void closeSession(org.apache.hive.service.cli.SessionHandle)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TCloseSessionResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: java.lang.ThreadLocal currentServerContext>;
v = virtualinvoke v.<java.lang.ThreadLocal: java.lang.Object get()>();
if v == null goto label;
virtualinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService$ThriftCLIServerContext: void clearSessionHandle()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Failed to close the session", v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TCloseSessionResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TGetInfoResp GetInfo(org.apache.hive.service.rpc.thrift.TGetInfoReq) throws org.apache.thrift.TException
{
org.apache.hive.service.cli.SessionHandle v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.rpc.thrift.TGetInfoValue v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.rpc.thrift.TGetInfoType v;
java.lang.Exception v;
org.apache.hive.service.cli.GetInfoType v;
org.apache.hive.service.rpc.thrift.TGetInfoResp v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
org.apache.hive.service.rpc.thrift.TGetInfoReq v;
org.apache.hive.service.cli.GetInfoValue v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TGetInfoReq;
v = new org.apache.hive.service.rpc.thrift.TGetInfoResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TGetInfoResp: void <init>()>();
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetInfoReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetInfoReq: org.apache.hive.service.rpc.thrift.TGetInfoType getInfoType()>();
v = staticinvoke <org.apache.hive.service.cli.GetInfoType: org.apache.hive.service.cli.GetInfoType getGetInfoType(org.apache.hive.service.rpc.thrift.TGetInfoType)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.GetInfoValue getInfo(org.apache.hive.service.cli.SessionHandle,org.apache.hive.service.cli.GetInfoType)>(v, v);
v = virtualinvoke v.<org.apache.hive.service.cli.GetInfoValue: org.apache.hive.service.rpc.thrift.TGetInfoValue toTGetInfoValue()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetInfoResp: void setInfoValue(org.apache.hive.service.rpc.thrift.TGetInfoValue)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetInfoResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Failed to get info", v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetInfoResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TExecuteStatementResp ExecuteStatement(org.apache.hive.service.rpc.thrift.TExecuteStatementReq) throws org.apache.thrift.TException
{
org.apache.hive.service.rpc.thrift.TOperationHandle v;
org.apache.hive.service.cli.HandleIdentifier v;
java.util.Map v;
boolean v, v, v, v;
org.apache.hive.service.cli.SessionHandle v;
org.apache.hive.service.cli.session.SessionManager v;
java.lang.Exception v;
org.apache.hive.service.cli.operation.OperationManager v;
java.lang.StringBuilder v;
org.apache.hive.service.rpc.thrift.TExecuteStatementReq v;
long v;
org.apache.hive.service.rpc.thrift.TExecuteStatementResp v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v;
org.apache.hive.service.rpc.thrift.TStatus v, v, v;
int v;
java.lang.Boolean v;
java.lang.String v, v, v, v, v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v, v, v;
org.apache.hadoop.hive.conf.HiveConf v, v;
org.apache.hive.service.rpc.thrift.TStatusCode v;
org.apache.hive.service.cli.OperationHandle v, v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TExecuteStatementReq;
v = new org.apache.hive.service.rpc.thrift.TExecuteStatementResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TExecuteStatementResp: void <init>()>();
label:
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TExecuteStatementReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TExecuteStatementReq: java.lang.String getStatement()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TExecuteStatementReq: java.util.Map getConfOverlay()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TExecuteStatementReq: boolean isRunAsync()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TExecuteStatementReq: long getQueryTimeout()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.OperationHandle executeStatementAsync(org.apache.hive.service.cli.SessionHandle,java.lang.String,java.util.Map,long)>(v, v, v, v);
goto label;
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.OperationHandle executeStatement(org.apache.hive.service.cli.SessionHandle,java.lang.String,java.util.Map,long)>(v, v, v, v);
label:
v = v;
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.rpc.thrift.TOperationHandle toTOperationHandle()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TExecuteStatementResp: void setOperationHandle(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.session.SessionManager getSessionManager()>();
v = virtualinvoke v.<org.apache.hive.service.cli.session.SessionManager: org.apache.hive.service.cli.operation.OperationManager getOperationManager()>();
v = virtualinvoke v.<org.apache.hive.service.cli.operation.OperationManager: boolean canShowDrilldownLink(org.apache.hive.service.cli.OperationHandle)>(v);
if v == 0 goto label;
specialinvoke v.<java.lang.StringBuilder: void <init>(java.lang.String)>("The url to track the statement: ");
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hadoop.hive.conf.HiveConf hiveConf>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_USE_SSL>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v == 0 goto label;
v = "https";
goto label;
label:
v = "http";
label:
v = virtualinvoke v.<org.apache.hive.service.cli.session.SessionManager: java.lang.String getHiveServer2HostName()>();
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hadoop.hive.conf.HiveConf hiveConf>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_WEBUI_PORT>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: int getIntVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.cli.HandleIdentifier getHandleIdentifier()>();
v = virtualinvoke v.<org.apache.hive.service.cli.HandleIdentifier: java.lang.String toString()>();
v = new org.apache.hive.service.rpc.thrift.TStatus;
v = <org.apache.hive.service.rpc.thrift.TStatusCode: org.apache.hive.service.rpc.thrift.TStatusCode SUCCESS_WITH_INFO_STATUS>;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TStatus: void <init>(org.apache.hive.service.rpc.thrift.TStatusCode)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,int,java.lang.String)>(v, v, v, 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[])>("\u0001://\u0001:\u0001/query_page.html?operationId=\u0001");
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TStatus: void addToInfoMessages(java.lang.String)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TExecuteStatementResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
goto label;
label:
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TExecuteStatementResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to execute statement [request: {}]", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TExecuteStatementResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TGetTypeInfoResp GetTypeInfo(org.apache.hive.service.rpc.thrift.TGetTypeInfoReq) throws org.apache.thrift.TException
{
org.apache.hive.service.cli.SessionHandle v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.rpc.thrift.TOperationHandle v;
java.lang.Exception v;
org.apache.hive.service.rpc.thrift.TGetTypeInfoReq v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
org.apache.hive.service.rpc.thrift.TGetTypeInfoResp v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TGetTypeInfoReq;
v = new org.apache.hive.service.rpc.thrift.TGetTypeInfoResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TGetTypeInfoResp: void <init>()>();
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetTypeInfoReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.OperationHandle getTypeInfo(org.apache.hive.service.cli.SessionHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.rpc.thrift.TOperationHandle toTOperationHandle()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetTypeInfoResp: void setOperationHandle(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetTypeInfoResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to get type info [request: {}]", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetTypeInfoResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TGetCatalogsResp GetCatalogs(org.apache.hive.service.rpc.thrift.TGetCatalogsReq) throws org.apache.thrift.TException
{
org.apache.hive.service.cli.SessionHandle v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.rpc.thrift.TGetCatalogsResp v;
org.apache.hive.service.rpc.thrift.TOperationHandle v;
java.lang.Exception v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
org.apache.hive.service.rpc.thrift.TGetCatalogsReq v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TGetCatalogsReq;
v = new org.apache.hive.service.rpc.thrift.TGetCatalogsResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TGetCatalogsResp: void <init>()>();
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetCatalogsReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.OperationHandle getCatalogs(org.apache.hive.service.cli.SessionHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.rpc.thrift.TOperationHandle toTOperationHandle()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetCatalogsResp: void setOperationHandle(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetCatalogsResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed getting catalogs [request: {}]", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetCatalogsResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TGetSchemasResp GetSchemas(org.apache.hive.service.rpc.thrift.TGetSchemasReq) throws org.apache.thrift.TException
{
org.apache.hive.service.cli.SessionHandle v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.rpc.thrift.TOperationHandle v;
java.lang.Exception v;
org.apache.hive.service.rpc.thrift.TGetSchemasReq v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
java.lang.String v, v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
org.apache.hive.service.rpc.thrift.TGetSchemasResp v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TGetSchemasReq;
v = new org.apache.hive.service.rpc.thrift.TGetSchemasResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TGetSchemasResp: void <init>()>();
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetSchemasReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetSchemasReq: java.lang.String getCatalogName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetSchemasReq: java.lang.String getSchemaName()>();
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.OperationHandle getSchemas(org.apache.hive.service.cli.SessionHandle,java.lang.String,java.lang.String)>(v, v, v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.rpc.thrift.TOperationHandle toTOperationHandle()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetSchemasResp: void setOperationHandle(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetSchemasResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to get schemas [request: {}]", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetSchemasResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TGetTablesResp GetTables(org.apache.hive.service.rpc.thrift.TGetTablesReq) throws org.apache.thrift.TException
{
org.apache.hive.service.rpc.thrift.TOperationHandle v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
org.apache.hive.service.rpc.thrift.TGetTablesResp v;
java.lang.String v, v, v;
org.apache.hive.service.cli.SessionHandle v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
java.lang.Exception v;
java.util.List v;
org.apache.hive.service.rpc.thrift.TGetTablesReq v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TGetTablesReq;
v = new org.apache.hive.service.rpc.thrift.TGetTablesResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TGetTablesResp: void <init>()>();
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetTablesReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetTablesReq: java.lang.String getCatalogName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetTablesReq: java.lang.String getSchemaName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetTablesReq: java.lang.String getTableName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetTablesReq: java.util.List getTableTypes()>();
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.OperationHandle getTables(org.apache.hive.service.cli.SessionHandle,java.lang.String,java.lang.String,java.lang.String,java.util.List)>(v, v, v, v, v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.rpc.thrift.TOperationHandle toTOperationHandle()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetTablesResp: void setOperationHandle(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetTablesResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to get tables [request: {}]", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetTablesResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TGetTableTypesResp GetTableTypes(org.apache.hive.service.rpc.thrift.TGetTableTypesReq) throws org.apache.thrift.TException
{
org.apache.hive.service.cli.SessionHandle v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.rpc.thrift.TOperationHandle v;
org.apache.hive.service.rpc.thrift.TGetTableTypesReq v;
java.lang.Exception v;
org.apache.hive.service.rpc.thrift.TGetTableTypesResp v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TGetTableTypesReq;
v = new org.apache.hive.service.rpc.thrift.TGetTableTypesResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TGetTableTypesResp: void <init>()>();
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetTableTypesReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.OperationHandle getTableTypes(org.apache.hive.service.cli.SessionHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.rpc.thrift.TOperationHandle toTOperationHandle()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetTableTypesResp: void setOperationHandle(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetTableTypesResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to get table types [request: {}]", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetTableTypesResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TGetColumnsResp GetColumns(org.apache.hive.service.rpc.thrift.TGetColumnsReq) throws org.apache.thrift.TException
{
org.apache.hive.service.rpc.thrift.TGetColumnsResp v;
org.apache.hive.service.rpc.thrift.TOperationHandle v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
java.lang.String v, v, v, v;
org.apache.hive.service.cli.SessionHandle v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.rpc.thrift.TGetColumnsReq v;
java.lang.Exception v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TGetColumnsReq;
v = new org.apache.hive.service.rpc.thrift.TGetColumnsResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TGetColumnsResp: void <init>()>();
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetColumnsReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetColumnsReq: java.lang.String getCatalogName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetColumnsReq: java.lang.String getSchemaName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetColumnsReq: java.lang.String getTableName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetColumnsReq: java.lang.String getColumnName()>();
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.OperationHandle getColumns(org.apache.hive.service.cli.SessionHandle,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.rpc.thrift.TOperationHandle toTOperationHandle()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetColumnsResp: void setOperationHandle(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetColumnsResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to get column types [request: {}]", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetColumnsResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TGetFunctionsResp GetFunctions(org.apache.hive.service.rpc.thrift.TGetFunctionsReq) throws org.apache.thrift.TException
{
org.apache.hive.service.cli.SessionHandle v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.rpc.thrift.TOperationHandle v;
java.lang.Exception v;
org.apache.hive.service.rpc.thrift.TGetFunctionsResp v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
org.apache.hive.service.rpc.thrift.TGetFunctionsReq v;
java.lang.String v, v, v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TGetFunctionsReq;
v = new org.apache.hive.service.rpc.thrift.TGetFunctionsResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TGetFunctionsResp: void <init>()>();
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetFunctionsReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetFunctionsReq: java.lang.String getCatalogName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetFunctionsReq: java.lang.String getSchemaName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetFunctionsReq: java.lang.String getFunctionName()>();
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.OperationHandle getFunctions(org.apache.hive.service.cli.SessionHandle,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.rpc.thrift.TOperationHandle toTOperationHandle()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetFunctionsResp: void setOperationHandle(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetFunctionsResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to get function: [request: {}]", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetFunctionsResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TGetOperationStatusResp GetOperationStatus(org.apache.hive.service.rpc.thrift.TGetOperationStatusReq) throws org.apache.thrift.TException
{
org.apache.hive.service.rpc.thrift.TOperationState v;
org.apache.hive.service.cli.OperationType v, v;
org.apache.hive.service.rpc.thrift.TOperationHandle v;
org.apache.hive.service.cli.TezProgressMonitorStatusMapper v;
boolean v, v, v, v, v, v;
org.apache.hive.service.rpc.thrift.TGetOperationStatusResp v;
java.lang.Exception v;
org.apache.hive.service.cli.JobProgressUpdate v;
java.util.List v, v;
org.apache.hive.service.rpc.thrift.TProgressUpdateResp v, v;
org.apache.hive.service.cli.OperationState v, v, v, v;
long v, v, v, v;
org.apache.hive.service.cli.OperationStatus v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
int v, v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.apache.hive.service.rpc.thrift.TGetOperationStatusReq v;
org.apache.hive.service.rpc.thrift.TJobExecutionStatus v, v;
double v, v;
org.apache.hive.service.cli.HiveSQLException v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v, v;
org.apache.hadoop.hive.conf.HiveConf v;
org.apache.hive.service.cli.ProgressMonitorStatusMapper v;
org.apache.hive.service.cli.OperationHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TGetOperationStatusReq;
v = new org.apache.hive.service.rpc.thrift.TGetOperationStatusResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusResp: void <init>()>();
v = new org.apache.hive.service.cli.OperationHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusReq: org.apache.hive.service.rpc.thrift.TOperationHandle getOperationHandle()>();
specialinvoke v.<org.apache.hive.service.cli.OperationHandle: void <init>(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusReq: boolean isGetProgressUpdate()>();
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.OperationStatus getOperationStatus(org.apache.hive.service.cli.OperationHandle,boolean)>(v, v);
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hadoop.hive.conf.HiveConf getHiveSessionConf(org.apache.hive.service.cli.OperationHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationStatus: org.apache.hive.service.cli.OperationState getState()>();
v = <org.apache.hive.service.cli.OperationState: org.apache.hive.service.cli.OperationState FINISHED>;
v = virtualinvoke v.<org.apache.hive.service.cli.OperationState: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.service.cli.OperationStatus: long getNumModifiedRows()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusResp: void setNumModifiedRows(long)>(v);
label:
v = virtualinvoke v.<org.apache.hive.service.cli.OperationStatus: org.apache.hive.service.cli.OperationState getState()>();
v = virtualinvoke v.<org.apache.hive.service.cli.OperationState: org.apache.hive.service.rpc.thrift.TOperationState toTOperationState()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusResp: void setOperationState(org.apache.hive.service.rpc.thrift.TOperationState)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationStatus: org.apache.hive.service.cli.OperationState getState()>();
v = virtualinvoke v.<org.apache.hive.service.cli.OperationState: java.lang.String getErrorMessage()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusResp: void setErrorMessage(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationStatus: org.apache.hive.service.cli.HiveSQLException getOperationException()>();
v = virtualinvoke v.<org.apache.hive.service.cli.OperationStatus: java.lang.String getTaskStatus()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusResp: void setTaskStatus(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationStatus: long getOperationStarted()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusResp: void setOperationStarted(long)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationStatus: long getOperationCompleted()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusResp: void setOperationCompleted(long)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationStatus: boolean isHasResultSetIsSet()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.service.cli.OperationStatus: boolean getHasResultSet()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusResp: void setHasResultSet(boolean)>(v);
label:
v = virtualinvoke v.<org.apache.hive.service.cli.OperationStatus: org.apache.hive.service.cli.JobProgressUpdate jobProgressUpdate()>();
v = <org.apache.hive.service.cli.ProgressMonitorStatusMapper: org.apache.hive.service.cli.ProgressMonitorStatusMapper DEFAULT>;
v = "tez";
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_EXECUTION_ENGINE>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = new org.apache.hive.service.cli.TezProgressMonitorStatusMapper;
specialinvoke v.<org.apache.hive.service.cli.TezProgressMonitorStatusMapper: void <init>()>();
v = v;
label:
v = v.<org.apache.hive.service.cli.JobProgressUpdate: java.lang.String status>;
v = interfaceinvoke v.<org.apache.hive.service.cli.ProgressMonitorStatusMapper: org.apache.hive.service.rpc.thrift.TJobExecutionStatus forStatus(java.lang.String)>(v);
v = new org.apache.hive.service.rpc.thrift.TProgressUpdateResp;
v = virtualinvoke v.<org.apache.hive.service.cli.JobProgressUpdate: java.util.List headers()>();
v = virtualinvoke v.<org.apache.hive.service.cli.JobProgressUpdate: java.util.List rows()>();
v = v.<org.apache.hive.service.cli.JobProgressUpdate: double progressedPercentage>;
v = v.<org.apache.hive.service.cli.JobProgressUpdate: java.lang.String footerSummary>;
v = v.<org.apache.hive.service.cli.JobProgressUpdate: long startTimeMillis>;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TProgressUpdateResp: void <init>(java.util.List,java.util.List,double,org.apache.hive.service.rpc.thrift.TJobExecutionStatus,java.lang.String,long)>(v, v, v, v, v, v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusResp: void setProgressUpdateResponse(org.apache.hive.service.rpc.thrift.TProgressUpdateResp)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.hive.service.cli.HiveSQLException: java.lang.String getSQLState()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusResp: void setSqlState(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.HiveSQLException: int getErrorCode()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusResp: void setErrorCode(int)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.HiveSQLException: int getErrorCode()>();
if v != 29999 goto label;
v = staticinvoke <org.apache.hadoop.util.StringUtils: java.lang.String stringifyException(java.lang.Throwable)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusResp: void setErrorMessage(java.lang.String)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.hive.service.cli.HiveSQLException: java.lang.String getMessage()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusResp: void setErrorMessage(java.lang.String)>(v);
goto label;
label:
v = <org.apache.hive.service.rpc.thrift.TJobExecutionStatus: org.apache.hive.service.rpc.thrift.TJobExecutionStatus NOT_AVAILABLE>;
if v != v goto label;
v = <org.apache.hive.service.cli.OperationType: org.apache.hive.service.cli.OperationType EXECUTE_STATEMENT>;
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.cli.OperationType getOperationType()>();
v = virtualinvoke v.<org.apache.hive.service.cli.OperationType: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusResp: org.apache.hive.service.rpc.thrift.TProgressUpdateResp getProgressUpdateResponse()>();
v = specialinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: double getProgressedPercentage(org.apache.hive.service.cli.OperationHandle)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TProgressUpdateResp: void setProgressedPercentage(double)>(v);
label:
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to get operation status [request: {}]", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetOperationStatusResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TCancelOperationResp CancelOperation(org.apache.hive.service.rpc.thrift.TCancelOperationReq) throws org.apache.thrift.TException
{
org.apache.hive.service.rpc.thrift.TCancelOperationResp v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.rpc.thrift.TOperationHandle v;
java.lang.Exception v;
org.apache.hive.service.rpc.thrift.TCancelOperationReq v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
org.apache.hive.service.cli.OperationHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TCancelOperationReq;
v = new org.apache.hive.service.rpc.thrift.TCancelOperationResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TCancelOperationResp: void <init>()>();
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = new org.apache.hive.service.cli.OperationHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TCancelOperationReq: org.apache.hive.service.rpc.thrift.TOperationHandle getOperationHandle()>();
specialinvoke v.<org.apache.hive.service.cli.OperationHandle: void <init>(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
virtualinvoke v.<org.apache.hive.service.cli.CLIService: void cancelOperation(org.apache.hive.service.cli.OperationHandle)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TCancelOperationResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to get cancel operation [request: {}]", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TCancelOperationResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TCloseOperationResp CloseOperation(org.apache.hive.service.rpc.thrift.TCloseOperationReq) throws org.apache.thrift.TException
{
org.apache.hive.service.rpc.thrift.TCloseOperationReq v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.rpc.thrift.TOperationHandle v;
org.apache.hive.service.rpc.thrift.TCloseOperationResp v;
java.lang.Exception v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
org.apache.hive.service.cli.OperationHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TCloseOperationReq;
v = new org.apache.hive.service.rpc.thrift.TCloseOperationResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TCloseOperationResp: void <init>()>();
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = new org.apache.hive.service.cli.OperationHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TCloseOperationReq: org.apache.hive.service.rpc.thrift.TOperationHandle getOperationHandle()>();
specialinvoke v.<org.apache.hive.service.cli.OperationHandle: void <init>(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
virtualinvoke v.<org.apache.hive.service.cli.CLIService: void closeOperation(org.apache.hive.service.cli.OperationHandle)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TCloseOperationResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to close operation [request: {}]", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TCloseOperationResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TGetResultSetMetadataResp GetResultSetMetadata(org.apache.hive.service.rpc.thrift.TGetResultSetMetadataReq) throws org.apache.thrift.TException
{
org.apache.hive.service.rpc.thrift.TGetResultSetMetadataReq v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.rpc.thrift.TGetResultSetMetadataResp v;
org.apache.hive.service.cli.TableSchema v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.rpc.thrift.TOperationHandle v;
org.apache.hive.service.rpc.thrift.TTableSchema v;
java.lang.Exception v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
org.apache.hive.service.cli.OperationHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TGetResultSetMetadataReq;
v = new org.apache.hive.service.rpc.thrift.TGetResultSetMetadataResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TGetResultSetMetadataResp: void <init>()>();
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = new org.apache.hive.service.cli.OperationHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetResultSetMetadataReq: org.apache.hive.service.rpc.thrift.TOperationHandle getOperationHandle()>();
specialinvoke v.<org.apache.hive.service.cli.OperationHandle: void <init>(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.TableSchema getResultSetMetadata(org.apache.hive.service.cli.OperationHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.TableSchema: org.apache.hive.service.rpc.thrift.TTableSchema toTTableSchema()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetResultSetMetadataResp: void setSchema(org.apache.hive.service.rpc.thrift.TTableSchema)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetResultSetMetadataResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to get result set metadata [request: {}]", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetResultSetMetadataResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TFetchResultsResp FetchResults(org.apache.hive.service.rpc.thrift.TFetchResultsReq) throws org.apache.thrift.TException
{
org.apache.hive.service.rpc.thrift.TFetchOrientation v;
org.apache.hive.service.cli.RowSet v;
org.apache.hive.service.rpc.thrift.TFetchResultsResp v;
org.apache.hive.service.rpc.thrift.TOperationHandle v;
long v, v, v;
org.apache.hive.service.rpc.thrift.TRowSet v;
org.apache.hive.service.cli.FetchType v;
java.lang.Integer v;
short v;
byte v;
org.apache.hive.service.cli.FetchOrientation v;
java.lang.Long v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
int v;
org.slf4j.Logger v, v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hadoop.hive.conf.HiveConf v;
java.lang.Exception v;
org.apache.hive.service.rpc.thrift.TFetchResultsReq v;
org.apache.hive.service.cli.OperationHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TFetchResultsReq;
v = new org.apache.hive.service.rpc.thrift.TFetchResultsResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TFetchResultsResp: void <init>()>();
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hadoop.hive.conf.HiveConf hiveConf>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_RESULTSET_MAX_FETCH_SIZE>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: int getIntVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TFetchResultsReq: long getMaxRows()>();
v = v cmp v;
if v <= 0 goto label;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TFetchResultsReq: long getMaxRows()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object,java.lang.Object)>("Fetch Size greater than maximum allowed. Capping fetch size. [req={}, max={}]", v, v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TFetchResultsReq: void setMaxRows(long)>(v);
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = new org.apache.hive.service.cli.OperationHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TFetchResultsReq: org.apache.hive.service.rpc.thrift.TOperationHandle getOperationHandle()>();
specialinvoke v.<org.apache.hive.service.cli.OperationHandle: void <init>(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TFetchResultsReq: org.apache.hive.service.rpc.thrift.TFetchOrientation getOrientation()>();
v = staticinvoke <org.apache.hive.service.cli.FetchOrientation: org.apache.hive.service.cli.FetchOrientation getFetchOrientation(org.apache.hive.service.rpc.thrift.TFetchOrientation)>(v);
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TFetchResultsReq: long getMaxRows()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TFetchResultsReq: short getFetchType()>();
v = staticinvoke <org.apache.hive.service.cli.FetchType: org.apache.hive.service.cli.FetchType getFetchType(short)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.RowSet fetchResults(org.apache.hive.service.cli.OperationHandle,org.apache.hive.service.cli.FetchOrientation,long,org.apache.hive.service.cli.FetchType)>(v, v, v, v);
v = interfaceinvoke v.<org.apache.hive.service.cli.RowSet: org.apache.hive.service.rpc.thrift.TRowSet toTRowSet()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TFetchResultsResp: void setResults(org.apache.hive.service.rpc.thrift.TRowSet)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TFetchResultsResp: void setHasMoreRows(boolean)>(0);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TFetchResultsResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed fetch results [request: {}]", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TFetchResultsResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TGetPrimaryKeysResp GetPrimaryKeys(org.apache.hive.service.rpc.thrift.TGetPrimaryKeysReq) throws org.apache.thrift.TException
{
org.apache.hive.service.cli.SessionHandle v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.rpc.thrift.TOperationHandle v;
org.apache.hive.service.rpc.thrift.TGetPrimaryKeysReq v;
java.lang.Exception v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
org.apache.hive.service.rpc.thrift.TGetPrimaryKeysResp v;
java.lang.String v, v, v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TGetPrimaryKeysReq;
v = new org.apache.hive.service.rpc.thrift.TGetPrimaryKeysResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TGetPrimaryKeysResp: void <init>()>();
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetPrimaryKeysReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetPrimaryKeysReq: java.lang.String getCatalogName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetPrimaryKeysReq: java.lang.String getSchemaName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetPrimaryKeysReq: java.lang.String getTableName()>();
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.OperationHandle getPrimaryKeys(org.apache.hive.service.cli.SessionHandle,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.rpc.thrift.TOperationHandle toTOperationHandle()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetPrimaryKeysResp: void setOperationHandle(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetPrimaryKeysResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to get primary keys [request: {}]", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetPrimaryKeysResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TGetCrossReferenceResp GetCrossReference(org.apache.hive.service.rpc.thrift.TGetCrossReferenceReq) throws org.apache.thrift.TException
{
org.apache.hive.service.rpc.thrift.TOperationHandle v;
org.apache.hive.service.rpc.thrift.TGetCrossReferenceReq v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
java.lang.String v, v, v, v, v, v;
org.apache.hive.service.cli.SessionHandle v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
java.lang.Exception v;
org.apache.hive.service.rpc.thrift.TGetCrossReferenceResp v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TGetCrossReferenceReq;
v = new org.apache.hive.service.rpc.thrift.TGetCrossReferenceResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TGetCrossReferenceResp: void <init>()>();
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetCrossReferenceReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetCrossReferenceReq: java.lang.String getParentCatalogName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetCrossReferenceReq: java.lang.String getParentSchemaName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetCrossReferenceReq: java.lang.String getParentTableName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetCrossReferenceReq: java.lang.String getForeignCatalogName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetCrossReferenceReq: java.lang.String getForeignSchemaName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetCrossReferenceReq: java.lang.String getForeignTableName()>();
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.OperationHandle getCrossReference(org.apache.hive.service.cli.SessionHandle,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v, v, v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.rpc.thrift.TOperationHandle toTOperationHandle()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetCrossReferenceResp: void setOperationHandle(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetCrossReferenceResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to get cross reference [request: {}]", v, v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetCrossReferenceResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TGetQueryIdResp GetQueryId(org.apache.hive.service.rpc.thrift.TGetQueryIdReq) throws org.apache.thrift.TException
{
org.apache.hive.service.cli.HiveSQLException v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.rpc.thrift.TOperationHandle v;
org.apache.thrift.TException v;
java.lang.Exception v;
org.apache.hive.service.rpc.thrift.TGetQueryIdResp v, v;
java.lang.String v;
org.apache.hive.service.rpc.thrift.TGetQueryIdReq v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TGetQueryIdReq;
label:
v = new org.apache.hive.service.rpc.thrift.TGetQueryIdResp;
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TGetQueryIdReq: org.apache.hive.service.rpc.thrift.TOperationHandle getOperationHandle()>();
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: java.lang.String getQueryId(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
specialinvoke v.<org.apache.hive.service.rpc.thrift.TGetQueryIdResp: void <init>(java.lang.String)>(v);
label:
return v;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to get query ID [request: {}]", v, v);
v = new org.apache.thrift.TException;
specialinvoke v.<org.apache.thrift.TException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v := @caughtexception;
v = new org.apache.hive.service.rpc.thrift.TGetQueryIdResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TGetQueryIdResp: void <init>(java.lang.String)>("");
return v;
catch org.apache.hive.service.cli.HiveSQLException from label to label with label;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TUploadDataResp UploadData(org.apache.hive.service.rpc.thrift.TUploadDataReq) throws org.apache.thrift.TException
{
org.apache.hive.service.cli.SessionHandle v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.rpc.thrift.TOperationHandle v;
org.apache.hive.service.rpc.thrift.TUploadDataReq v;
java.lang.Exception v;
java.nio.ByteBuffer v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
java.lang.String v, v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
org.apache.hive.service.rpc.thrift.TUploadDataResp v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TUploadDataReq;
v = new org.apache.hive.service.rpc.thrift.TUploadDataResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TUploadDataResp: void <init>()>();
label:
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TUploadDataReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TUploadDataReq: java.nio.ByteBuffer bufferForValues()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TUploadDataReq: java.lang.String getTableName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TUploadDataReq: java.lang.String getPath()>();
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.OperationHandle uploadData(org.apache.hive.service.cli.SessionHandle,java.nio.ByteBuffer,java.lang.String,java.lang.String)>(v, v, v, v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.rpc.thrift.TOperationHandle toTOperationHandle()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TUploadDataResp: void setOperationHandle(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TUploadDataResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Error UploadData: ", v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TUploadDataResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.rpc.thrift.TDownloadDataResp DownloadData(org.apache.hive.service.rpc.thrift.TDownloadDataReq) throws org.apache.thrift.TException
{
org.apache.hive.service.rpc.thrift.TOperationHandle v;
org.apache.hive.service.rpc.thrift.TDownloadDataResp v;
org.apache.hive.service.rpc.thrift.TStatus v, v;
java.util.Map v;
java.lang.String v, v, v;
org.apache.hive.service.cli.SessionHandle v;
org.slf4j.Logger v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hive.service.cli.CLIService v;
org.apache.hive.service.rpc.thrift.TDownloadDataReq v;
java.lang.Exception v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.rpc.thrift.TSessionHandle v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: org.apache.hive.service.rpc.thrift.TDownloadDataReq;
v = new org.apache.hive.service.rpc.thrift.TDownloadDataResp;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TDownloadDataResp: void <init>()>();
label:
v = new org.apache.hive.service.cli.SessionHandle;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TDownloadDataReq: org.apache.hive.service.rpc.thrift.TSessionHandle getSessionHandle()>();
specialinvoke v.<org.apache.hive.service.cli.SessionHandle: void <init>(org.apache.hive.service.rpc.thrift.TSessionHandle)>(v);
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.cli.CLIService cliService>;
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TDownloadDataReq: java.lang.String getTableName()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TDownloadDataReq: java.lang.String getQuery()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TDownloadDataReq: java.lang.String getFormat()>();
v = virtualinvoke v.<org.apache.hive.service.rpc.thrift.TDownloadDataReq: java.util.Map getDownloadOptions()>();
v = virtualinvoke v.<org.apache.hive.service.cli.CLIService: org.apache.hive.service.cli.OperationHandle downloadData(org.apache.hive.service.cli.SessionHandle,java.lang.String,java.lang.String,java.lang.String,java.util.Map)>(v, v, v, v, v);
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.rpc.thrift.TOperationHandle toTOperationHandle()>();
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TDownloadDataResp: void setOperationHandle(org.apache.hive.service.rpc.thrift.TOperationHandle)>(v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS>;
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TDownloadDataResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Error download data: ", v);
v = staticinvoke <org.apache.hive.service.cli.HiveSQLException: org.apache.hive.service.rpc.thrift.TStatus toTStatus(java.lang.Exception)>(v);
virtualinvoke v.<org.apache.hive.service.rpc.thrift.TDownloadDataResp: void setStatus(org.apache.hive.service.rpc.thrift.TStatus)>(v);
label:
return v;
catch java.lang.Exception from label to label with label;
}
public abstract void run();
protected abstract org.apache.hadoop.hive.conf.HiveServer2TransportMode getTransportMode();
private java.lang.String getProxyUser(java.lang.String, java.util.Map, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.auth.HiveAuthConstants$AuthTypes v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v;
java.util.Map v;
java.lang.String v, v, v, v, v;
org.apache.hadoop.hive.conf.HiveServer2TransportMode v, v;
boolean v, v, v;
org.apache.hive.service.cli.HiveSQLException v;
org.slf4j.Logger v, v, v;
org.apache.hive.service.cli.thrift.ThriftCLIService v;
org.apache.hadoop.hive.conf.HiveConf v, v, v;
java.lang.Object v;
v := @this: org.apache.hive.service.cli.thrift.ThriftCLIService;
v := @parameter: java.lang.String;
v := @parameter: java.util.Map;
v := @parameter: java.lang.String;
v = null;
v = virtualinvoke v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hadoop.hive.conf.HiveServer2TransportMode getTransportMode()>();
v = <org.apache.hadoop.hive.conf.HiveServer2TransportMode: org.apache.hadoop.hive.conf.HiveServer2TransportMode http>;
if v != v goto label;
v = staticinvoke <org.apache.hive.service.cli.session.SessionManager: java.lang.String getProxyUserName()>();
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Proxy user from query string: {}", v);
label:
if v != null goto label;
if v == null goto label;
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("hive.server.proxy.user");
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("hive.server.proxy.user");
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Proxy user from thrift body: {}", v);
v = v;
label:
if v != null goto label;
return v;
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hadoop.hive.conf.HiveConf hiveConf>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_ALLOW_USER_SUBSTITUTION>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
if v != 0 goto label;
v = new org.apache.hive.service.cli.HiveSQLException;
specialinvoke v.<org.apache.hive.service.cli.HiveSQLException: void <init>(java.lang.String)>("Proxy user substitution is not allowed");
throw v;
label:
v = <org.apache.hive.service.auth.HiveAuthConstants$AuthTypes: org.apache.hive.service.auth.HiveAuthConstants$AuthTypes NONE>;
v = virtualinvoke v.<org.apache.hive.service.auth.HiveAuthConstants$AuthTypes: java.lang.String toString()>();
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hadoop.hive.conf.HiveConf hiveConf>;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_AUTHENTICATION>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: java.lang.String getVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
return v;
label:
v = v.<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hadoop.hive.conf.HiveConf hiveConf>;
staticinvoke <org.apache.hive.service.auth.HiveAuthFactory: void verifyProxyAccess(java.lang.String,java.lang.String,java.lang.String,org.apache.hadoop.hive.conf.HiveConf)>(v, v, v, v);
v = <org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Verified proxy user: {}", v);
return v;
}
static void <clinit>()
{
org.apache.hive.service.rpc.thrift.TStatusCode v;
org.slf4j.Logger v;
org.apache.hive.service.rpc.thrift.TStatus v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/hive/service/cli/thrift/ThriftCLIService;");
<org.apache.hive.service.cli.thrift.ThriftCLIService: org.slf4j.Logger LOG> = v;
v = new org.apache.hive.service.rpc.thrift.TStatus;
v = <org.apache.hive.service.rpc.thrift.TStatusCode: org.apache.hive.service.rpc.thrift.TStatusCode SUCCESS_STATUS>;
specialinvoke v.<org.apache.hive.service.rpc.thrift.TStatus: void <init>(org.apache.hive.service.rpc.thrift.TStatusCode)>(v);
<org.apache.hive.service.cli.thrift.ThriftCLIService: org.apache.hive.service.rpc.thrift.TStatus OK_STATUS> = v;
return;
}
}