public abstract class org.apache.hive.service.cli.operation.Operation extends java.lang.Object
{
protected final org.apache.hive.service.cli.session.HiveSession parentSession;
protected boolean embedded;
private volatile org.apache.hive.service.cli.OperationState state;
private volatile org.apache.hadoop.hive.common.metrics.common.MetricsScope currentStateScope;
private final org.apache.hive.service.cli.OperationHandle opHandle;
public static final org.apache.hive.service.cli.FetchOrientation DEFAULT_FETCH_ORIENTATION;
protected final org.slf4j.Logger log;
protected java.lang.Boolean hasResultSet;
protected volatile org.apache.hive.service.cli.HiveSQLException operationException;
protected volatile java.util.concurrent.Future backgroundHandle;
protected org.apache.hadoop.hive.ql.session.OperationLog operationLog;
protected boolean isOperationLogEnabled;
private long operationTimeout;
private volatile long lastAccessTime;
private final long beginTime;
private final java.util.concurrent.CountDownLatch opTerminateMonitorLatch;
protected long operationStart;
protected long operationComplete;
protected final org.apache.hadoop.hive.ql.QueryState queryState;
protected static final java.util.EnumSet DEFAULT_FETCH_ORIENTATION_SET;
protected static java.util.Set scopeStates;
protected static java.util.Set terminalStates;
protected void <init>(org.apache.hive.service.cli.session.HiveSession, org.apache.hive.service.cli.OperationType)
{
org.apache.hive.service.cli.operation.Operation v;
org.apache.hive.service.cli.OperationType v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v := @parameter: org.apache.hive.service.cli.session.HiveSession;
v := @parameter: org.apache.hive.service.cli.OperationType;
specialinvoke v.<org.apache.hive.service.cli.operation.Operation: void <init>(org.apache.hive.service.cli.session.HiveSession,java.util.Map,org.apache.hive.service.cli.OperationType)>(v, null, v);
return;
}
protected void <init>(org.apache.hive.service.cli.session.HiveSession, java.util.Map, org.apache.hive.service.cli.OperationType)
{
java.util.Map v;
org.apache.hive.service.cli.OperationType v;
org.apache.hive.service.cli.operation.Operation v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v := @parameter: org.apache.hive.service.cli.session.HiveSession;
v := @parameter: java.util.Map;
v := @parameter: org.apache.hive.service.cli.OperationType;
specialinvoke v.<org.apache.hive.service.cli.operation.Operation: void <init>(org.apache.hive.service.cli.session.HiveSession,java.util.Map,org.apache.hive.service.cli.OperationType,boolean)>(v, v, v, 0);
return;
}
protected void <init>(org.apache.hive.service.cli.session.HiveSession, java.util.Map, org.apache.hive.service.cli.OperationType, boolean)
{
org.apache.hadoop.hive.ql.QueryState$Builder v, v, v, v;
org.apache.hadoop.hive.common.metrics.common.MetricsScope v;
org.apache.hive.service.cli.OperationState v, v;
org.apache.hive.service.cli.OperationType v;
long v, v, v;
org.apache.hive.service.cli.operation.Operation v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
java.util.Map v;
org.apache.hadoop.hive.ql.QueryState v;
boolean v, v;
org.apache.hive.service.rpc.thrift.TProtocolVersion v;
org.slf4j.Logger v;
org.apache.hadoop.hive.conf.HiveConf v, v;
org.apache.hive.service.cli.session.HiveSession v;
java.util.concurrent.TimeUnit v;
java.util.concurrent.CountDownLatch v;
java.lang.Class v;
org.apache.hive.service.cli.OperationHandle v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v := @parameter: org.apache.hive.service.cli.session.HiveSession;
v := @parameter: java.util.Map;
v := @parameter: org.apache.hive.service.cli.OperationType;
v := @parameter: boolean;
specialinvoke v.<java.lang.Object: void <init>()>();
v = <org.apache.hive.service.cli.OperationState: org.apache.hive.service.cli.OperationState INITIALIZED>;
v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationState state> = v;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(v);
v.<org.apache.hive.service.cli.operation.Operation: org.slf4j.Logger log> = v;
v.<org.apache.hive.service.cli.operation.Operation: java.lang.Boolean hasResultSet> = null;
v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.session.HiveSession parentSession> = v;
v.<org.apache.hive.service.cli.operation.Operation: boolean embedded> = v;
v = new org.apache.hive.service.cli.OperationHandle;
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: org.apache.hive.service.rpc.thrift.TProtocolVersion getProtocolVersion()>();
specialinvoke v.<org.apache.hive.service.cli.OperationHandle: void <init>(org.apache.hive.service.cli.OperationType,org.apache.hive.service.rpc.thrift.TProtocolVersion)>(v, v);
v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationHandle opHandle> = v;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.hive.service.cli.operation.Operation: java.util.concurrent.CountDownLatch opTerminateMonitorLatch> = v;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v.<org.apache.hive.service.cli.operation.Operation: long beginTime> = v;
v = v.<org.apache.hive.service.cli.operation.Operation: long beginTime>;
v.<org.apache.hive.service.cli.operation.Operation: long lastAccessTime> = v;
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: org.apache.hadoop.hive.conf.HiveConf getHiveConf()>();
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_IDLE_OPERATION_TIMEOUT>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: long getTimeVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars,java.util.concurrent.TimeUnit)>(v, v, v);
v.<org.apache.hive.service.cli.operation.Operation: long operationTimeout> = v;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationState state>;
v = virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.common.metrics.common.MetricsScope updateOperationStateMetrics(org.apache.hadoop.hive.common.metrics.common.MetricsScope,java.lang.String,java.lang.String,org.apache.hive.service.cli.OperationState)>(null, "hs2_operation_", "hs2_completed_operation_", v);
v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.common.metrics.common.MetricsScope currentStateScope> = v;
v = new org.apache.hadoop.hive.ql.QueryState$Builder;
specialinvoke v.<org.apache.hadoop.hive.ql.QueryState$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.hadoop.hive.ql.QueryState$Builder: org.apache.hadoop.hive.ql.QueryState$Builder withConfOverlay(java.util.Map)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = virtualinvoke v.<org.apache.hadoop.hive.ql.QueryState$Builder: org.apache.hadoop.hive.ql.QueryState$Builder withGenerateNewQueryId(boolean)>(v);
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: org.apache.hadoop.hive.conf.HiveConf getHiveConf()>();
v = virtualinvoke v.<org.apache.hadoop.hive.ql.QueryState$Builder: org.apache.hadoop.hive.ql.QueryState$Builder withHiveConf(org.apache.hadoop.hive.conf.HiveConf)>(v);
v = virtualinvoke v.<org.apache.hadoop.hive.ql.QueryState$Builder: org.apache.hadoop.hive.ql.QueryState build()>();
v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.ql.QueryState queryState> = v;
return;
}
public java.util.concurrent.Future getBackgroundHandle()
{
java.util.concurrent.Future v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: java.util.concurrent.Future backgroundHandle>;
return v;
}
protected void setBackgroundHandle(java.util.concurrent.Future)
{
java.util.concurrent.Future v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v := @parameter: java.util.concurrent.Future;
v.<org.apache.hive.service.cli.operation.Operation: java.util.concurrent.Future backgroundHandle> = v;
return;
}
public boolean shouldRunAsync()
{
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
return 0;
}
public org.apache.hive.service.cli.session.HiveSession getParentSession()
{
org.apache.hive.service.cli.operation.Operation v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.session.HiveSession parentSession>;
return v;
}
public org.apache.hive.service.cli.OperationHandle getHandle()
{
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationHandle opHandle>;
return v;
}
public org.apache.hive.service.rpc.thrift.TProtocolVersion getProtocolVersion()
{
org.apache.hive.service.rpc.thrift.TProtocolVersion v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationHandle opHandle>;
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.rpc.thrift.TProtocolVersion getProtocolVersion()>();
return v;
}
public org.apache.hive.service.cli.OperationType getType()
{
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.cli.operation.Operation v;
org.apache.hive.service.cli.OperationType v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationHandle opHandle>;
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.cli.OperationType getOperationType()>();
return v;
}
public org.apache.hive.service.cli.OperationStatus getStatus()
{
org.apache.hive.service.cli.HiveSQLException v, v;
org.slf4j.Logger v;
org.apache.hive.service.cli.OperationState v;
long v, v;
org.apache.hive.service.cli.OperationStatus v;
org.apache.hive.service.cli.operation.Operation v;
java.lang.Boolean v;
java.lang.String v;
org.apache.hive.service.cli.OperationHandle v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = null;
label:
v = virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: java.lang.String getTaskStatus()>();
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.hive.service.cli.operation.Operation: org.slf4j.Logger log>;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationHandle opHandle>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Error getting task status for {}", v, v);
label:
v = new org.apache.hive.service.cli.OperationStatus;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationState state>;
v = v.<org.apache.hive.service.cli.operation.Operation: long operationStart>;
v = v.<org.apache.hive.service.cli.operation.Operation: long operationComplete>;
v = v.<org.apache.hive.service.cli.operation.Operation: java.lang.Boolean hasResultSet>;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.HiveSQLException operationException>;
specialinvoke v.<org.apache.hive.service.cli.OperationStatus: void <init>(org.apache.hive.service.cli.OperationState,java.lang.String,long,long,java.lang.Boolean,org.apache.hive.service.cli.HiveSQLException)>(v, v, v, v, v, v);
return v;
catch org.apache.hive.service.cli.HiveSQLException from label to label with label;
}
public boolean hasResultSet()
{
java.lang.Boolean v, v;
org.apache.hive.service.cli.operation.Operation v;
boolean v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: java.lang.Boolean hasResultSet>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.hive.service.cli.operation.Operation: java.lang.Boolean hasResultSet>;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
label:
return v;
}
protected void setHasResultSet(boolean)
{
java.lang.Boolean v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.cli.operation.Operation v;
boolean v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v := @parameter: boolean;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
v.<org.apache.hive.service.cli.operation.Operation: java.lang.Boolean hasResultSet> = v;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationHandle opHandle>;
virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: void setHasResultSet(boolean)>(v);
return;
}
public org.apache.hadoop.hive.ql.session.OperationLog getOperationLog()
{
org.apache.hadoop.hive.ql.session.OperationLog v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.ql.session.OperationLog operationLog>;
return v;
}
protected final org.apache.hive.service.cli.OperationState setState(org.apache.hive.service.cli.OperationState) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hadoop.hive.common.metrics.common.MetricsScope v, v;
org.apache.hive.service.cli.OperationState v, v, v, v, v, v;
long v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v := @parameter: org.apache.hive.service.cli.OperationState;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationState state>;
virtualinvoke v.<org.apache.hive.service.cli.OperationState: void validateTransition(org.apache.hive.service.cli.OperationState)>(v);
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationState state>;
v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationState state> = v;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.common.metrics.common.MetricsScope currentStateScope>;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationState state>;
v = virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.common.metrics.common.MetricsScope updateOperationStateMetrics(org.apache.hadoop.hive.common.metrics.common.MetricsScope,java.lang.String,java.lang.String,org.apache.hive.service.cli.OperationState)>(v, "hs2_operation_", "hs2_completed_operation_", v);
v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.common.metrics.common.MetricsScope currentStateScope> = v;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationState state>;
virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: void onNewState(org.apache.hive.service.cli.OperationState,org.apache.hive.service.cli.OperationState)>(v, v);
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v.<org.apache.hive.service.cli.operation.Operation: long lastAccessTime> = v;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationState state>;
return v;
}
public boolean isTimedOut(long)
{
org.apache.hive.service.cli.OperationState v;
long v, v, v, v, v, v, v, v, v, v;
org.apache.hive.service.cli.operation.Operation v;
byte v, v, v, v;
boolean v, v, v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v := @parameter: long;
v = v.<org.apache.hive.service.cli.operation.Operation: long operationTimeout>;
v = v cmp 0L;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.hive.service.cli.operation.Operation: long operationTimeout>;
v = v cmp 0L;
if v <= 0 goto label;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationState state>;
v = virtualinvoke v.<org.apache.hive.service.cli.OperationState: boolean isTerminal()>();
if v == 0 goto label;
v = v.<org.apache.hive.service.cli.operation.Operation: long lastAccessTime>;
v = v.<org.apache.hive.service.cli.operation.Operation: long operationTimeout>;
v = v + v;
v = v cmp v;
if v > 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
label:
v = v.<org.apache.hive.service.cli.operation.Operation: long lastAccessTime>;
v = v.<org.apache.hive.service.cli.operation.Operation: long operationTimeout>;
v = neg v;
v = v + v;
v = v cmp v;
if v > 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public long getLastAccessTime()
{
long v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: long lastAccessTime>;
return v;
}
public long getOperationTimeout()
{
long v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: long operationTimeout>;
return v;
}
public void setOperationTimeout(long)
{
long v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v := @parameter: long;
v.<org.apache.hive.service.cli.operation.Operation: long operationTimeout> = v;
return;
}
public long getNumModifiedRows()
{
long v;
org.apache.hadoop.hive.ql.QueryState v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.ql.QueryState queryState>;
v = virtualinvoke v.<org.apache.hadoop.hive.ql.QueryState: long getNumModifiedRows()>();
return v;
}
protected void setOperationException(org.apache.hive.service.cli.HiveSQLException)
{
org.apache.hive.service.cli.HiveSQLException v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v := @parameter: org.apache.hive.service.cli.HiveSQLException;
v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.HiveSQLException operationException> = v;
return;
}
protected final void assertState(java.util.Collection) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.HiveSQLException v;
org.apache.hive.service.cli.OperationState v, v;
java.util.Collection v;
long v;
org.apache.hive.service.cli.operation.Operation v;
java.lang.String v;
boolean v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v := @parameter: java.util.Collection;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationState state>;
v = interfaceinvoke v.<java.util.Collection: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
v = new org.apache.hive.service.cli.HiveSQLException;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationState state>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.Collection,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[])>("Expected states: \u, but found \u0001");
specialinvoke v.<org.apache.hive.service.cli.HiveSQLException: void <init>(java.lang.String)>(v);
throw v;
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v.<org.apache.hive.service.cli.operation.Operation: long lastAccessTime> = v;
return;
}
public boolean isDone()
{
org.apache.hive.service.cli.OperationState v;
org.apache.hive.service.cli.operation.Operation v;
boolean v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationState state>;
v = virtualinvoke v.<org.apache.hive.service.cli.OperationState: boolean isTerminal()>();
return v;
}
public boolean waitToTerminate(long) throws java.lang.InterruptedException
{
java.util.concurrent.TimeUnit v;
java.util.concurrent.CountDownLatch v;
long v;
org.apache.hive.service.cli.operation.Operation v;
boolean v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v := @parameter: long;
v = v.<org.apache.hive.service.cli.operation.Operation: java.util.concurrent.CountDownLatch opTerminateMonitorLatch>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(v, v);
return v;
}
protected void createOperationLog()
{
org.apache.hadoop.hive.conf.HiveConf v;
org.apache.hive.service.cli.operation.Operation v;
java.io.File v, v;
org.apache.hive.service.cli.session.HiveSession v, v, v;
org.apache.hadoop.hive.ql.session.OperationLog v;
java.lang.String v, v;
org.apache.hadoop.hive.ql.QueryState v;
org.apache.hive.service.cli.OperationHandle v;
boolean v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.session.HiveSession parentSession>;
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: boolean isOperationLogEnabled()>();
if v == 0 goto label;
v = new java.io.File;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.session.HiveSession parentSession>;
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: java.io.File getOperationLogSessionDir()>();
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.ql.QueryState queryState>;
v = virtualinvoke v.<org.apache.hadoop.hive.ql.QueryState: java.lang.String getQueryId()>();
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, v);
v = new org.apache.hadoop.hive.ql.session.OperationLog;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationHandle opHandle>;
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: java.lang.String toString()>();
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.session.HiveSession parentSession>;
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: org.apache.hadoop.hive.conf.HiveConf getHiveConf()>();
specialinvoke v.<org.apache.hadoop.hive.ql.session.OperationLog: void <init>(java.lang.String,java.io.File,org.apache.hadoop.hive.conf.HiveConf)>(v, v, v);
v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.ql.session.OperationLog operationLog> = v;
v.<org.apache.hive.service.cli.operation.Operation: boolean isOperationLogEnabled> = 1;
label:
return;
}
protected void beforeRun()
{
java.lang.Object[] v;
org.apache.hive.service.cli.OperationType v;
long v, v;
org.apache.hive.service.cli.operation.Operation v;
java.lang.Long v, v;
java.lang.String v, v, v, v, v;
org.apache.hadoop.hive.ql.QueryState v, v, v;
boolean v;
org.apache.hadoop.hive.shims.HadoopShims v;
org.slf4j.Logger v;
org.apache.hadoop.hive.conf.HiveConf v;
org.apache.hadoop.hive.ql.session.SessionState v;
org.apache.hive.service.cli.session.HiveSession v, v, v, v;
org.apache.hive.service.cli.OperationHandle v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = staticinvoke <org.apache.hadoop.hive.shims.ShimLoader: org.apache.hadoop.hive.shims.HadoopShims getHadoopShims()>();
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.ql.QueryState queryState>;
v = virtualinvoke v.<org.apache.hadoop.hive.ql.QueryState: java.lang.String getQueryId()>();
interfaceinvoke v.<org.apache.hadoop.hive.shims.HadoopShims: void setHadoopQueryContext(java.lang.String)>(v);
v = v.<org.apache.hive.service.cli.operation.Operation: boolean embedded>;
if v != 0 goto label;
virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: void createOperationLog()>();
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.ql.QueryState queryState>;
v = virtualinvoke v.<org.apache.hadoop.hive.ql.QueryState: org.apache.hadoop.hive.conf.HiveConf getConf()>();
staticinvoke <org.apache.hadoop.hive.common.LogUtils: void registerLoggingContext(org.apache.hadoop.conf.Configuration)>(v);
label:
v = v.<org.apache.hive.service.cli.operation.Operation: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[7];
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationHandle opHandle>;
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.cli.OperationType getOperationType()>();
v[0] = v;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.ql.QueryState queryState>;
v = virtualinvoke v.<org.apache.hadoop.hive.ql.QueryState: java.lang.String getQueryId()>();
v[1] = v;
v = v.<org.apache.hive.service.cli.operation.Operation: long beginTime>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[2] = v;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.session.HiveSession parentSession>;
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: org.apache.hadoop.hive.ql.session.SessionState getSessionState()>();
v = virtualinvoke v.<org.apache.hadoop.hive.ql.session.SessionState: java.lang.String getSessionId()>();
v[3] = v;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.session.HiveSession parentSession>;
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: long getCreationTime()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[4] = v;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.session.HiveSession parentSession>;
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: java.lang.String getUserName()>();
v[5] = v;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.session.HiveSession parentSession>;
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: java.lang.String getIpAddress()>();
v[6] = v;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object[])>("[opType={}, queryId={}, startTime={}, sessionId={}, createTime={}, userName={}, ipAddress={}]", v);
return;
}
protected void afterRun()
{
org.apache.hadoop.hive.shims.HadoopShims v;
java.lang.String v;
org.apache.hadoop.hive.ql.session.SessionState v;
org.apache.hive.service.cli.operation.Operation v;
boolean v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: boolean embedded>;
if v != 0 goto label;
staticinvoke <org.apache.hadoop.hive.common.LogUtils: void unregisterLoggingContext()>();
label:
v = staticinvoke <org.apache.hadoop.hive.shims.ShimLoader: org.apache.hadoop.hive.shims.HadoopShims getHadoopShims()>();
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.session.HiveSession parentSession>;
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: org.apache.hadoop.hive.ql.session.SessionState getSessionState()>();
v = virtualinvoke v.<org.apache.hadoop.hive.ql.session.SessionState: java.lang.String getSessionId()>();
interfaceinvoke v.<org.apache.hadoop.hive.shims.HadoopShims: void setHadoopSessionContext(java.lang.String)>(v);
return;
}
protected abstract void runInternal() throws org.apache.hive.service.cli.HiveSQLException;
public void run() throws org.apache.hive.service.cli.HiveSQLException
{
java.lang.Throwable v;
org.apache.hadoop.hive.common.metrics.common.Metrics v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: void beforeRun()>();
label:
v = staticinvoke <org.apache.hadoop.hive.common.metrics.common.MetricsFactory: org.apache.hadoop.hive.common.metrics.common.Metrics getInstance()>();
if v == null goto label;
interfaceinvoke v.<org.apache.hadoop.hive.common.metrics.common.Metrics: java.lang.Long incrementCounter(java.lang.String)>("open_operations");
label:
virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: void runInternal()>();
label:
virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: void afterRun()>();
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: void afterRun()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
protected synchronized void cleanupOperationLog(long)
{
long v;
org.apache.hive.service.cli.operation.Operation v;
byte v;
org.apache.hive.service.cli.HandleIdentifier v;
java.util.concurrent.ScheduledExecutorService v;
java.lang.String v;
boolean v;
org.slf4j.Logger v, v, v;
java.util.concurrent.TimeUnit v;
org.apache.hadoop.hive.ql.session.OperationLog v, v, v, v;
org.apache.hive.service.cli.operation.Operation$OperationLogCleaner v;
org.apache.hive.service.cli.OperationHandle v, v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v := @parameter: long;
v = v.<org.apache.hive.service.cli.operation.Operation: boolean isOperationLogEnabled>;
if v == 0 goto label;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationHandle opHandle>;
if v != null goto label;
v = v.<org.apache.hive.service.cli.operation.Operation: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>("Operation seems to be in invalid state, opHandle is null");
return;
label:
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.ql.session.OperationLog operationLog>;
if v != null goto label;
v = v.<org.apache.hive.service.cli.operation.Operation: org.slf4j.Logger log>;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationHandle opHandle>;
v = virtualinvoke v.<org.apache.hive.service.cli.OperationHandle: org.apache.hive.service.cli.HandleIdentifier getHandleIdentifier()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.service.cli.HandleIdentifier)>(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 ] logging is enabled, but its OperationLog object cannot be found. Perhaps the operation has already terminated.");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
goto label;
label:
v = v cmp 0L;
if v <= 0 goto label;
v = staticinvoke <java.util.concurrent.Executors: java.util.concurrent.ScheduledExecutorService newScheduledThreadPool(int)>(1);
v = new org.apache.hive.service.cli.operation.Operation$OperationLogCleaner;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.ql.session.OperationLog operationLog>;
specialinvoke v.<org.apache.hive.service.cli.operation.Operation$OperationLogCleaner: void <init>(org.apache.hive.service.cli.operation.Operation,org.apache.hadoop.hive.ql.session.OperationLog)>(v, v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
interfaceinvoke v.<java.util.concurrent.ScheduledExecutorService: java.util.concurrent.ScheduledFuture schedule(java.lang.Runnable,long,java.util.concurrent.TimeUnit)>(v, v, v);
interfaceinvoke v.<java.util.concurrent.ScheduledExecutorService: void shutdown()>();
goto label;
label:
v = v.<org.apache.hive.service.cli.operation.Operation: org.slf4j.Logger log>;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.ql.session.OperationLog operationLog>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Closing operation log {} without delay", v);
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.ql.session.OperationLog operationLog>;
virtualinvoke v.<org.apache.hadoop.hive.ql.session.OperationLog: void close()>();
staticinvoke <org.apache.hive.service.cli.operation.OperationLogManager: void closeOperation(org.apache.hive.service.cli.operation.Operation)>(v);
label:
return;
}
public abstract void cancel(org.apache.hive.service.cli.OperationState) throws org.apache.hive.service.cli.HiveSQLException;
public abstract void close() throws org.apache.hive.service.cli.HiveSQLException;
public abstract org.apache.hive.service.cli.TableSchema getResultSetSchema() throws org.apache.hive.service.cli.HiveSQLException;
public abstract org.apache.hive.service.cli.RowSet getNextRowSet(org.apache.hive.service.cli.FetchOrientation, long) throws org.apache.hive.service.cli.HiveSQLException;
public java.lang.String getTaskStatus() throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
return null;
}
protected void validateDefaultFetchOrientation(org.apache.hive.service.cli.FetchOrientation) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.FetchOrientation v;
org.apache.hive.service.cli.operation.Operation v;
java.util.EnumSet v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v := @parameter: org.apache.hive.service.cli.FetchOrientation;
v = <org.apache.hive.service.cli.operation.Operation: java.util.EnumSet DEFAULT_FETCH_ORIENTATION_SET>;
virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: void validateFetchOrientation(org.apache.hive.service.cli.FetchOrientation,java.util.EnumSet)>(v, v);
return;
}
protected void validateFetchOrientation(org.apache.hive.service.cli.FetchOrientation, java.util.EnumSet) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.HiveSQLException v;
org.apache.hive.service.cli.FetchOrientation v;
java.lang.String v, v;
org.apache.hive.service.cli.operation.Operation v;
java.util.EnumSet v;
boolean v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v := @parameter: org.apache.hive.service.cli.FetchOrientation;
v := @parameter: java.util.EnumSet;
v = virtualinvoke v.<java.util.EnumSet: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
v = new org.apache.hive.service.cli.HiveSQLException;
v = virtualinvoke v.<org.apache.hive.service.cli.FetchOrientation: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("The fetch type \u is not supported for this resultset");
specialinvoke v.<org.apache.hive.service.cli.HiveSQLException: void <init>(java.lang.String,java.lang.String)>(v, "HY106");
throw v;
label:
return;
}
protected org.apache.hive.service.cli.HiveSQLException toSQLException(java.lang.String, org.apache.hadoop.hive.ql.processors.CommandProcessorException)
{
java.lang.Throwable v, v;
org.apache.hive.service.cli.HiveSQLException v;
org.apache.hive.service.cli.operation.Operation v;
org.apache.hadoop.hive.ql.processors.CommandProcessorException v;
int v;
java.lang.String v, v, v, v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hadoop.hive.ql.processors.CommandProcessorException;
v = new org.apache.hive.service.cli.HiveSQLException;
v = virtualinvoke v.<org.apache.hadoop.hive.ql.processors.CommandProcessorException: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,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[])>("\u0001: \u0001");
v = virtualinvoke v.<org.apache.hadoop.hive.ql.processors.CommandProcessorException: java.lang.String getSqlState()>();
v = virtualinvoke v.<org.apache.hadoop.hive.ql.processors.CommandProcessorException: int getResponseCode()>();
specialinvoke v.<org.apache.hive.service.cli.HiveSQLException: void <init>(java.lang.String,java.lang.String,int)>(v, v, v);
v = virtualinvoke v.<org.apache.hadoop.hive.ql.processors.CommandProcessorException: java.lang.Throwable getCause()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.hadoop.hive.ql.processors.CommandProcessorException: java.lang.Throwable getCause()>();
virtualinvoke v.<org.apache.hive.service.cli.HiveSQLException: java.lang.Throwable initCause(java.lang.Throwable)>(v);
label:
return v;
}
protected final org.apache.hadoop.hive.common.metrics.common.MetricsScope updateOperationStateMetrics(org.apache.hadoop.hive.common.metrics.common.MetricsScope, java.lang.String, java.lang.String, org.apache.hive.service.cli.OperationState)
{
org.apache.hadoop.hive.common.metrics.common.Metrics v;
org.apache.hadoop.hive.common.metrics.common.MetricsScope v;
org.apache.hive.service.cli.OperationState v;
java.util.Set v, v;
org.apache.hive.service.cli.operation.Operation v;
java.lang.String v, v, v, v;
boolean v, v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v := @parameter: org.apache.hadoop.hive.common.metrics.common.MetricsScope;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hive.service.cli.OperationState;
v = staticinvoke <org.apache.hadoop.hive.common.metrics.common.MetricsFactory: org.apache.hadoop.hive.common.metrics.common.Metrics getInstance()>();
if v == null goto label;
if v == null goto label;
interfaceinvoke v.<org.apache.hadoop.hive.common.metrics.common.Metrics: void endScope(org.apache.hadoop.hive.common.metrics.common.MetricsScope)>(v);
v = null;
label:
v = <org.apache.hive.service.cli.operation.Operation: java.util.Set scopeStates>;
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,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[])>("api_\u0001\u0001");
v = interfaceinvoke v.<org.apache.hadoop.hive.common.metrics.common.Metrics: org.apache.hadoop.hive.common.metrics.common.MetricsScope createScope(java.lang.String)>(v);
label:
v = <org.apache.hive.service.cli.operation.Operation: java.util.Set terminalStates>;
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,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\u0001");
interfaceinvoke v.<org.apache.hadoop.hive.common.metrics.common.Metrics: java.lang.Long incrementCounter(java.lang.String)>(v);
label:
return v;
}
public long getBeginTime()
{
long v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: long beginTime>;
return v;
}
protected org.apache.hive.service.cli.OperationState getState()
{
org.apache.hive.service.cli.OperationState v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.OperationState state>;
return v;
}
protected void onNewState(org.apache.hive.service.cli.OperationState, org.apache.hive.service.cli.OperationState)
{
org.apache.hive.service.cli.OperationState v, v;
org.apache.hive.service.cli.operation.Operation v;
java.util.concurrent.CountDownLatch v;
int[] v;
int v, v;
boolean v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v := @parameter: org.apache.hive.service.cli.OperationState;
v := @parameter: org.apache.hive.service.cli.OperationState;
v = <org.apache.hive.service.cli.operation.Operation$1: int[] $SwitchMap$org$apache$hive$service$cli$OperationState>;
v = virtualinvoke v.<org.apache.hive.service.cli.OperationState: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
default: goto label;
};
label:
virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: void markOperationStartTime()>();
goto label;
label:
virtualinvoke v.<org.apache.hive.service.cli.operation.Operation: void markOperationCompletedTime()>();
label:
v = virtualinvoke v.<org.apache.hive.service.cli.OperationState: boolean isTerminal()>();
if v == 0 goto label;
v = v.<org.apache.hive.service.cli.operation.Operation: java.util.concurrent.CountDownLatch opTerminateMonitorLatch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
label:
return;
}
public long getOperationComplete()
{
long v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: long operationComplete>;
return v;
}
public long getOperationStart()
{
long v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: long operationStart>;
return v;
}
protected void markOperationStartTime()
{
long v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v.<org.apache.hive.service.cli.operation.Operation: long operationStart> = v;
return;
}
protected void markOperationCompletedTime()
{
long v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v.<org.apache.hive.service.cli.operation.Operation: long operationComplete> = v;
return;
}
public java.lang.String getQueryTag()
{
java.lang.String v;
org.apache.hadoop.hive.ql.QueryState v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.ql.QueryState queryState>;
v = virtualinvoke v.<org.apache.hadoop.hive.ql.QueryState: java.lang.String getQueryTag()>();
return v;
}
public java.lang.String getQueryId()
{
java.lang.String v;
org.apache.hadoop.hive.ql.QueryState v;
org.apache.hive.service.cli.operation.Operation v;
v := @this: org.apache.hive.service.cli.operation.Operation;
v = v.<org.apache.hive.service.cli.operation.Operation: org.apache.hadoop.hive.ql.QueryState queryState>;
v = virtualinvoke v.<org.apache.hadoop.hive.ql.QueryState: java.lang.String getQueryId()>();
return v;
}
static void <clinit>()
{
org.apache.hive.service.cli.OperationState v, v, v, v, v, v, v, v;
org.apache.hive.service.cli.OperationState[] v, v;
org.apache.hive.service.cli.FetchOrientation v, v, v;
java.util.EnumSet v;
com.google.common.collect.ImmutableSet v, v;
v = <org.apache.hive.service.cli.FetchOrientation: org.apache.hive.service.cli.FetchOrientation FETCH_NEXT>;
<org.apache.hive.service.cli.operation.Operation: org.apache.hive.service.cli.FetchOrientation DEFAULT_FETCH_ORIENTATION> = v;
v = <org.apache.hive.service.cli.FetchOrientation: org.apache.hive.service.cli.FetchOrientation FETCH_NEXT>;
v = <org.apache.hive.service.cli.FetchOrientation: org.apache.hive.service.cli.FetchOrientation FETCH_FIRST>;
v = staticinvoke <java.util.EnumSet: java.util.EnumSet of(java.lang.Enum,java.lang.Enum)>(v, v);
<org.apache.hive.service.cli.operation.Operation: java.util.EnumSet DEFAULT_FETCH_ORIENTATION_SET> = v;
v = <org.apache.hive.service.cli.OperationState: org.apache.hive.service.cli.OperationState INITIALIZED>;
v = newarray (org.apache.hive.service.cli.OperationState)[2];
v = <org.apache.hive.service.cli.OperationState: org.apache.hive.service.cli.OperationState PENDING>;
v[0] = v;
v = <org.apache.hive.service.cli.OperationState: org.apache.hive.service.cli.OperationState RUNNING>;
v[1] = v;
v = staticinvoke <com.google.common.collect.Sets: com.google.common.collect.ImmutableSet immutableEnumSet(java.lang.Enum,java.lang.Enum[])>(v, v);
<org.apache.hive.service.cli.operation.Operation: java.util.Set scopeStates> = v;
v = <org.apache.hive.service.cli.OperationState: org.apache.hive.service.cli.OperationState CLOSED>;
v = newarray (org.apache.hive.service.cli.OperationState)[4];
v = <org.apache.hive.service.cli.OperationState: org.apache.hive.service.cli.OperationState CANCELED>;
v[0] = v;
v = <org.apache.hive.service.cli.OperationState: org.apache.hive.service.cli.OperationState FINISHED>;
v[1] = v;
v = <org.apache.hive.service.cli.OperationState: org.apache.hive.service.cli.OperationState ERROR>;
v[2] = v;
v = <org.apache.hive.service.cli.OperationState: org.apache.hive.service.cli.OperationState UNKNOWN>;
v[3] = v;
v = staticinvoke <com.google.common.collect.Sets: com.google.common.collect.ImmutableSet immutableEnumSet(java.lang.Enum,java.lang.Enum[])>(v, v);
<org.apache.hive.service.cli.operation.Operation: java.util.Set terminalStates> = v;
return;
}
}