public class org.apache.hive.service.cli.operation.HiveCommandOperation extends org.apache.hive.service.cli.operation.ExecuteStatementOperation
{
private final org.apache.hadoop.hive.ql.processors.CommandProcessor commandProcessor;
private org.apache.hive.service.cli.TableSchema resultSchema;
private java.io.BufferedReader resultReader;
protected void <init>(org.apache.hive.service.cli.session.HiveSession, java.lang.String, org.apache.hadoop.hive.ql.processors.CommandProcessor, java.util.Map)
{
java.util.Map v;
org.apache.hive.service.cli.operation.HiveCommandOperation v;
java.lang.String v;
org.apache.hadoop.hive.ql.session.SessionState v;
org.apache.hadoop.hive.ql.processors.CommandProcessor v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.HiveCommandOperation;
v := @parameter: org.apache.hive.service.cli.session.HiveSession;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hadoop.hive.ql.processors.CommandProcessor;
v := @parameter: java.util.Map;
specialinvoke v.<org.apache.hive.service.cli.operation.ExecuteStatementOperation: void <init>(org.apache.hive.service.cli.session.HiveSession,java.lang.String,java.util.Map)>(v, v, v);
v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.apache.hive.service.cli.TableSchema resultSchema> = null;
v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.apache.hadoop.hive.ql.processors.CommandProcessor commandProcessor> = v;
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: org.apache.hadoop.hive.ql.session.SessionState getSessionState()>();
specialinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: void setupSessionIO(org.apache.hadoop.hive.ql.session.SessionState)>(v);
return;
}
private void setupSessionIO(org.apache.hadoop.hive.ql.session.SessionState)
{
org.apache.hadoop.hive.ql.session.SessionState v, v, v;
org.apache.hive.service.cli.session.HiveSession v, v;
java.io.UnsupportedEncodingException v;
java.lang.Object[] v;
java.nio.charset.Charset v, v, v, v;
org.apache.hadoop.hive.common.io.SessionStream v, v, v, v, v, v;
org.apache.hive.service.cli.operation.HiveCommandOperation v;
java.lang.String v, v, v, v, v;
java.io.PrintStream v, v;
org.slf4j.Logger v, v, v, v;
java.io.FileOutputStream v, v;
java.io.IOException v;
java.io.File v, v, v, v;
v := @this: org.apache.hive.service.cli.operation.HiveCommandOperation;
v := @parameter: org.apache.hadoop.hive.ql.session.SessionState;
label:
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.slf4j.Logger log>;
v = virtualinvoke v.<org.apache.hadoop.hive.ql.session.SessionState: java.io.File getTmpOutputFile()>();
v = virtualinvoke v.<org.apache.hadoop.hive.ql.session.SessionState: java.io.File getTmpErrOutputFile()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.io.File,java.io.File)>(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[])>("Putting temp output to file \u and error output to file \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
v.<org.apache.hadoop.hive.ql.session.SessionState: java.io.InputStream in> = null;
v = new org.apache.hadoop.hive.common.io.SessionStream;
v = new java.io.FileOutputStream;
v = virtualinvoke v.<org.apache.hadoop.hive.ql.session.SessionState: java.io.File getTmpOutputFile()>();
specialinvoke v.<java.io.FileOutputStream: void <init>(java.io.File)>(v);
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.nio.charset.Charset: java.lang.String name()>();
specialinvoke v.<org.apache.hadoop.hive.common.io.SessionStream: void <init>(java.io.OutputStream,boolean,java.lang.String)>(v, 1, v);
v.<org.apache.hadoop.hive.ql.session.SessionState: org.apache.hadoop.hive.common.io.SessionStream out> = v;
v = new org.apache.hadoop.hive.common.io.SessionStream;
v = new java.io.FileOutputStream;
v = virtualinvoke v.<org.apache.hadoop.hive.ql.session.SessionState: java.io.File getTmpErrOutputFile()>();
specialinvoke v.<java.io.FileOutputStream: void <init>(java.io.File)>(v);
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.nio.charset.Charset: java.lang.String name()>();
specialinvoke v.<org.apache.hadoop.hive.common.io.SessionStream: void <init>(java.io.OutputStream,boolean,java.lang.String)>(v, 1, v);
v.<org.apache.hadoop.hive.ql.session.SessionState: org.apache.hadoop.hive.common.io.SessionStream err> = v;
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Error in creating temp output file", v);
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.slf4j.Logger log>;
v = newarray (java.io.Closeable)[2];
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: 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 = v.<org.apache.hadoop.hive.ql.session.SessionState: org.apache.hadoop.hive.common.io.SessionStream out>;
v[0] = v;
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: 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 = v.<org.apache.hadoop.hive.ql.session.SessionState: org.apache.hadoop.hive.common.io.SessionStream err>;
v[1] = v;
staticinvoke <org.apache.hive.service.ServiceUtils: void cleanup(org.slf4j.Logger,java.io.Closeable[])>(v, v);
label:
v.<org.apache.hadoop.hive.ql.session.SessionState: java.io.InputStream in> = null;
v = new org.apache.hadoop.hive.common.io.SessionStream;
v = <java.lang.System: java.io.PrintStream out>;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.nio.charset.Charset: java.lang.String name()>();
specialinvoke v.<org.apache.hadoop.hive.common.io.SessionStream: void <init>(java.io.OutputStream,boolean,java.lang.String)>(v, 1, v);
v.<org.apache.hadoop.hive.ql.session.SessionState: org.apache.hadoop.hive.common.io.SessionStream out> = v;
v = new org.apache.hadoop.hive.common.io.SessionStream;
v = <java.lang.System: java.io.PrintStream err>;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.nio.charset.Charset: java.lang.String name()>();
specialinvoke v.<org.apache.hadoop.hive.common.io.SessionStream: void <init>(java.io.OutputStream,boolean,java.lang.String)>(v, 1, v);
v.<org.apache.hadoop.hive.ql.session.SessionState: org.apache.hadoop.hive.common.io.SessionStream err> = v;
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Error creating PrintStream", v);
v.<org.apache.hadoop.hive.ql.session.SessionState: org.apache.hadoop.hive.common.io.SessionStream out> = null;
v.<org.apache.hadoop.hive.ql.session.SessionState: org.apache.hadoop.hive.common.io.SessionStream err> = null;
label:
return;
catch java.io.IOException from label to label with label;
catch java.io.UnsupportedEncodingException from label to label with label;
}
private void tearDownSessionIO()
{
java.lang.Object[] v;
org.slf4j.Logger v;
org.apache.hadoop.hive.ql.session.SessionState v, v;
org.apache.hive.service.cli.session.HiveSession v, v;
org.apache.hadoop.hive.common.io.SessionStream v, v;
org.apache.hive.service.cli.operation.HiveCommandOperation v;
v := @this: org.apache.hive.service.cli.operation.HiveCommandOperation;
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.slf4j.Logger log>;
v = newarray (java.io.Closeable)[2];
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: 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 = v.<org.apache.hadoop.hive.ql.session.SessionState: org.apache.hadoop.hive.common.io.SessionStream out>;
v[0] = v;
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: 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 = v.<org.apache.hadoop.hive.ql.session.SessionState: org.apache.hadoop.hive.common.io.SessionStream err>;
v[1] = v;
staticinvoke <org.apache.hive.service.ServiceUtils: void cleanup(org.slf4j.Logger,java.io.Closeable[])>(v, v);
return;
}
public void runInternal() throws org.apache.hive.service.cli.HiveSQLException
{
java.lang.Throwable v;
org.apache.hive.service.cli.OperationState v, v, v, v;
org.apache.hive.service.cli.TableSchema v, v;
org.apache.hadoop.hive.metastore.api.Schema v;
java.lang.String[] v;
int v;
org.apache.hive.service.cli.operation.HiveCommandOperation v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.apache.hive.service.cli.HiveSQLException v, v;
org.slf4j.Logger v;
java.lang.Exception v;
org.apache.hadoop.hive.ql.processors.CommandProcessor v;
org.apache.hadoop.hive.ql.processors.CommandProcessorResponse v;
v := @this: org.apache.hive.service.cli.operation.HiveCommandOperation;
v = <org.apache.hive.service.cli.OperationState: org.apache.hive.service.cli.OperationState RUNNING>;
virtualinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.apache.hive.service.cli.OperationState setState(org.apache.hive.service.cli.OperationState)>(v);
label:
v = virtualinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: java.lang.String getStatement()>();
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>("\\s");
v = v[0];
v = virtualinvoke v.<java.lang.String: int length()>();
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int)>(v);
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.apache.hadoop.hive.ql.processors.CommandProcessor commandProcessor>;
v = interfaceinvoke v.<org.apache.hadoop.hive.ql.processors.CommandProcessor: org.apache.hadoop.hive.ql.processors.CommandProcessorResponse run(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.hadoop.hive.ql.processors.CommandProcessorResponse: org.apache.hadoop.hive.metastore.api.Schema getSchema()>();
if v == null goto label;
virtualinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: void setHasResultSet(boolean)>(1);
v = new org.apache.hive.service.cli.TableSchema;
specialinvoke v.<org.apache.hive.service.cli.TableSchema: void <init>(org.apache.hadoop.hive.metastore.api.Schema)>(v);
v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.apache.hive.service.cli.TableSchema resultSchema> = v;
goto label;
label:
virtualinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: void setHasResultSet(boolean)>(0);
v = new org.apache.hive.service.cli.TableSchema;
specialinvoke v.<org.apache.hive.service.cli.TableSchema: void <init>()>();
v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.apache.hive.service.cli.TableSchema resultSchema> = v;
label:
v = virtualinvoke v.<org.apache.hadoop.hive.ql.processors.CommandProcessorResponse: java.lang.String getMessage()>();
if v == null goto label;
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.slf4j.Logger log>;
v = virtualinvoke v.<org.apache.hadoop.hive.ql.processors.CommandProcessorResponse: java.lang.String getMessage()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.OperationState: org.apache.hive.service.cli.OperationState ERROR>;
virtualinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.apache.hive.service.cli.OperationState setState(org.apache.hive.service.cli.OperationState)>(v);
v = virtualinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.apache.hive.service.cli.HiveSQLException toSQLException(java.lang.String,org.apache.hadoop.hive.ql.processors.CommandProcessorException)>("Error while processing statement", v);
throw v;
label:
v := @caughtexception;
v = <org.apache.hive.service.cli.OperationState: org.apache.hive.service.cli.OperationState ERROR>;
virtualinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.apache.hive.service.cli.OperationState setState(org.apache.hive.service.cli.OperationState)>(v);
v = new org.apache.hive.service.cli.HiveSQLException;
v = virtualinvoke v.<java.lang.Exception: 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[])>("Error running query: \u0001");
specialinvoke v.<org.apache.hive.service.cli.HiveSQLException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v = <org.apache.hive.service.cli.OperationState: org.apache.hive.service.cli.OperationState FINISHED>;
virtualinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.apache.hive.service.cli.OperationState setState(org.apache.hive.service.cli.OperationState)>(v);
return;
catch org.apache.hadoop.hive.ql.processors.CommandProcessorException from label to label with label;
catch java.lang.Exception from label to label with label;
}
public void close() throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.operation.HiveCommandOperation v;
org.apache.hive.service.cli.OperationState v;
v := @this: org.apache.hive.service.cli.operation.HiveCommandOperation;
v = <org.apache.hive.service.cli.OperationState: org.apache.hive.service.cli.OperationState CLOSED>;
virtualinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.apache.hive.service.cli.OperationState setState(org.apache.hive.service.cli.OperationState)>(v);
specialinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: void tearDownSessionIO()>();
specialinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: void cleanTmpFile()>();
virtualinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: void cleanupOperationLog(long)>(0L);
return;
}
public org.apache.hive.service.cli.TableSchema getResultSetSchema() throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.operation.HiveCommandOperation v;
org.apache.hive.service.cli.TableSchema v;
v := @this: org.apache.hive.service.cli.operation.HiveCommandOperation;
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.apache.hive.service.cli.TableSchema resultSchema>;
return v;
}
public org.apache.hive.service.cli.RowSet getNextRowSet(org.apache.hive.service.cli.FetchOrientation, long) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.RowSet v;
org.apache.hive.service.cli.TableSchema v, v, v;
java.lang.String[] v, v;
long v;
org.apache.hive.service.cli.FetchOrientation v, v;
int v;
org.apache.hive.service.cli.operation.HiveCommandOperation v;
boolean v, v, v;
org.apache.hive.service.rpc.thrift.TProtocolVersion v;
java.util.Iterator v, v;
java.util.List v;
java.lang.Object v, v;
v := @this: org.apache.hive.service.cli.operation.HiveCommandOperation;
v := @parameter: org.apache.hive.service.cli.FetchOrientation;
v := @parameter: long;
virtualinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: void validateDefaultFetchOrientation(org.apache.hive.service.cli.FetchOrientation)>(v);
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;
specialinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: void resetResultReader()>();
label:
v = specialinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: java.util.List readResults(int)>(v);
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.apache.hive.service.cli.TableSchema resultSchema>;
v = virtualinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: 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 = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.apache.hive.service.cli.TableSchema resultSchema>;
if v == null goto label;
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.apache.hive.service.cli.TableSchema resultSchema>;
v = virtualinvoke v.<org.apache.hive.service.cli.TableSchema: int getSize()>();
if v <= 1 goto 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 = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>("\\t");
interfaceinvoke v.<org.apache.hive.service.cli.RowSet: org.apache.hive.service.cli.RowSet addRow(java.lang.Object[])>(v);
goto label;
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;
}
private java.util.List readResults(int) throws org.apache.hive.service.cli.HiveSQLException
{
java.util.ArrayList v;
int v, v;
org.apache.hive.service.cli.operation.HiveCommandOperation v;
java.lang.String v, v;
org.apache.hive.service.cli.HiveSQLException v, v;
java.io.IOException v;
org.apache.hadoop.hive.ql.session.SessionState v;
java.io.File v;
java.io.FileNotFoundException v;
org.apache.hive.service.cli.session.HiveSession v;
java.io.BufferedReader v, v, v;
java.io.FileReader v;
v := @this: org.apache.hive.service.cli.operation.HiveCommandOperation;
v := @parameter: int;
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: java.io.BufferedReader resultReader>;
if v != null goto label;
v = virtualinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.apache.hive.service.cli.session.HiveSession getParentSession()>();
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: org.apache.hadoop.hive.ql.session.SessionState getSessionState()>();
v = virtualinvoke v.<org.apache.hadoop.hive.ql.session.SessionState: java.io.File getTmpOutputFile()>();
label:
v = new java.io.BufferedReader;
v = new java.io.FileReader;
specialinvoke v.<java.io.FileReader: void <init>(java.io.File)>(v);
specialinvoke v.<java.io.BufferedReader: void <init>(java.io.Reader)>(v);
v.<org.apache.hive.service.cli.operation.HiveCommandOperation: java.io.BufferedReader resultReader> = v;
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.service.cli.HiveSQLException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.io.File)>(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[])>("File \u not found");
specialinvoke v.<org.apache.hive.service.cli.HiveSQLException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = 0;
label:
if v < v goto label;
if v > 0 goto label;
label:
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: java.io.BufferedReader resultReader>;
v = virtualinvoke v.<java.io.BufferedReader: java.lang.String readLine()>();
if v == null goto label;
label:
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new org.apache.hive.service.cli.HiveSQLException;
specialinvoke v.<org.apache.hive.service.cli.HiveSQLException: void <init>(java.lang.String,java.lang.Throwable)>("Unable to read line from file", v);
throw v;
label:
v = v + 1;
goto label;
label:
return v;
catch java.io.FileNotFoundException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
}
private void cleanTmpFile()
{
org.apache.hive.service.cli.operation.HiveCommandOperation v;
org.apache.hadoop.hive.ql.session.SessionState v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.HiveCommandOperation;
specialinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: void resetResultReader()>();
v = virtualinvoke v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.apache.hive.service.cli.session.HiveSession getParentSession()>();
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: org.apache.hadoop.hive.ql.session.SessionState getSessionState()>();
virtualinvoke v.<org.apache.hadoop.hive.ql.session.SessionState: void deleteTmpOutputFile()>();
virtualinvoke v.<org.apache.hadoop.hive.ql.session.SessionState: void deleteTmpErrOutputFile()>();
return;
}
private void resetResultReader()
{
org.slf4j.Logger v;
java.io.Closeable[] v;
org.apache.hive.service.cli.operation.HiveCommandOperation v;
java.io.BufferedReader v, v;
v := @this: org.apache.hive.service.cli.operation.HiveCommandOperation;
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: java.io.BufferedReader resultReader>;
if v == null goto label;
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: org.slf4j.Logger log>;
v = newarray (java.io.Closeable)[1];
v = v.<org.apache.hive.service.cli.operation.HiveCommandOperation: java.io.BufferedReader resultReader>;
v[0] = v;
staticinvoke <org.apache.hive.service.ServiceUtils: void cleanup(org.slf4j.Logger,java.io.Closeable[])>(v, v);
v.<org.apache.hive.service.cli.operation.HiveCommandOperation: java.io.BufferedReader resultReader> = null;
label:
return;
}
public void cancel(org.apache.hive.service.cli.OperationState) throws org.apache.hive.service.cli.HiveSQLException
{
java.lang.UnsupportedOperationException v;
org.apache.hive.service.cli.operation.HiveCommandOperation v;
org.apache.hive.service.cli.OperationState v;
v := @this: org.apache.hive.service.cli.operation.HiveCommandOperation;
v := @parameter: org.apache.hive.service.cli.OperationState;
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("HiveCommandOperation.cancel()");
throw v;
}
}