public class org.apache.hive.service.cli.operation.OperationManager extends org.apache.hive.service.AbstractService
{
private final org.slf4j.Logger LOG;
private final java.util.concurrent.ConcurrentHashMap handleToOperation;
private final java.util.concurrent.ConcurrentHashMap queryIdOperation;
private final com.google.common.collect.SetMultimap queryTagToIdMap;
private java.util.Optional queryInfoCache;
public void <init>()
{
org.slf4j.Logger v;
com.google.common.collect.MultimapBuilder$MultimapBuilderWithKeys v;
java.util.concurrent.ConcurrentHashMap v, v;
com.google.common.collect.SetMultimap v, v;
org.apache.hive.service.cli.operation.OperationManager v;
java.util.Optional v;
java.lang.Class v, v;
java.lang.String v, v;
com.google.common.collect.MultimapBuilder$SetMultimapBuilder v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v = class "Lorg/apache/hive/service/cli/operation/OperationManager;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
specialinvoke v.<org.apache.hive.service.AbstractService: void <init>(java.lang.String)>(v);
v = class "Lorg/apache/hive/service/cli/operation/OperationManager;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.String)>(v);
v.<org.apache.hive.service.cli.operation.OperationManager: org.slf4j.Logger LOG> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<org.apache.hive.service.cli.operation.OperationManager: java.util.concurrent.ConcurrentHashMap handleToOperation> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<org.apache.hive.service.cli.operation.OperationManager: java.util.concurrent.ConcurrentHashMap queryIdOperation> = v;
v = staticinvoke <com.google.common.collect.MultimapBuilder: com.google.common.collect.MultimapBuilder$MultimapBuilderWithKeys hashKeys()>();
v = virtualinvoke v.<com.google.common.collect.MultimapBuilder$MultimapBuilderWithKeys: com.google.common.collect.MultimapBuilder$SetMultimapBuilder hashSetValues()>();
v = virtualinvoke v.<com.google.common.collect.MultimapBuilder$SetMultimapBuilder: com.google.common.collect.SetMultimap build()>();
v = staticinvoke <com.google.common.collect.Multimaps: com.google.common.collect.SetMultimap synchronizedSetMultimap(com.google.common.collect.SetMultimap)>(v);
v.<org.apache.hive.service.cli.operation.OperationManager: com.google.common.collect.SetMultimap queryTagToIdMap> = v;
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
v.<org.apache.hive.service.cli.operation.OperationManager: java.util.Optional queryInfoCache> = v;
return;
}
public synchronized void init(org.apache.hadoop.hive.conf.HiveConf)
{
org.apache.hive.service.cli.operation.OperationManager v;
org.apache.hadoop.hive.conf.HiveConf v;
java.util.Optional v;
boolean v;
org.apache.hive.service.cli.operation.QueryInfoCache v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf;
staticinvoke <org.apache.hadoop.hive.ql.log.LogDivertAppender: void registerRoutingAppender(org.apache.hadoop.conf.Configuration)>(v);
staticinvoke <org.apache.hadoop.hive.ql.log.LogDivertAppenderForTest: void registerRoutingAppenderIfInTest(org.apache.hadoop.conf.Configuration)>(v);
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean isWebUiEnabled()>();
if v == 0 goto label;
v = new org.apache.hive.service.cli.operation.QueryInfoCache;
specialinvoke v.<org.apache.hive.service.cli.operation.QueryInfoCache: void <init>(org.apache.hadoop.hive.conf.HiveConf)>(v);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
v.<org.apache.hive.service.cli.operation.OperationManager: java.util.Optional queryInfoCache> = v;
label:
specialinvoke v.<org.apache.hive.service.AbstractService: void init(org.apache.hadoop.hive.conf.HiveConf)>(v);
return;
}
public synchronized void start()
{
org.apache.hive.service.cli.operation.OperationManager v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
specialinvoke v.<org.apache.hive.service.AbstractService: void start()>();
return;
}
public synchronized void stop()
{
org.slf4j.Logger v;
java.util.Iterator v;
java.util.Collection v;
java.lang.Exception v;
org.apache.hive.service.cli.operation.OperationManager v;
java.lang.Object v;
org.apache.hive.service.cli.OperationHandle v;
boolean v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
specialinvoke v.<org.apache.hive.service.AbstractService: void stop()>();
v = virtualinvoke v.<org.apache.hive.service.cli.operation.OperationManager: java.util.Collection getOperations()>();
v = interfaceinvoke v.<java.util.Collection: 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()>();
label:
v = virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationHandle getHandle()>();
virtualinvoke v.<org.apache.hive.service.cli.operation.OperationManager: void cancelOperation(org.apache.hive.service.cli.OperationHandle,java.lang.String)>(v, "Operation canceled due to HiveServer stop");
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.hive.service.cli.operation.OperationManager: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Error canceling the operation", v);
goto label;
label:
return;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.cli.operation.ExecuteStatementOperation newExecuteStatementOperation(org.apache.hive.service.cli.session.HiveSession, java.lang.String, java.util.Map, boolean, long) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.operation.OperationManager v;
java.util.Map v;
org.apache.hive.service.cli.operation.ExecuteStatementOperation v;
long v;
java.lang.String v;
boolean v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.session.HiveSession;
v := @parameter: java.lang.String;
v := @parameter: java.util.Map;
v := @parameter: boolean;
v := @parameter: long;
v = staticinvoke <org.apache.hive.service.cli.operation.ExecuteStatementOperation: org.apache.hive.service.cli.operation.ExecuteStatementOperation newExecuteStatementOperation(org.apache.hive.service.cli.session.HiveSession,java.lang.String,java.util.Map,boolean,long)>(v, v, v, v, v);
specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: void addOperation(org.apache.hive.service.cli.operation.Operation)>(v);
return v;
}
public org.apache.hive.service.cli.operation.GetTypeInfoOperation newGetTypeInfoOperation(org.apache.hive.service.cli.session.HiveSession) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.operation.OperationManager v;
org.apache.hive.service.cli.operation.GetTypeInfoOperation v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.session.HiveSession;
v = new org.apache.hive.service.cli.operation.GetTypeInfoOperation;
specialinvoke v.<org.apache.hive.service.cli.operation.GetTypeInfoOperation: void <init>(org.apache.hive.service.cli.session.HiveSession)>(v);
specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: void addOperation(org.apache.hive.service.cli.operation.Operation)>(v);
return v;
}
public org.apache.hive.service.cli.operation.GetCatalogsOperation newGetCatalogsOperation(org.apache.hive.service.cli.session.HiveSession) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.operation.OperationManager v;
org.apache.hive.service.cli.operation.GetCatalogsOperation v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.session.HiveSession;
v = new org.apache.hive.service.cli.operation.GetCatalogsOperation;
specialinvoke v.<org.apache.hive.service.cli.operation.GetCatalogsOperation: void <init>(org.apache.hive.service.cli.session.HiveSession)>(v);
specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: void addOperation(org.apache.hive.service.cli.operation.Operation)>(v);
return v;
}
public org.apache.hive.service.cli.operation.GetSchemasOperation newGetSchemasOperation(org.apache.hive.service.cli.session.HiveSession, java.lang.String, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.operation.GetSchemasOperation v;
org.apache.hive.service.cli.operation.OperationManager v;
java.lang.String v, v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.session.HiveSession;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = new org.apache.hive.service.cli.operation.GetSchemasOperation;
specialinvoke v.<org.apache.hive.service.cli.operation.GetSchemasOperation: void <init>(org.apache.hive.service.cli.session.HiveSession,java.lang.String,java.lang.String)>(v, v, v);
specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: void addOperation(org.apache.hive.service.cli.operation.Operation)>(v);
return v;
}
public org.apache.hive.service.cli.operation.MetadataOperation newGetTablesOperation(org.apache.hive.service.cli.session.HiveSession, java.lang.String, java.lang.String, java.lang.String, java.util.List) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.operation.GetTablesOperation v;
org.apache.hive.service.cli.operation.OperationManager v;
java.util.List v;
java.lang.String v, v, v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.session.HiveSession;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
v = new org.apache.hive.service.cli.operation.GetTablesOperation;
specialinvoke v.<org.apache.hive.service.cli.operation.GetTablesOperation: void <init>(org.apache.hive.service.cli.session.HiveSession,java.lang.String,java.lang.String,java.lang.String,java.util.List)>(v, v, v, v, v);
specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: void addOperation(org.apache.hive.service.cli.operation.Operation)>(v);
return v;
}
public org.apache.hive.service.cli.operation.GetTableTypesOperation newGetTableTypesOperation(org.apache.hive.service.cli.session.HiveSession) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.operation.OperationManager v;
org.apache.hive.service.cli.operation.GetTableTypesOperation v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.session.HiveSession;
v = new org.apache.hive.service.cli.operation.GetTableTypesOperation;
specialinvoke v.<org.apache.hive.service.cli.operation.GetTableTypesOperation: void <init>(org.apache.hive.service.cli.session.HiveSession)>(v);
specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: void addOperation(org.apache.hive.service.cli.operation.Operation)>(v);
return v;
}
public org.apache.hive.service.cli.operation.GetColumnsOperation newGetColumnsOperation(org.apache.hive.service.cli.session.HiveSession, java.lang.String, java.lang.String, java.lang.String, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.operation.OperationManager v;
java.lang.String v, v, v, v;
org.apache.hive.service.cli.operation.GetColumnsOperation v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.session.HiveSession;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = new org.apache.hive.service.cli.operation.GetColumnsOperation;
specialinvoke v.<org.apache.hive.service.cli.operation.GetColumnsOperation: void <init>(org.apache.hive.service.cli.session.HiveSession,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v);
specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: void addOperation(org.apache.hive.service.cli.operation.Operation)>(v);
return v;
}
public org.apache.hive.service.cli.operation.GetFunctionsOperation newGetFunctionsOperation(org.apache.hive.service.cli.session.HiveSession, java.lang.String, 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.operation.GetFunctionsOperation v;
java.lang.String v, v, v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.session.HiveSession;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = new org.apache.hive.service.cli.operation.GetFunctionsOperation;
specialinvoke v.<org.apache.hive.service.cli.operation.GetFunctionsOperation: void <init>(org.apache.hive.service.cli.session.HiveSession,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v);
specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: void addOperation(org.apache.hive.service.cli.operation.Operation)>(v);
return v;
}
public org.apache.hive.service.cli.operation.GetPrimaryKeysOperation newGetPrimaryKeysOperation(org.apache.hive.service.cli.session.HiveSession, java.lang.String, java.lang.String, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.operation.OperationManager v;
java.lang.String v, v, v;
org.apache.hive.service.cli.operation.GetPrimaryKeysOperation v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.session.HiveSession;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = new org.apache.hive.service.cli.operation.GetPrimaryKeysOperation;
specialinvoke v.<org.apache.hive.service.cli.operation.GetPrimaryKeysOperation: void <init>(org.apache.hive.service.cli.session.HiveSession,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v);
specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: void addOperation(org.apache.hive.service.cli.operation.Operation)>(v);
return v;
}
public org.apache.hive.service.cli.operation.GetCrossReferenceOperation newGetCrossReferenceOperation(org.apache.hive.service.cli.session.HiveSession, 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
{
org.apache.hive.service.cli.operation.GetCrossReferenceOperation 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;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.session.HiveSession;
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;
v = new org.apache.hive.service.cli.operation.GetCrossReferenceOperation;
specialinvoke v.<org.apache.hive.service.cli.operation.GetCrossReferenceOperation: void <init>(org.apache.hive.service.cli.session.HiveSession,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);
specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: void addOperation(org.apache.hive.service.cli.operation.Operation)>(v);
return v;
}
public org.apache.hive.service.cli.operation.Operation newUploadDataOperation(org.apache.hive.service.cli.session.HiveSession, java.nio.ByteBuffer, java.lang.String, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.HiveSQLException v;
org.apache.hive.service.cli.operation.OperationManager v;
java.lang.String v, v;
java.nio.ByteBuffer v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.session.HiveSession;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = new org.apache.hive.service.cli.HiveSQLException;
specialinvoke v.<org.apache.hive.service.cli.HiveSQLException: void <init>(java.lang.String)>("unimplemented exception");
throw v;
}
public org.apache.hive.service.cli.operation.Operation newDownloadDataOperation(org.apache.hive.service.cli.session.HiveSession, java.lang.String, java.lang.String, java.lang.String, java.util.Map) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.HiveSQLException v;
org.apache.hive.service.cli.operation.OperationManager v;
java.util.Map v;
java.lang.String v, v, v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.session.HiveSession;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.util.Map;
v = new org.apache.hive.service.cli.HiveSQLException;
specialinvoke v.<org.apache.hive.service.cli.HiveSQLException: void <init>(java.lang.String)>("unimplemented exception");
throw v;
}
public org.apache.hive.service.cli.operation.Operation getOperation(org.apache.hive.service.cli.OperationHandle) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.HiveSQLException v;
org.apache.hive.service.cli.operation.OperationManager v;
java.lang.String v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.OperationHandle;
v = specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: org.apache.hive.service.cli.operation.Operation getOperationInternal(org.apache.hive.service.cli.OperationHandle)>(v);
if v != null goto label;
v = new org.apache.hive.service.cli.HiveSQLException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.service.cli.OperationHandle)>(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[])>("Invalid OperationHandle: \u0001");
specialinvoke v.<org.apache.hive.service.cli.HiveSQLException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
private org.apache.hive.service.cli.operation.Operation getOperationInternal(org.apache.hive.service.cli.OperationHandle)
{
org.apache.hive.service.cli.operation.OperationManager v;
java.util.concurrent.ConcurrentHashMap v;
java.lang.Object v;
org.apache.hive.service.cli.OperationHandle v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.OperationHandle;
v = v.<org.apache.hive.service.cli.operation.OperationManager: java.util.concurrent.ConcurrentHashMap handleToOperation>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
return v;
}
private java.lang.String getQueryId(org.apache.hive.service.cli.operation.Operation)
{
org.apache.hive.service.cli.operation.OperationManager v;
java.lang.String v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.operation.Operation;
v = virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: java.lang.String getQueryId()>();
return v;
}
private void addOperation(org.apache.hive.service.cli.operation.Operation) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.operation.Operation v;
java.lang.String v, v;
org.apache.hive.service.cli.HiveSQLException v;
org.apache.hive.service.cli.SessionHandle v;
org.slf4j.Logger v;
org.apache.hive.service.Service$STATE v, v, v;
java.util.concurrent.ConcurrentHashMap v, v;
org.apache.hive.service.cli.session.HiveSession v;
java.util.function.Consumer v;
org.apache.hive.service.cli.operation.OperationManager v;
java.util.Optional v;
org.apache.hive.service.cli.OperationHandle v, v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.operation.Operation;
v = virtualinvoke v.<org.apache.hive.service.cli.operation.OperationManager: org.apache.hive.service.Service$STATE getServiceState()>();
v = <org.apache.hive.service.Service$STATE: org.apache.hive.service.Service$STATE STARTED>;
if v == v goto label;
v = new org.apache.hive.service.cli.HiveSQLException;
v = virtualinvoke v.<org.apache.hive.service.cli.operation.OperationManager: org.apache.hive.service.Service$STATE getServiceState()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.service.Service$STATE)>(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[])>("Unable to run new queries as HiveServer is decommissioned or inactive, state: \u0001");
specialinvoke v.<org.apache.hive.service.cli.HiveSQLException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.hive.service.cli.operation.OperationManager: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationHandle getHandle()>();
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.hive.service.cli.SessionHandle getSessionHandle()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Adding operation: {} {}", v, v);
v = v.<org.apache.hive.service.cli.operation.OperationManager: java.util.concurrent.ConcurrentHashMap queryIdOperation>;
v = specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: java.lang.String getQueryId(org.apache.hive.service.cli.operation.Operation)>(v);
virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.hive.service.cli.operation.OperationManager: java.util.concurrent.ConcurrentHashMap handleToOperation>;
v = virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationHandle getHandle()>();
virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.hive.service.cli.operation.OperationManager: java.util.Optional queryInfoCache>;
v = staticinvoke <org.apache.hive.service.cli.operation.OperationManager$lambda_addOperation_0__4: java.util.function.Consumer bootstrap$(org.apache.hive.service.cli.operation.Operation)>(v);
virtualinvoke v.<java.util.Optional: void ifPresent(java.util.function.Consumer)>(v);
return;
}
public void updateQueryTag(java.lang.String, java.lang.String)
{
org.apache.hive.service.cli.operation.OperationManager v;
org.slf4j.Logger v;
java.util.concurrent.ConcurrentHashMap v;
java.lang.Object v;
java.lang.String v, v;
com.google.common.collect.SetMultimap v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = v.<org.apache.hive.service.cli.operation.OperationManager: java.util.concurrent.ConcurrentHashMap queryIdOperation>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = v.<org.apache.hive.service.cli.operation.OperationManager: com.google.common.collect.SetMultimap queryTagToIdMap>;
interfaceinvoke v.<com.google.common.collect.SetMultimap: boolean put(java.lang.Object,java.lang.Object)>(v, v);
return;
label:
v = v.<org.apache.hive.service.cli.operation.OperationManager: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Query id is missing during query tag updation");
return;
}
private org.apache.hive.service.cli.operation.Operation removeOperation(org.apache.hive.service.cli.OperationHandle)
{
java.lang.Object[] v;
org.slf4j.Logger v;
java.util.concurrent.ConcurrentHashMap v, v;
java.lang.RuntimeException v;
com.google.common.collect.SetMultimap v;
java.util.function.Consumer v;
org.apache.hive.service.cli.operation.OperationManager v;
java.util.Optional v;
java.lang.Object v;
java.lang.String v, v, v;
org.apache.hive.service.cli.OperationHandle v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.OperationHandle;
v = v.<org.apache.hive.service.cli.operation.OperationManager: java.util.concurrent.ConcurrentHashMap handleToOperation>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object remove(java.lang.Object)>(v);
if v != null goto label;
v = new java.lang.RuntimeException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.service.cli.OperationHandle)>(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[])>("Operation does not exist: \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v = specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: java.lang.String getQueryId(org.apache.hive.service.cli.operation.Operation)>(v);
v = v.<org.apache.hive.service.cli.operation.OperationManager: java.util.concurrent.ConcurrentHashMap queryIdOperation>;
virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object remove(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: java.lang.String getQueryTag()>();
if v == null goto label;
v = v.<org.apache.hive.service.cli.operation.OperationManager: com.google.common.collect.SetMultimap queryTagToIdMap>;
interfaceinvoke v.<com.google.common.collect.SetMultimap: boolean remove(java.lang.Object,java.lang.Object)>(v, v);
label:
v = v.<org.apache.hive.service.cli.operation.OperationManager: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object[])>("Removed queryId: {} corresponding to operation: {} with tag: {}", v);
v = v.<org.apache.hive.service.cli.operation.OperationManager: java.util.Optional queryInfoCache>;
v = staticinvoke <org.apache.hive.service.cli.operation.OperationManager$lambda_removeOperation_1__5: java.util.function.Consumer bootstrap$(org.apache.hive.service.cli.operation.Operation)>(v);
virtualinvoke v.<java.util.Optional: void ifPresent(java.util.function.Consumer)>(v);
return v;
}
private org.apache.hive.service.cli.operation.Operation removeTimedOutOperation(org.apache.hive.service.cli.OperationHandle)
{
org.apache.hadoop.hive.common.metrics.common.Metrics v;
org.slf4j.Logger v, v;
org.apache.hive.service.cli.OperationState v;
java.util.concurrent.ConcurrentHashMap v;
long v;
org.apache.hive.service.cli.operation.Operation v;
java.lang.Exception v;
org.apache.hive.service.cli.operation.OperationManager v;
java.lang.Object v;
java.lang.String v, v;
org.apache.hive.service.cli.OperationHandle v, v;
boolean v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.OperationHandle;
v = v.<org.apache.hive.service.cli.operation.OperationManager: java.util.concurrent.ConcurrentHashMap handleToOperation>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: boolean isTimedOut(long)>(v);
if v == 0 goto label;
v = v.<org.apache.hive.service.cli.operation.OperationManager: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationHandle getHandle()>();
v = virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationState getState()>();
v = virtualinvoke v.<org.apache.hive.service.cli.OperationState: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.service.cli.OperationHandle,java.lang.String)>(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[])>("Operation is timed out,operation=\u,state=\u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = staticinvoke <org.apache.hadoop.hive.common.metrics.common.MetricsFactory: org.apache.hadoop.hive.common.metrics.common.Metrics getInstance()>();
if v == null goto label;
label:
interfaceinvoke v.<org.apache.hadoop.hive.common.metrics.common.Metrics: java.lang.Long decrementCounter(java.lang.String)>("open_operations");
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.hive.service.cli.operation.OperationManager: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Error decrementing open_operations metric, reported values may be incorrect", v);
label:
v = specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: org.apache.hive.service.cli.operation.Operation removeOperation(org.apache.hive.service.cli.OperationHandle)>(v);
return v;
label:
return null;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.cli.OperationStatus getOperationStatus(org.apache.hive.service.cli.OperationHandle) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.operation.OperationManager v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.cli.OperationStatus v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.OperationHandle;
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.OperationStatus getStatus()>();
return v;
}
public void cancelOperation(org.apache.hive.service.cli.OperationHandle, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException
{
org.slf4j.Logger v, v;
org.apache.hive.service.cli.OperationState v, v;
org.apache.hive.service.cli.operation.Operation v;
java.util.function.Consumer v;
org.apache.hive.service.cli.operation.OperationManager v;
java.util.Optional v;
java.lang.String v, v, v;
org.apache.hive.service.cli.OperationHandle v;
boolean v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.OperationHandle;
v := @parameter: java.lang.String;
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.OperationState getState()>();
v = virtualinvoke v.<org.apache.hive.service.cli.OperationState: boolean isTerminal()>();
if v == 0 goto label;
v = v.<org.apache.hive.service.cli.operation.OperationManager: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.service.cli.OperationHandle,org.apache.hive.service.cli.OperationState)>(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: Operation is already aborted in state - \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
goto label;
label:
v = v.<org.apache.hive.service.cli.operation.OperationManager: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.service.cli.OperationHandle,org.apache.hive.service.cli.OperationState)>(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: Attempting to cancel from state - \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
v = <org.apache.hive.service.cli.OperationState: org.apache.hive.service.cli.OperationState CANCELED>;
virtualinvoke v.<org.apache.hive.service.cli.OperationState: void setErrorMessage(java.lang.String)>(v);
virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: void cancel(org.apache.hive.service.cli.OperationState)>(v);
v = v.<org.apache.hive.service.cli.operation.OperationManager: java.util.Optional queryInfoCache>;
v = staticinvoke <org.apache.hive.service.cli.operation.OperationManager$lambda_cancelOperation_2__6: java.util.function.Consumer bootstrap$(org.apache.hive.service.cli.operation.Operation)>(v);
virtualinvoke v.<java.util.Optional: void ifPresent(java.util.function.Consumer)>(v);
label:
return;
}
public void cancelOperation(org.apache.hive.service.cli.OperationHandle) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.operation.OperationManager v;
org.apache.hive.service.cli.OperationHandle v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.OperationHandle;
virtualinvoke v.<org.apache.hive.service.cli.operation.OperationManager: void cancelOperation(org.apache.hive.service.cli.OperationHandle,java.lang.String)>(v, "");
return;
}
public void closeOperation(org.apache.hive.service.cli.OperationHandle) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hadoop.hive.common.metrics.common.Metrics v;
org.slf4j.Logger v, v;
org.apache.hive.service.cli.operation.Operation v;
java.lang.Exception v;
org.apache.hive.service.cli.operation.OperationManager v;
java.lang.String v;
org.apache.hive.service.cli.OperationHandle v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.OperationHandle;
v = v.<org.apache.hive.service.cli.operation.OperationManager: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.service.cli.OperationHandle)>(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[])>("Closing operation: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v = specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: org.apache.hive.service.cli.operation.Operation removeOperation(org.apache.hive.service.cli.OperationHandle)>(v);
v = staticinvoke <org.apache.hadoop.hive.common.metrics.common.MetricsFactory: org.apache.hadoop.hive.common.metrics.common.Metrics getInstance()>();
if v == null goto label;
label:
interfaceinvoke v.<org.apache.hadoop.hive.common.metrics.common.Metrics: java.lang.Long decrementCounter(java.lang.String)>("open_operations");
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.hive.service.cli.operation.OperationManager: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Error Reporting close operation to Metrics system", v);
label:
virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: void close()>();
return;
catch java.lang.Exception from label to label with label;
}
public org.apache.hive.service.cli.TableSchema getOperationResultSetSchema(org.apache.hive.service.cli.OperationHandle) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.operation.OperationManager v;
org.apache.hive.service.cli.TableSchema v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.OperationHandle;
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.TableSchema getResultSetSchema()>();
return v;
}
public org.apache.hive.service.cli.RowSet getOperationNextRowSet(org.apache.hive.service.cli.OperationHandle, org.apache.hive.service.cli.FetchOrientation, long) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.operation.OperationManager v;
org.apache.hive.service.cli.FetchOrientation v;
org.apache.hive.service.cli.RowSet v;
long v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.OperationHandle;
v := @parameter: org.apache.hive.service.cli.FetchOrientation;
v := @parameter: long;
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.RowSet getNextRowSet(org.apache.hive.service.cli.FetchOrientation,long)>(v, v);
return v;
}
public org.apache.hive.service.cli.RowSet getOperationLogRowSet(org.apache.hive.service.cli.OperationHandle, org.apache.hive.service.cli.FetchOrientation, long, org.apache.hadoop.hive.conf.HiveConf) throws org.apache.hive.service.cli.HiveSQLException
{
java.lang.Throwable v;
org.apache.hive.service.cli.RowSet v;
org.apache.hive.service.cli.TableSchema v;
org.apache.hadoop.hive.metastore.api.Schema v;
java.lang.String[] v;
long v;
org.apache.hive.service.cli.operation.Operation v, v;
java.sql.SQLException v;
org.apache.hive.service.cli.FetchOrientation v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
java.lang.String v, v;
boolean v, v, v;
org.apache.hive.service.rpc.thrift.TProtocolVersion v;
org.apache.hive.service.cli.HiveSQLException v, v;
org.slf4j.Logger v;
java.util.Iterator v;
org.apache.hadoop.hive.conf.HiveConf v;
org.apache.hive.service.cli.operation.OperationManager v;
java.util.List v;
org.apache.hadoop.hive.ql.session.OperationLog v;
java.lang.Object v;
org.apache.hive.service.cli.OperationHandle v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.OperationHandle;
v := @parameter: org.apache.hive.service.cli.FetchOrientation;
v := @parameter: long;
v := @parameter: org.apache.hadoop.hive.conf.HiveConf;
v = new org.apache.hive.service.cli.TableSchema;
v = specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: org.apache.hadoop.hive.metastore.api.Schema getLogSchema()>();
specialinvoke v.<org.apache.hive.service.cli.TableSchema: void <init>(org.apache.hadoop.hive.metastore.api.Schema)>(v);
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.rpc.thrift.TProtocolVersion getProtocolVersion()>();
v = staticinvoke <org.apache.hive.service.cli.RowSetFactory: org.apache.hive.service.cli.RowSet create(org.apache.hive.service.cli.TableSchema,org.apache.hive.service.rpc.thrift.TProtocolVersion,boolean)>(v, v, 0);
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_LOGGING_OPERATION_ENABLED>;
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 = v.<org.apache.hive.service.cli.operation.OperationManager: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>("Try to get operation log when hive.server.logging.operation.enabled is false, no log will be returned. ");
return v;
label:
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.hadoop.hive.ql.session.OperationLog getOperationLog()>();
if v != null goto label;
v = new org.apache.hive.service.cli.HiveSQLException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.service.cli.OperationHandle)>(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[])>("Couldn\'t find log associated with operation handle: \u0001");
specialinvoke v.<org.apache.hive.service.cli.HiveSQLException: void <init>(java.lang.String)>(v);
throw v;
label:
v = specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: boolean isFetchFirst(org.apache.hive.service.cli.FetchOrientation)>(v);
v = virtualinvoke v.<org.apache.hadoop.hive.ql.session.OperationLog: java.util.List readOperationLog(boolean,long)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.service.cli.HiveSQLException;
v = virtualinvoke v.<java.sql.SQLException: java.lang.String getMessage()>();
v = virtualinvoke v.<java.sql.SQLException: java.lang.Throwable getCause()>();
specialinvoke v.<org.apache.hive.service.cli.HiveSQLException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v = interfaceinvoke v.<java.util.List: 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()>();
v = newarray (java.lang.String)[1];
v[0] = v;
interfaceinvoke v.<org.apache.hive.service.cli.RowSet: org.apache.hive.service.cli.RowSet addRow(java.lang.Object[])>(v);
goto label;
label:
return v;
catch java.sql.SQLException from label to label with label;
}
private boolean isFetchFirst(org.apache.hive.service.cli.FetchOrientation)
{
org.apache.hive.service.cli.operation.OperationManager v;
org.apache.hive.service.cli.FetchOrientation v, v;
boolean v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.FetchOrientation;
v = <org.apache.hive.service.cli.FetchOrientation: org.apache.hive.service.cli.FetchOrientation FETCH_FIRST>;
v = virtualinvoke v.<org.apache.hive.service.cli.FetchOrientation: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
return 1;
label:
return 0;
}
private org.apache.hadoop.hive.metastore.api.Schema getLogSchema()
{
org.apache.hadoop.hive.metastore.api.FieldSchema v;
org.apache.hive.service.cli.operation.OperationManager v;
org.apache.hadoop.hive.metastore.api.Schema v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v = new org.apache.hadoop.hive.metastore.api.Schema;
specialinvoke v.<org.apache.hadoop.hive.metastore.api.Schema: void <init>()>();
v = new org.apache.hadoop.hive.metastore.api.FieldSchema;
specialinvoke v.<org.apache.hadoop.hive.metastore.api.FieldSchema: void <init>()>();
virtualinvoke v.<org.apache.hadoop.hive.metastore.api.FieldSchema: void setName(java.lang.String)>("operation_log");
virtualinvoke v.<org.apache.hadoop.hive.metastore.api.FieldSchema: void setType(java.lang.String)>("string");
virtualinvoke v.<org.apache.hadoop.hive.metastore.api.Schema: void addToFieldSchemas(org.apache.hadoop.hive.metastore.api.FieldSchema)>(v);
return v;
}
public java.util.Collection getOperations()
{
org.apache.hive.service.cli.operation.OperationManager v;
java.util.Collection v, v;
java.util.concurrent.ConcurrentHashMap v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v = v.<org.apache.hive.service.cli.operation.OperationManager: java.util.concurrent.ConcurrentHashMap handleToOperation>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.util.Collection values()>();
v = staticinvoke <java.util.Collections: java.util.Collection unmodifiableCollection(java.util.Collection)>(v);
return v;
}
public java.util.List removeExpiredOperations(org.apache.hive.service.cli.OperationHandle[])
{
org.slf4j.Logger v;
org.apache.hive.service.cli.OperationHandle[] v;
org.apache.hive.service.cli.operation.Operation v;
java.util.ArrayList v;
org.apache.hive.service.cli.operation.OperationManager v;
int v, v;
java.lang.String v;
org.apache.hive.service.cli.OperationHandle v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.OperationHandle[];
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = specialinvoke v.<org.apache.hive.service.cli.operation.OperationManager: org.apache.hive.service.cli.operation.Operation removeTimedOutOperation(org.apache.hive.service.cli.OperationHandle)>(v);
if v == null goto label;
v = v.<org.apache.hive.service.cli.operation.OperationManager: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.service.cli.OperationHandle)>(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[])>("Operation \u is timed-out and will be closed");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = v + 1;
goto label;
label:
return v;
}
public java.util.List getHistoricalQueryInfos()
{
org.apache.hive.service.cli.operation.OperationManager v;
java.util.List v;
java.util.Optional v, v;
java.lang.Object v;
java.util.function.Function v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v = v.<org.apache.hive.service.cli.operation.OperationManager: java.util.Optional queryInfoCache>;
v = staticinvoke <org.apache.hive.service.cli.operation.OperationManager$lambda_getHistoricalQueryInfos_3__7: java.util.function.Function bootstrap$()>();
v = virtualinvoke v.<java.util.Optional: java.util.Optional map(java.util.function.Function)>(v);
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object orElse(java.lang.Object)>(v);
return v;
}
public java.util.List getLiveQueryInfos()
{
org.apache.hive.service.cli.operation.OperationManager v;
java.util.List v;
java.util.Optional v, v;
java.lang.Object v;
java.util.function.Function v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v = v.<org.apache.hive.service.cli.operation.OperationManager: java.util.Optional queryInfoCache>;
v = staticinvoke <org.apache.hive.service.cli.operation.OperationManager$lambda_getLiveQueryInfos_4__8: java.util.function.Function bootstrap$()>();
v = virtualinvoke v.<java.util.Optional: java.util.Optional map(java.util.function.Function)>(v);
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object orElse(java.lang.Object)>(v);
return v;
}
public org.apache.hadoop.hive.ql.QueryInfo getQueryInfo(java.lang.String)
{
org.apache.hive.service.cli.operation.OperationManager v;
java.util.Optional v, v;
java.lang.Object v;
java.lang.String v;
java.util.function.Function v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: java.lang.String;
v = v.<org.apache.hive.service.cli.operation.OperationManager: java.util.Optional queryInfoCache>;
v = staticinvoke <org.apache.hive.service.cli.operation.OperationManager$lambda_getQueryInfo_5__9: java.util.function.Function bootstrap$(java.lang.String)>(v);
v = virtualinvoke v.<java.util.Optional: java.util.Optional map(java.util.function.Function)>(v);
v = virtualinvoke v.<java.util.Optional: java.lang.Object orElse(java.lang.Object)>(null);
return v;
}
public org.apache.hive.service.cli.operation.Operation getOperationByQueryId(java.lang.String)
{
org.apache.hive.service.cli.operation.OperationManager v;
java.util.concurrent.ConcurrentHashMap v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: java.lang.String;
v = v.<org.apache.hive.service.cli.operation.OperationManager: java.util.concurrent.ConcurrentHashMap queryIdOperation>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public java.util.Set getOperationsByQueryTag(java.lang.String)
{
java.util.Iterator v;
java.util.Set v;
org.apache.hive.service.cli.operation.Operation v, v;
com.google.common.collect.SetMultimap v;
java.util.HashSet v;
org.apache.hive.service.cli.operation.OperationManager v;
java.lang.Object v;
java.lang.String v;
boolean v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: java.lang.String;
v = v.<org.apache.hive.service.cli.operation.OperationManager: com.google.common.collect.SetMultimap queryTagToIdMap>;
v = interfaceinvoke v.<com.google.common.collect.SetMultimap: java.util.Set get(java.lang.Object)>(v);
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
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 = virtualinvoke v.<org.apache.hive.service.cli.operation.OperationManager: org.apache.hive.service.cli.operation.Operation getOperationByQueryId(java.lang.String)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.hive.service.cli.operation.OperationManager: org.apache.hive.service.cli.operation.Operation getOperationByQueryId(java.lang.String)>(v);
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
goto label;
label:
return v;
}
public boolean canShowDrilldownLink(org.apache.hive.service.cli.OperationHandle)
{
org.apache.hive.service.cli.HiveSQLException v;
org.apache.hadoop.hive.conf.HiveConf v, v;
org.apache.hive.service.cli.operation.Operation v;
org.apache.hive.service.cli.operation.OperationManager v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
org.apache.hadoop.hive.ql.QueryState v;
org.apache.hive.service.cli.OperationHandle v;
boolean v, v, v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v := @parameter: org.apache.hive.service.cli.OperationHandle;
label:
v = virtualinvoke v.<org.apache.hive.service.cli.operation.OperationManager: org.apache.hadoop.hive.conf.HiveConf getHiveConf()>();
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean isWebUiEnabled()>();
if v != 0 goto label;
label:
return 0;
label:
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 = v instanceof org.apache.hive.service.cli.operation.SQLOperation;
if v == 0 goto label;
v = v.<org.apache.hive.service.cli.operation.SQLOperation: org.apache.hadoop.hive.ql.QueryState queryState>;
v = virtualinvoke v.<org.apache.hadoop.hive.ql.QueryState: org.apache.hadoop.hive.conf.HiveConf getConf()>();
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_SHOW_OPERATION_DRILLDOWN_LINK>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: boolean getBoolVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
label:
return v;
label:
v := @caughtexception;
label:
return 0;
catch org.apache.hive.service.cli.HiveSQLException from label to label with label;
catch org.apache.hive.service.cli.HiveSQLException from label to label with label;
}
public java.util.Set getAllCachedQueryIds()
{
org.apache.hive.service.cli.operation.OperationManager v;
java.util.Optional v, v;
java.util.Set v;
java.lang.Object v;
java.util.function.Function v;
v := @this: org.apache.hive.service.cli.operation.OperationManager;
v = v.<org.apache.hive.service.cli.operation.OperationManager: java.util.Optional queryInfoCache>;
v = staticinvoke <org.apache.hive.service.cli.operation.OperationManager$lambda_getAllCachedQueryIds_6__10: java.util.function.Function bootstrap$()>();
v = virtualinvoke v.<java.util.Optional: java.util.Optional map(java.util.function.Function)>(v);
v = staticinvoke <java.util.Collections: java.util.Set emptySet()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object orElse(java.lang.Object)>(v);
return v;
}
}