public class org.apache.hive.service.cli.session.HiveSessionImpl extends java.lang.Object implements org.apache.hive.service.cli.session.HiveSession { private final org.apache.hive.service.cli.SessionHandle sessionHandle; private java.lang.String username; private final java.lang.String password; private final org.apache.hadoop.hive.conf.HiveConf sessionConf; private final long creationTime; private org.apache.hadoop.hive.ql.session.SessionState sessionState; private java.lang.String ipAddress; private java.util.List forwardedAddresses; private static final java.lang.String FETCH_WORK_SERDE_CLASS; private static final org.slf4j.Logger LOG; private org.apache.hive.service.cli.session.SessionManager sessionManager; private org.apache.hive.service.cli.operation.OperationManager operationManager; private final java.util.Set opHandleSet; private boolean isOperationLogEnabled; private java.io.File sessionLogDir; private org.apache.hadoop.hive.ql.metadata.Hive sessionHive; private volatile long lastAccessTime; private volatile boolean lockedByUser; private final java.util.concurrent.Semaphore operationLock; private static final java.util.Set ODBC_KEYWORDS; public void (org.apache.hive.service.cli.SessionHandle, org.apache.hive.service.rpc.thrift.TProtocolVersion, java.lang.String, java.lang.String, org.apache.hadoop.hive.conf.HiveConf, java.lang.String, java.util.List) { long v, v; org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v; org.apache.hive.service.cli.HandleIdentifier v; int v; java.lang.String v, v, v, v, v, v; boolean v; org.apache.hive.service.rpc.thrift.TProtocolVersion v; org.apache.hive.service.cli.SessionHandle v, v, v; org.apache.hive.service.cli.session.HiveSessionImpl v; java.util.concurrent.Semaphore v; org.apache.hadoop.hive.conf.HiveConf v, v, v, v, v; java.util.List v; java.util.concurrent.ConcurrentHashMap$KeySetView v; java.lang.Class v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: org.apache.hive.service.cli.SessionHandle; v := @parameter: org.apache.hive.service.rpc.thrift.TProtocolVersion; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: org.apache.hadoop.hive.conf.HiveConf; v := @parameter: java.lang.String; v := @parameter: java.util.List; specialinvoke v.()>(); v = staticinvoke (); v. = v; v = staticinvoke (); v. = v; v. = v; v. = v; v = staticinvoke (); v. = v; if v == null goto label; v = v; goto label; label: v = new org.apache.hive.service.cli.SessionHandle; specialinvoke v.(org.apache.hive.service.rpc.thrift.TProtocolVersion)>(v); label: v. = v; v = new org.apache.hadoop.hive.conf.HiveConf; specialinvoke v.(org.apache.hadoop.hive.conf.HiveConf)>(v); v. = v; v. = v; v. = v; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = null; goto label; label: v = new java.util.concurrent.Semaphore; specialinvoke v.(int)>(1); label: v. = v; v = v.; v = ; v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v); v = v.; v = class "Lorg/apache/hadoop/hive/serde2/thrift/ThriftFormatter;"; v = virtualinvoke v.(); virtualinvoke v.("list.sink.output.formatter", v); v = v.; v = virtualinvoke v.(); virtualinvoke v.("list.sink.output.protocol", v); return; } public void open(java.util.Map) throws org.apache.hive.service.cli.HiveSQLException { java.util.Map v; org.apache.hadoop.hive.ql.cleanup.CleanupService v; boolean v; org.apache.hive.service.cli.session.SessionManager v, v, v, v, v, v; org.apache.hadoop.hive.ql.session.SessionState v, v, v, v, v, v, v, v, v, v, v; java.lang.Exception v; org.apache.hive.service.cli.operation.OperationManager v; java.util.List v; org.apache.hive.service.server.KillQueryImpl v; long v; org.apache.hive.service.server.KillQueryZookeeperManager v; java.lang.String v, v, v, v, v; org.apache.hive.service.cli.HiveSQLException v, v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.slf4j.Logger v; org.apache.hadoop.hive.conf.HiveConf v, v; java.io.IOException v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.util.Map; v = v.; if v == null goto label; v = new org.apache.hadoop.hive.ql.session.SessionState; v = v.; v = v.; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.hadoop.hive.conf.HiveConf,java.lang.String,org.apache.hadoop.hive.ql.cleanup.CleanupService)>(v, v, v); v. = v; goto label; label: v = new org.apache.hadoop.hive.ql.session.SessionState; v = v.; v = v.; specialinvoke v.(org.apache.hadoop.hive.conf.HiveConf,java.lang.String)>(v, v); v. = v; label: v = v.; v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(1); v = v.; v = staticinvoke (); virtualinvoke v.(v); v = v.; v = specialinvoke v.(); virtualinvoke v.(v); label: v = v.; if v == null goto label; v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = new org.apache.hive.service.cli.HiveSQLException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = null; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); label: v = v.; v = new org.apache.hive.service.server.KillQueryImpl; v = v.; specialinvoke v.(org.apache.hive.service.cli.operation.OperationManager,org.apache.hive.service.server.KillQueryZookeeperManager)>(v, v); virtualinvoke v.(v); v = v.; staticinvoke (v); label: v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to load reloadable jar file path: \u0001"); v = ; interfaceinvoke v.(v, v); v = new org.apache.hive.service.cli.HiveSQLException; specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: specialinvoke v.(); specialinvoke v.(); if v == null goto label; specialinvoke v.(v); label: v = staticinvoke (); v. = v; return; catch java.lang.Exception from label to label with label; catch java.io.IOException from label to label with label; } private void setSessionHive() throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hadoop.hive.ql.metadata.Hive v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.slf4j.Logger v; java.lang.String v; org.apache.hadoop.hive.ql.session.SessionState v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; label: v = v.; v = virtualinvoke v.(); v. = v; label: goto label; label: v := @caughtexception; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to create Hive Object: \u0001"); v = ; interfaceinvoke v.(v, v); v = new org.apache.hive.service.cli.HiveSQLException; specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: return; catch org.apache.hadoop.hive.ql.metadata.HiveException from label to label with label; } private void processGlobalInitFile() { org.apache.hadoop.hive.conf.HiveConf$ConfVars v; int v; java.lang.String v, v, v, v; boolean v, v; org.apache.hive.service.cli.session.HiveSessionImpl$GlobalHivercFileProcessor v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.slf4j.Logger v, v, v, v; org.apache.hadoop.hive.conf.HiveConf v; java.io.IOException v; java.io.File v, v, v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = new org.apache.hive.service.cli.session.HiveSessionImpl$GlobalHivercFileProcessor; specialinvoke v.(org.apache.hive.service.cli.session.HiveSessionImpl)>(v); label: v = v.; v = ; v = virtualinvoke v.(v); if v == null goto label; v = new java.io.File; specialinvoke v.(java.lang.String)>(v); v = v; v = virtualinvoke v.(); if v == 0 goto label; v = new java.io.File; specialinvoke v.(java.io.File,java.lang.String)>(v, ".hiverc"); v = v; label: v = virtualinvoke v.(); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Running global init file: \u0001"); interfaceinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == 0 goto label; v = ; interfaceinvoke v.("Failed on initializing global .hiverc file"); goto label; label: v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Global init file \u does not exist"); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed on initializing global .hiverc file", v); label: return; catch java.io.IOException from label to label with label; } private void configureSession(java.util.Map) throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; java.util.Map v; java.lang.String v, v; boolean v, v, v, v; org.apache.hive.service.cli.HiveSQLException v, v, v; org.apache.hadoop.hive.ql.metadata.Hive v; org.apache.hive.service.cli.session.HiveSessionImpl v; java.util.Iterator v; org.apache.hadoop.hive.conf.HiveConf v; java.util.Set v; org.apache.hadoop.hive.ql.session.SessionState v, v; java.lang.Exception v; java.lang.Object v, v, v, v, v, v, v, v; org.apache.hadoop.hive.metastore.api.Database v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.util.Map; v = v.; staticinvoke (v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.("set:"); if v == 0 goto label; label: v = virtualinvoke v.(4); v = interfaceinvoke v.(); staticinvoke (v, v); label: goto label; label: v := @caughtexception; v = new org.apache.hive.service.cli.HiveSQLException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = virtualinvoke v.("use:"); if v == 0 goto label; label: v = interfaceinvoke v.(); v = staticinvoke ("default", v); if v != 0 goto label; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v != null goto label; v = new org.apache.hive.service.cli.HiveSQLException; v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Database \u does not exist"); specialinvoke v.(java.lang.String)>(v); throw v; label: v := @caughtexception; v = new org.apache.hive.service.cli.HiveSQLException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = staticinvoke (); v = interfaceinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; v = interfaceinvoke v.(); virtualinvoke v.(v, v); goto label; label: return; catch java.lang.Exception from label to label with label; catch org.apache.hadoop.hive.ql.metadata.HiveException from label to label with label; } private boolean updateIsUsingThriftJDBCBinarySerDe() { org.apache.hive.service.rpc.thrift.TProtocolVersion v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hadoop.hive.conf.HiveConf$ConfVars v; int v; org.apache.hadoop.hive.conf.HiveConf v; boolean v, v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = virtualinvoke v.(); v = virtualinvoke v.(); if 8 > v goto label; v = v.; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public void setOperationLogSessionDir(java.io.File) { org.apache.hive.service.cli.HandleIdentifier v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; boolean v, v, v, v, v, v; org.apache.hive.service.cli.SessionHandle v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.slf4j.Logger v, v, v, v, v; java.io.File v, v, v, v, v, v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.io.File; v = virtualinvoke v.(); if v != 0 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("The operation log root directory is removed, recreating:\u0001"); interfaceinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Unable to create operation log root directory: \u0001"); interfaceinvoke v.(v); label: v = virtualinvoke v.(); if v != 0 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("The operation log root directory is not writable: \u0001"); interfaceinvoke v.(v); label: v = new java.io.File; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.io.File,java.lang.String)>(v, v); v. = v; v. = 1; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = ; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Unable to create operation log session directory: \u0001"); interfaceinvoke v.(v); v. = 0; label: v = v.; if v == 0 goto label; v = ; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Operation log session directory is created: \u0001"); interfaceinvoke v.(v); label: return; } public boolean isOperationLogEnabled() { org.apache.hive.service.cli.session.HiveSessionImpl v; boolean v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; return v; } public java.io.File getOperationLogSessionDir() { org.apache.hive.service.cli.session.HiveSessionImpl v; java.io.File v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; return v; } public org.apache.hive.service.rpc.thrift.TProtocolVersion getProtocolVersion() { org.apache.hive.service.rpc.thrift.TProtocolVersion v; org.apache.hive.service.cli.SessionHandle v; org.apache.hive.service.cli.session.HiveSessionImpl v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; v = virtualinvoke v.(); return v; } public org.apache.hive.service.cli.session.SessionManager getSessionManager() { org.apache.hive.service.cli.session.SessionManager v; org.apache.hive.service.cli.session.HiveSessionImpl v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; return v; } public void setSessionManager(org.apache.hive.service.cli.session.SessionManager) { org.apache.hive.service.cli.session.SessionManager v; org.apache.hive.service.cli.session.HiveSessionImpl v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: org.apache.hive.service.cli.session.SessionManager; v. = v; return; } private org.apache.hive.service.cli.operation.OperationManager getOperationManager() { org.apache.hive.service.cli.operation.OperationManager v; org.apache.hive.service.cli.session.HiveSessionImpl v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; return v; } public void setOperationManager(org.apache.hive.service.cli.operation.OperationManager) { org.apache.hive.service.cli.operation.OperationManager v; org.apache.hive.service.cli.session.HiveSessionImpl v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: org.apache.hive.service.cli.operation.OperationManager; v. = v; return; } protected void acquire(boolean, boolean) { java.lang.Throwable v; org.apache.hive.service.cli.session.HiveSessionImpl v; java.util.concurrent.Semaphore v, v, v, v; java.lang.RuntimeException v; java.lang.InterruptedException v; java.lang.Thread v; boolean v, v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: boolean; v := @parameter: boolean; if v == 0 goto label; v = v.; if v == null goto label; label: v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = staticinvoke (); virtualinvoke v.(); v = new java.lang.RuntimeException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: specialinvoke v.(v); label: goto label; label: v := @caughtexception; if v == 0 goto label; v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: throw v; label: return; catch java.lang.InterruptedException from label to label with label; catch java.lang.Throwable from label to label with label; } private synchronized void acquireAfterOpLock(boolean) { org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.session.HiveSessionImpl v; long v; java.lang.RuntimeException v; org.apache.hadoop.hive.ql.session.SessionState v, v, v, v; java.util.List v; boolean v, v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: boolean; v = v.; staticinvoke (v); v = v.; v = staticinvoke (); virtualinvoke v.(v); v = v.; v = specialinvoke v.(); virtualinvoke v.(v); if v == 0 goto label; v = staticinvoke (); v. = v; v. = 1; label: v = v.; virtualinvoke v.(); label: specialinvoke v.(); label: goto label; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: return; catch org.apache.hive.service.cli.HiveSQLException from label to label with label; } protected void release(boolean, boolean) { java.lang.Throwable v; org.apache.hive.service.cli.session.HiveSessionImpl v; java.util.concurrent.Semaphore v, v, v, v; boolean v, v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: boolean; v := @parameter: boolean; label: specialinvoke v.(v); label: if v == 0 goto label; v = v.; if v == null goto label; v = v.; virtualinvoke v.(); goto label; label: v := @caughtexception; if v == 0 goto label; v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: throw v; label: return; catch java.lang.Throwable from label to label with label; } private synchronized void releaseBeforeOpLock(boolean) { org.apache.hive.service.cli.session.HiveSessionImpl v; long v; org.apache.hadoop.hive.ql.session.SessionState v, v; java.lang.Thread v, v; boolean v, v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: boolean; v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: staticinvoke (); v = staticinvoke (); v = v instanceof org.apache.hive.service.server.ThreadWithGarbageCleanup; if v == 0 goto label; v = staticinvoke (); virtualinvoke v.(); label: if v == 0 goto label; v = staticinvoke (); v. = v; v. = 0; label: return; } public org.apache.hive.service.cli.SessionHandle getSessionHandle() { org.apache.hive.service.cli.SessionHandle v; org.apache.hive.service.cli.session.HiveSessionImpl v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; return v; } public java.lang.String getPassword() { org.apache.hive.service.cli.session.HiveSessionImpl v; java.lang.String v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; return v; } public org.apache.hadoop.hive.conf.HiveConf getHiveConf() { org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hadoop.hive.conf.HiveConf$ConfVars v; org.apache.hadoop.hive.conf.HiveConf v, v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; v = ; virtualinvoke v.(v, "org.apache.hadoop.hive.serde.lazy.LazySimpleSerDe"); v = v.; return v; } public org.apache.hadoop.hive.ql.metadata.Hive getSessionHive() { org.apache.hadoop.hive.ql.metadata.Hive v; org.apache.hive.service.cli.session.HiveSessionImpl v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; return v; } public org.apache.hadoop.hive.metastore.IMetaStoreClient getMetaStoreClient() throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hadoop.hive.ql.metadata.Hive v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hadoop.hive.metastore.IMetaStoreClient v; java.lang.String v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; label: v = virtualinvoke v.(); v = virtualinvoke v.(); label: return v; label: v := @caughtexception; v = new org.apache.hive.service.cli.HiveSQLException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to get metastore connection: \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; catch org.apache.hadoop.hive.metastore.api.MetaException from label to label with label; } public org.apache.hive.service.cli.GetInfoValue getInfo(org.apache.hive.service.cli.GetInfoType) throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; int[] v; org.apache.hive.service.cli.GetInfoType v; int v, v; java.lang.String v, v, v, v; org.apache.hive.service.cli.GetInfoValue v, v, v, v, v, v, v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.session.HiveSessionImpl v; java.util.Set v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: org.apache.hive.service.cli.GetInfoType; virtualinvoke v.(1, 1); label: v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; case 6: goto label; case 7: goto label; case 8: goto label; default: goto label; }; label: v = new org.apache.hive.service.cli.GetInfoValue; specialinvoke v.(java.lang.String)>("Hive"); label: virtualinvoke v.(1, 1); return v; label: v = new org.apache.hive.service.cli.GetInfoValue; specialinvoke v.(java.lang.String)>("Apache Hive"); label: virtualinvoke v.(1, 1); return v; label: v = new org.apache.hive.service.cli.GetInfoValue; v = staticinvoke (); specialinvoke v.(java.lang.String)>(v); label: virtualinvoke v.(1, 1); return v; label: v = new org.apache.hive.service.cli.GetInfoValue; specialinvoke v.(int)>(128); label: virtualinvoke v.(1, 1); return v; label: v = new org.apache.hive.service.cli.GetInfoValue; specialinvoke v.(int)>(128); label: virtualinvoke v.(1, 1); return v; label: v = new org.apache.hive.service.cli.GetInfoValue; specialinvoke v.(int)>(128); label: virtualinvoke v.(1, 1); return v; label: v = new org.apache.hive.service.cli.GetInfoValue; v = ; v = staticinvoke (v); specialinvoke v.(java.lang.String)>(v); label: virtualinvoke v.(1, 1); return v; label: v = new org.apache.hive.service.cli.HiveSQLException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Unrecognized GetInfoType value: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v := @caughtexception; virtualinvoke v.(1, 1); throw v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public org.apache.hadoop.hive.conf.HiveConf getSessionConf() throws org.apache.hive.service.cli.HiveSQLException { org.apache.hadoop.hive.conf.HiveConf v; org.apache.hive.service.cli.session.HiveSessionImpl v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; return v; } public org.apache.hive.service.cli.OperationHandle executeStatement(java.lang.String, java.util.Map) throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.cli.session.HiveSessionImpl v; java.util.Map v; java.lang.String v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.lang.String; v := @parameter: java.util.Map; v = specialinvoke v.(v, v, 0, 0L); return v; } public org.apache.hive.service.cli.OperationHandle executeStatement(java.lang.String, java.util.Map, long) throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.cli.session.HiveSessionImpl v; java.util.Map v; long v; java.lang.String v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.lang.String; v := @parameter: java.util.Map; v := @parameter: long; v = specialinvoke v.(v, v, 0, v); return v; } public org.apache.hive.service.cli.OperationHandle executeStatementAsync(java.lang.String, java.util.Map) throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.cli.session.HiveSessionImpl v; java.util.Map v; java.lang.String v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.lang.String; v := @parameter: java.util.Map; v = specialinvoke v.(v, v, 1, 0L); return v; } public org.apache.hive.service.cli.OperationHandle executeStatementAsync(java.lang.String, java.util.Map, long) throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.cli.session.HiveSessionImpl v; java.util.Map v; long v; java.lang.String v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.lang.String; v := @parameter: java.util.Map; v := @parameter: long; v = specialinvoke v.(v, v, 1, v); return v; } private org.apache.hive.service.cli.OperationHandle executeStatementInternal(java.lang.String, java.util.Map, boolean, long) throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; long v; java.util.concurrent.Future v, v; java.util.Map v; java.lang.String v, v; boolean v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.slf4j.Logger v; org.apache.hive.service.cli.session.HiveSession v; org.apache.hive.service.cli.operation.OperationManager v, v; org.apache.hive.service.cli.operation.ExecuteStatementOperation v; org.apache.hive.service.cli.OperationHandle v, v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.lang.String; v := @parameter: java.util.Map; v := @parameter: boolean; v := @parameter: long; virtualinvoke v.(1, 1); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("executing \u0001"); interfaceinvoke v.(v); v = null; v = null; label: v = specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v, v, v, v); v = virtualinvoke v.(); specialinvoke v.(v); virtualinvoke v.(); v = v; label: v = virtualinvoke v.(); if v != null goto label; virtualinvoke v.(1, 1); goto label; label: specialinvoke v.(1); label: return v; label: v := @caughtexception; if v == null goto label; specialinvoke v.(v); v = specialinvoke v.(); virtualinvoke v.(v); label: throw v; label: v := @caughtexception; if v == null goto label; v = virtualinvoke v.(); if v != null goto label; label: virtualinvoke v.(1, 1); goto label; label: specialinvoke v.(1); label: throw v; catch org.apache.hive.service.cli.HiveSQLException from label to label with label; catch java.lang.Throwable from label to label with label; } public java.util.concurrent.Future submitBackgroundOperation(java.lang.Runnable) { org.apache.hive.service.cli.session.SessionManager v; java.util.concurrent.Future v; org.apache.hive.service.cli.session.HiveSessionImpl v; java.util.concurrent.Semaphore v; org.apache.hive.service.cli.session.HiveSessionImpl$1 v; java.lang.Runnable v, v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.lang.Runnable; v = virtualinvoke v.(); v = v.; if v != null goto label; v = v; goto label; label: v = new org.apache.hive.service.cli.session.HiveSessionImpl$1; v = v; specialinvoke v.(org.apache.hive.service.cli.session.HiveSessionImpl,java.lang.Runnable,java.lang.Void)>(v, v, null); label: v = virtualinvoke v.(v); return v; } public org.apache.hive.service.cli.OperationHandle getTypeInfo() throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.operation.OperationManager v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hive.service.cli.OperationHandle v; org.apache.hive.service.cli.operation.GetTypeInfoOperation v; org.apache.hive.service.cli.session.HiveSession v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; virtualinvoke v.(1, 1); v = specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); label: specialinvoke v.(v); virtualinvoke v.(); label: virtualinvoke v.(1, 1); return v; label: v := @caughtexception; specialinvoke v.(v); virtualinvoke v.(v); throw v; label: v := @caughtexception; virtualinvoke v.(1, 1); throw v; catch org.apache.hive.service.cli.HiveSQLException from label to label with label; catch java.lang.Throwable from label to label with label; } public org.apache.hive.service.cli.OperationHandle getCatalogs() throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.operation.OperationManager v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hive.service.cli.operation.GetCatalogsOperation v; org.apache.hive.service.cli.OperationHandle v; org.apache.hive.service.cli.session.HiveSession v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; virtualinvoke v.(1, 1); v = specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); label: specialinvoke v.(v); virtualinvoke v.(); label: virtualinvoke v.(1, 1); return v; label: v := @caughtexception; specialinvoke v.(v); virtualinvoke v.(v); throw v; label: v := @caughtexception; virtualinvoke v.(1, 1); throw v; catch org.apache.hive.service.cli.HiveSQLException from label to label with label; catch java.lang.Throwable from label to label with label; } public org.apache.hive.service.cli.OperationHandle getSchemas(java.lang.String, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.operation.GetSchemasOperation v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hive.service.cli.session.HiveSession v; org.apache.hive.service.cli.operation.OperationManager v; java.lang.String v, v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.lang.String; v := @parameter: java.lang.String; virtualinvoke v.(1, 1); v = specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v, v); v = virtualinvoke v.(); label: specialinvoke v.(v); virtualinvoke v.(); label: virtualinvoke v.(1, 1); return v; label: v := @caughtexception; specialinvoke v.(v); virtualinvoke v.(v); throw v; label: v := @caughtexception; virtualinvoke v.(1, 1); throw v; catch org.apache.hive.service.cli.HiveSQLException from label to label with label; catch java.lang.Throwable from label to label with label; } public org.apache.hive.service.cli.OperationHandle getTables(java.lang.String, java.lang.String, java.lang.String, java.util.List) throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hive.service.cli.operation.MetadataOperation v; org.apache.hive.service.cli.session.HiveSession v; org.apache.hive.service.cli.operation.OperationManager v; java.util.List v; java.lang.String v, v, v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.util.List; virtualinvoke v.(1, 1); v = specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v, v, v, v); v = virtualinvoke v.(); label: specialinvoke v.(v); virtualinvoke v.(); label: virtualinvoke v.(1, 1); return v; label: v := @caughtexception; specialinvoke v.(v); virtualinvoke v.(v); throw v; label: v := @caughtexception; virtualinvoke v.(1, 1); throw v; catch org.apache.hive.service.cli.HiveSQLException from label to label with label; catch java.lang.Throwable from label to label with label; } public org.apache.hive.service.cli.OperationHandle getTableTypes() throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.operation.OperationManager v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hive.service.cli.OperationHandle v; org.apache.hive.service.cli.operation.GetTableTypesOperation v; org.apache.hive.service.cli.session.HiveSession v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; virtualinvoke v.(1, 1); v = specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); label: specialinvoke v.(v); virtualinvoke v.(); label: virtualinvoke v.(1, 1); return v; label: v := @caughtexception; specialinvoke v.(v); virtualinvoke v.(v); throw v; label: v := @caughtexception; virtualinvoke v.(1, 1); throw v; catch org.apache.hive.service.cli.HiveSQLException from label to label with label; catch java.lang.Throwable from label to label with label; } public org.apache.hive.service.cli.OperationHandle getColumns(java.lang.String, java.lang.String, java.lang.String, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hadoop.hive.ql.session.SessionState$ResourceType v; org.apache.hive.service.cli.operation.GetColumnsOperation v; java.lang.String v, v, v, v, v; boolean v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hadoop.hive.conf.HiveConf v; org.apache.hive.service.cli.session.HiveSession v, v; org.apache.hive.service.cli.operation.OperationManager v; org.apache.hadoop.hive.metastore.IMetaStoreClient v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; virtualinvoke v.(1, 1); v = v.; v = ; v = staticinvoke (v, v); v = staticinvoke (v); if v == 0 goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(); interfaceinvoke v.(v); label: v = specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v, v, v, v); v = virtualinvoke v.(); label: specialinvoke v.(v); virtualinvoke v.(); label: virtualinvoke v.(1, 1); return v; label: v := @caughtexception; specialinvoke v.(v); virtualinvoke v.(v); throw v; label: v := @caughtexception; virtualinvoke v.(1, 1); throw v; catch org.apache.hive.service.cli.HiveSQLException from label to label with label; catch java.lang.Throwable from label to label with label; } private void addOpHandle(org.apache.hive.service.cli.OperationHandle) { java.util.Set v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: org.apache.hive.service.cli.OperationHandle; v = v.; interfaceinvoke v.(v); return; } private void removeOpHandle(org.apache.hive.service.cli.OperationHandle) { java.util.Set v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: org.apache.hive.service.cli.OperationHandle; v = v.; interfaceinvoke v.(v); return; } public org.apache.hive.service.cli.OperationHandle getFunctions(java.lang.String, java.lang.String, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hive.service.cli.operation.GetFunctionsOperation v; org.apache.hive.service.cli.session.HiveSession v; org.apache.hive.service.cli.operation.OperationManager v; java.lang.String v, v, v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; virtualinvoke v.(1, 1); v = specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v, v, v); v = virtualinvoke v.(); label: specialinvoke v.(v); virtualinvoke v.(); label: virtualinvoke v.(1, 1); return v; label: v := @caughtexception; specialinvoke v.(v); virtualinvoke v.(v); throw v; label: v := @caughtexception; virtualinvoke v.(1, 1); throw v; catch org.apache.hive.service.cli.HiveSQLException from label to label with label; catch java.lang.Throwable from label to label with label; } public void close() throws org.apache.hive.service.cli.HiveSQLException { boolean v; java.util.Set v, v; org.apache.hadoop.hive.ql.session.SessionState v, v, v, v, v, v, v, v, v; org.apache.hive.service.cli.operation.OperationManager v; org.apache.hadoop.hive.ql.history.HiveHistory v; java.lang.Throwable v, v, v, v, v, v, v, v; java.util.ArrayList v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hadoop.hive.ql.metadata.Hive v, v, v, v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.slf4j.Logger v, v, v, v, v, v; java.util.Iterator v; java.io.IOException v; java.lang.Object v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; label: virtualinvoke v.(1, 0); v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; virtualinvoke v.(v); interfaceinvoke v.(v); goto label; label: v = v.; interfaceinvoke v.(v); specialinvoke v.(); v = v.; v = virtualinvoke v.(); if null == v goto label; interfaceinvoke v.(); label: v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); label: v. = null; goto label; label: v := @caughtexception; v. = null; throw v; label: v = v.; if v == null goto label; label: v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Error closing session", v); label: v. = null; label: v = v.; if v == null goto label; label: v = v.; virtualinvoke v.(1); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Error closing sessionHive", v); label: v. = null; label: staticinvoke (); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Error closing thread local Hive", v); label: virtualinvoke v.(1, 0); goto label; label: v := @caughtexception; v = new org.apache.hive.service.cli.HiveSQLException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Failure to close", v); throw v; label: v := @caughtexception; v = v.; if v == null goto label; label: v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Error closing session", v); label: v. = null; label: v = v.; if v == null goto label; label: v = v.; virtualinvoke v.(1); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Error closing sessionHive", v); label: v. = null; label: staticinvoke (); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Error closing thread local Hive", v); label: virtualinvoke v.(1, 0); throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.io.IOException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private void cleanupSessionLogDir() { org.apache.hive.service.cli.SessionHandle v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.slf4j.Logger v, v; org.apache.hadoop.hive.conf.HiveConf v; java.io.File v, v; java.lang.Exception v; org.apache.hadoop.hive.conf.HiveConf$ConfVars v; java.lang.String v, v, v; boolean v, v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; if v == 0 goto label; v = v.; v = ; v = virtualinvoke v.(v); if v == 0 goto label; label: v = v.; staticinvoke (v); v = ; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Operation log session directory is deleted: \u0001"); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to cleanup session log dir: \u0001"); interfaceinvoke v.(v, v); label: return; catch java.lang.Exception from label to label with label; } public org.apache.hadoop.hive.ql.session.SessionState getSessionState() { org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hadoop.hive.ql.session.SessionState v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; return v; } public java.lang.String getUserName() { org.apache.hive.service.cli.session.HiveSessionImpl v; java.lang.String v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; return v; } public void setUserName(java.lang.String) { org.apache.hive.service.cli.session.HiveSessionImpl v; java.lang.String v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.lang.String; v. = v; return; } public long getLastAccessTime() { long v; org.apache.hive.service.cli.session.HiveSessionImpl v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; return v; } public long getCreationTime() { long v; org.apache.hive.service.cli.session.HiveSessionImpl v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; return v; } public void closeExpiredOperations() { org.apache.hive.service.cli.session.HiveSessionImpl v; java.lang.Object[] v; java.util.Set v; org.apache.hive.service.cli.OperationHandle[] v; java.util.ArrayList v; org.apache.hive.service.cli.operation.OperationManager v; java.util.List v; boolean v, v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = new java.util.ArrayList; v = v.; specialinvoke v.(java.util.Collection)>(v); v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = newarray (org.apache.hive.service.cli.OperationHandle)[0]; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = interfaceinvoke v.(); if v != 0 goto label; specialinvoke v.(v); label: return; } public long getNoOperationTime() { org.apache.hive.service.cli.session.HiveSessionImpl v; java.util.Set v; long v, v, v; boolean v, v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; if v != 0 goto label; v = staticinvoke (); v = v.; v = v - v; goto label; label: v = 0L; label: return v; } private void closeTimedOutOperations(java.util.List) { java.lang.Throwable v; java.util.List v; org.apache.hive.service.cli.session.HiveSessionImpl v; java.util.Iterator v; java.lang.Object v; org.apache.hive.service.cli.OperationHandle v; boolean v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.util.List; virtualinvoke v.(0, 0); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(v); goto label; label: virtualinvoke v.(0, 0); goto label; label: v := @caughtexception; virtualinvoke v.(0, 0); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void cancelOperation(org.apache.hive.service.cli.OperationHandle) throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.operation.OperationManager v; org.apache.hive.service.cli.session.SessionManager v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: org.apache.hive.service.cli.OperationHandle; virtualinvoke v.(1, 0); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: virtualinvoke v.(1, 0); goto label; label: v := @caughtexception; virtualinvoke v.(1, 0); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void updateQueryTag(java.lang.String, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.cli.operation.OperationManager v; org.apache.hive.service.cli.session.SessionManager v; org.apache.hive.service.cli.session.HiveSessionImpl v; java.lang.String v, v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v); return; } public void closeOperation(org.apache.hive.service.cli.OperationHandle) throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.operation.OperationManager v; org.apache.hive.service.cli.session.HiveSessionImpl v; java.util.Set v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: org.apache.hive.service.cli.OperationHandle; virtualinvoke v.(1, 0); label: v = v.; virtualinvoke v.(v); v = v.; interfaceinvoke v.(v); label: virtualinvoke v.(1, 0); goto label; label: v := @caughtexception; virtualinvoke v.(1, 0); throw v; label: return; catch java.lang.Throwable from label to label with label; } public org.apache.hive.service.cli.TableSchema getResultSetMetadata(org.apache.hive.service.cli.OperationHandle) throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.operation.OperationManager v; org.apache.hive.service.cli.session.SessionManager v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hive.service.cli.TableSchema v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: org.apache.hive.service.cli.OperationHandle; virtualinvoke v.(1, 1); label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); label: virtualinvoke v.(1, 1); return v; label: v := @caughtexception; virtualinvoke v.(1, 1); throw v; catch java.lang.Throwable from label to label with label; } public 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) throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hive.service.cli.RowSet v, v; org.apache.hadoop.hive.conf.HiveConf v; long v; org.apache.hive.service.cli.FetchType v, v; org.apache.hive.service.cli.operation.OperationManager v, v; org.apache.hive.service.cli.FetchOrientation v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: org.apache.hive.service.cli.OperationHandle; v := @parameter: org.apache.hive.service.cli.FetchOrientation; v := @parameter: long; v := @parameter: org.apache.hive.service.cli.FetchType; virtualinvoke v.(1, 0); label: v = ; if v != v goto label; v = v.; v = virtualinvoke v.(v, v, v); label: virtualinvoke v.(1, 0); return v; label: v = v.; v = v.; v = virtualinvoke v.(v, v, v, v); label: virtualinvoke v.(1, 0); return v; label: v := @caughtexception; virtualinvoke v.(1, 0); throw v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } protected org.apache.hive.service.cli.session.HiveSession getSession() { org.apache.hive.service.cli.session.HiveSessionImpl v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; return v; } public int getOpenOperationCount() { int v; java.util.Set v; org.apache.hive.service.cli.session.HiveSessionImpl v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; v = interfaceinvoke v.(); return v; } public java.lang.String getIpAddress() { org.apache.hive.service.cli.session.HiveSessionImpl v; java.lang.String v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; return v; } public void setIpAddress(java.lang.String) { org.apache.hive.service.cli.session.HiveSessionImpl v; java.lang.String v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.lang.String; v. = v; return; } public java.util.List getForwardedAddresses() { java.util.List v; org.apache.hive.service.cli.session.HiveSessionImpl v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v = v.; return v; } public void setForwardedAddresses(java.util.List) { java.util.List v; org.apache.hive.service.cli.session.HiveSessionImpl v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.util.List; v. = v; return; } public java.lang.String getDelegationToken(org.apache.hive.service.auth.HiveAuthFactory, java.lang.String, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hadoop.hive.conf.HiveConf v; org.apache.hive.service.auth.HiveAuthFactory v; java.lang.String v, v, v, v, v, v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: org.apache.hive.service.auth.HiveAuthFactory; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v, v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(v, v, v); return v; } public void cancelDelegationToken(org.apache.hive.service.auth.HiveAuthFactory, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hadoop.hive.conf.HiveConf v; java.lang.String v, v, v, v; org.apache.hive.service.auth.HiveAuthFactory v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: org.apache.hive.service.auth.HiveAuthFactory; v := @parameter: java.lang.String; v = virtualinvoke v.(); v = specialinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v, v, v, v); virtualinvoke v.(v); return; } public void renewDelegationToken(org.apache.hive.service.auth.HiveAuthFactory, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hadoop.hive.conf.HiveConf v; java.lang.String v, v, v, v; org.apache.hive.service.auth.HiveAuthFactory v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: org.apache.hive.service.auth.HiveAuthFactory; v := @parameter: java.lang.String; v = virtualinvoke v.(); v = specialinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke (v, v, v, v); virtualinvoke v.(v); return; } private java.lang.String getUserFromToken(org.apache.hive.service.auth.HiveAuthFactory, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException { org.apache.hive.service.cli.session.HiveSessionImpl v; java.lang.String v, v; org.apache.hive.service.auth.HiveAuthFactory v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: org.apache.hive.service.auth.HiveAuthFactory; v := @parameter: java.lang.String; v = virtualinvoke v.(v); return v; } public org.apache.hive.service.cli.OperationHandle getPrimaryKeys(java.lang.String, java.lang.String, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hive.service.cli.session.HiveSession v; org.apache.hive.service.cli.operation.OperationManager v; java.lang.String v, v, v; org.apache.hive.service.cli.OperationHandle v; org.apache.hive.service.cli.operation.GetPrimaryKeysOperation v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; virtualinvoke v.(1, 1); v = specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v, v, v); v = virtualinvoke v.(); label: specialinvoke v.(v); virtualinvoke v.(); label: virtualinvoke v.(1, 1); return v; label: v := @caughtexception; specialinvoke v.(v); virtualinvoke v.(v); throw v; label: v := @caughtexception; virtualinvoke v.(1, 1); throw v; catch org.apache.hive.service.cli.HiveSQLException from label to label with label; catch java.lang.Throwable from label to label with label; } public org.apache.hive.service.cli.OperationHandle getCrossReference(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.operation.GetCrossReferenceOperation v; org.apache.hive.service.cli.session.HiveSessionImpl v; org.apache.hive.service.cli.session.HiveSession v; org.apache.hive.service.cli.operation.OperationManager v; java.lang.String v, v, v, v, v, v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; virtualinvoke v.(1, 1); v = specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v, v, v, v, v, v); v = virtualinvoke v.(); label: specialinvoke v.(v); virtualinvoke v.(); label: virtualinvoke v.(1, 1); return v; label: v := @caughtexception; specialinvoke v.(v); virtualinvoke v.(v); throw v; label: v := @caughtexception; virtualinvoke v.(1, 1); throw v; catch org.apache.hive.service.cli.HiveSQLException from label to label with label; catch java.lang.Throwable from label to label with label; } public void setApplicationName(java.lang.String) { org.apache.hive.service.cli.session.HiveSessionImpl v; org.slf4j.Logger v; org.apache.hadoop.hive.ql.session.SessionState v; java.util.Map v; java.lang.Object v; java.lang.String v, v; boolean v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.lang.String; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.("wmapp", v); if v == null goto label; v = virtualinvoke v.(v); if v != 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("ApplicationName changed from \u to \u0001"); interfaceinvoke v.(v); label: return; } public org.apache.hive.service.cli.OperationHandle uploadData(java.nio.ByteBuffer, java.lang.String, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.session.HiveSessionImpl v; java.util.Set v; org.apache.hive.service.cli.operation.Operation v; java.nio.ByteBuffer v; org.apache.hive.service.cli.session.HiveSession v; org.apache.hive.service.cli.operation.OperationManager v; java.lang.String v, v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.nio.ByteBuffer; v := @parameter: java.lang.String; v := @parameter: java.lang.String; virtualinvoke v.(1, 1); v = specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v, v, v); v = virtualinvoke v.(); label: virtualinvoke v.(); v = v.; interfaceinvoke v.(v); label: virtualinvoke v.(1, 1); return v; label: v := @caughtexception; virtualinvoke v.(v); throw v; label: v := @caughtexception; virtualinvoke v.(1, 1); throw v; catch org.apache.hive.service.cli.HiveSQLException from label to label with label; catch java.lang.Throwable from label to label with label; } public org.apache.hive.service.cli.OperationHandle downloadData(java.lang.String, java.lang.String, java.lang.String, java.util.Map) throws org.apache.hive.service.cli.HiveSQLException { java.lang.Throwable v; org.apache.hive.service.cli.HiveSQLException v; org.apache.hive.service.cli.session.HiveSessionImpl v; java.util.Set 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; java.util.Map v; java.lang.String v, v, v; org.apache.hive.service.cli.OperationHandle v; v := @this: org.apache.hive.service.cli.session.HiveSessionImpl; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.util.Map; virtualinvoke v.(1, 1); v = specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v, v, v, v); v = virtualinvoke v.(); label: virtualinvoke v.(); v = v.; interfaceinvoke v.(v); label: virtualinvoke v.(1, 1); return v; label: v := @caughtexception; virtualinvoke v.(v); throw v; label: v := @caughtexception; virtualinvoke v.(1, 1); throw v; catch org.apache.hive.service.cli.HiveSQLException from label to label with label; catch java.lang.Throwable from label to label with label; } static void () { java.util.HashSet v; org.slf4j.Logger v; java.util.Set v; java.lang.String[] v; java.util.ArrayList v; v = staticinvoke (class "Lorg/apache/hive/service/cli/session/HiveSessionImpl;"); = v; v = new java.util.HashSet; v = newarray (java.lang.String)[234]; v[0] = "ABSOLUTE"; v[1] = "ACTION"; v[2] = "ADA"; v[3] = "ADD"; v[4] = "ALL"; v[5] = "ALLOCATE"; v[6] = "ALTER"; v[7] = "AND"; v[8] = "ANY"; v[9] = "ARE"; v[10] = "AS"; v[11] = "ASC"; v[12] = "ASSERTION"; v[13] = "AT"; v[14] = "AUTHORIZATION"; v[15] = "AVG"; v[16] = "BEGIN"; v[17] = "BETWEEN"; v[18] = "BIT_LENGTH"; v[19] = "BIT"; v[20] = "BOTH"; v[21] = "BY"; v[22] = "CASCADE"; v[23] = "CASCADED"; v[24] = "CASE"; v[25] = "CAST"; v[26] = "CATALOG"; v[27] = "CHAR_LENGTH"; v[28] = "CHAR"; v[29] = "CHARACTER_LENGTH"; v[30] = "CHARACTER"; v[31] = "CHECK"; v[32] = "CLOSE"; v[33] = "COALESCE"; v[34] = "COLLATE"; v[35] = "COLLATION"; v[36] = "COLUMN"; v[37] = "COMMIT"; v[38] = "CONNECT"; v[39] = "CONNECTION"; v[40] = "CONSTRAINT"; v[41] = "CONSTRAINTS"; v[42] = "CONTINUE"; v[43] = "CONVERT"; v[44] = "CORRESPONDING"; v[45] = "COUNT"; v[46] = "CREATE"; v[47] = "CROSS"; v[48] = "CURRENT_DATE"; v[49] = "CURRENT_TIME"; v[50] = "CURRENT_TIMESTAMP"; v[51] = "CURRENT_USER"; v[52] = "CURRENT"; v[53] = "CURSOR"; v[54] = "DATE"; v[55] = "DAY"; v[56] = "DEALLOCATE"; v[57] = "DEC"; v[58] = "DECIMAL"; v[59] = "DECLARE"; v[60] = "DEFAULT"; v[61] = "DEFERRABLE"; v[62] = "DEFERRED"; v[63] = "DELETE"; v[64] = "DESC"; v[65] = "DESCRIBE"; v[66] = "DESCRIPTOR"; v[67] = "DIAGNOSTICS"; v[68] = "DISCONNECT"; v[69] = "DISTINCT"; v[70] = "DOMAIN"; v[71] = "DOUBLE"; v[72] = "DROP"; v[73] = "ELSE"; v[74] = "END"; v[75] = "ESCAPE"; v[76] = "EXCEPT"; v[77] = "EXCEPTION"; v[78] = "EXEC"; v[79] = "EXECUTE"; v[80] = "EXISTS"; v[81] = "EXTERNAL"; v[82] = "EXTRACT"; v[83] = "FALSE"; v[84] = "FETCH"; v[85] = "FIRST"; v[86] = "FLOAT"; v[87] = "FOR"; v[88] = "FOREIGN"; v[89] = "FORTRAN"; v[90] = "FOUND"; v[91] = "FROM"; v[92] = "FULL"; v[93] = "GET"; v[94] = "GLOBAL"; v[95] = "GO"; v[96] = "GOTO"; v[97] = "GRANT"; v[98] = "GROUP"; v[99] = "HAVING"; v[100] = "HOUR"; v[101] = "IDENTITY"; v[102] = "IMMEDIATE"; v[103] = "IN"; v[104] = "INCLUDE"; v[105] = "INDEX"; v[106] = "INDICATOR"; v[107] = "INITIALLY"; v[108] = "INNER"; v[109] = "INPUT"; v[110] = "INSENSITIVE"; v[111] = "INSERT"; v[112] = "INT"; v[113] = "INTEGER"; v[114] = "INTERSECT"; v[115] = "INTERVAL"; v[116] = "INTO"; v[117] = "IS"; v[118] = "ISOLATION"; v[119] = "JOIN"; v[120] = "KEY"; v[121] = "LANGUAGE"; v[122] = "LAST"; v[123] = "LEADING"; v[124] = "LEFT"; v[125] = "LEVEL"; v[126] = "LIKE"; v[127] = "LOCAL"; v[128] = "LOWER"; v[129] = "MATCH"; v[130] = "MAX"; v[131] = "MIN"; v[132] = "MINUTE"; v[133] = "MODULE"; v[134] = "MONTH"; v[135] = "NAMES"; v[136] = "NATIONAL"; v[137] = "NATURAL"; v[138] = "NCHAR"; v[139] = "NEXT"; v[140] = "NO"; v[141] = "NONE"; v[142] = "NOT"; v[143] = "NULL"; v[144] = "NULLIF"; v[145] = "NUMERIC"; v[146] = "OCTET_LENGTH"; v[147] = "OF"; v[148] = "ON"; v[149] = "ONLY"; v[150] = "OPEN"; v[151] = "OPTION"; v[152] = "OR"; v[153] = "ORDER"; v[154] = "OUTER"; v[155] = "OUTPUT"; v[156] = "OVERLAPS"; v[157] = "PAD"; v[158] = "PARTIAL"; v[159] = "PASCAL"; v[160] = "POSITION"; v[161] = "PRECISION"; v[162] = "PREPARE"; v[163] = "PRESERVE"; v[164] = "PRIMARY"; v[165] = "PRIOR"; v[166] = "PRIVILEGES"; v[167] = "PROCEDURE"; v[168] = "PUBLIC"; v[169] = "READ"; v[170] = "REAL"; v[171] = "REFERENCES"; v[172] = "RELATIVE"; v[173] = "RESTRICT"; v[174] = "REVOKE"; v[175] = "RIGHT"; v[176] = "ROLLBACK"; v[177] = "ROWS"; v[178] = "SCHEMA"; v[179] = "SCROLL"; v[180] = "SECOND"; v[181] = "SECTION"; v[182] = "SELECT"; v[183] = "SESSION_USER"; v[184] = "SESSION"; v[185] = "SET"; v[186] = "SIZE"; v[187] = "SMALLINT"; v[188] = "SOME"; v[189] = "SPACE"; v[190] = "SQL"; v[191] = "SQLCA"; v[192] = "SQLCODE"; v[193] = "SQLERROR"; v[194] = "SQLSTATE"; v[195] = "SQLWARNING"; v[196] = "SUBSTRING"; v[197] = "SUM"; v[198] = "SYSTEM_USER"; v[199] = "TABLE"; v[200] = "TEMPORARY"; v[201] = "THEN"; v[202] = "TIME"; v[203] = "TIMESTAMP"; v[204] = "TIMEZONE_HOUR"; v[205] = "TIMEZONE_MINUTE"; v[206] = "TO"; v[207] = "TRAILING"; v[208] = "TRANSACTION"; v[209] = "TRANSLATE"; v[210] = "TRANSLATION"; v[211] = "TRIM"; v[212] = "TRUE"; v[213] = "UNION"; v[214] = "UNIQUE"; v[215] = "UNKNOWN"; v[216] = "UPDATE"; v[217] = "UPPER"; v[218] = "USAGE"; v[219] = "USER"; v[220] = "USING"; v[221] = "VALUE"; v[222] = "VALUES"; v[223] = "VARCHAR"; v[224] = "VARYING"; v[225] = "VIEW"; v[226] = "WHEN"; v[227] = "WHENEVER"; v[228] = "WHERE"; v[229] = "WITH"; v[230] = "WORK"; v[231] = "WRITE"; v[232] = "YEAR"; v[233] = "ZONE"; v = staticinvoke (v); specialinvoke v.(java.util.Collection)>(v); v = staticinvoke (v); = v; return; } }