public class org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor extends java.lang.Object implements org.apache.hive.hplsql.executor.QueryExecutor
{
public static final java.lang.String QUERY_EXECUTOR;
public static final java.lang.String HPLSQL;
private final org.apache.hive.service.cli.session.HiveSession hiveSession;
private final long fetchSize;
public void <init>(org.apache.hive.service.cli.session.HiveSession)
{
org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor v;
org.apache.hadoop.hive.conf.HiveConf$ConfVars v;
int v;
org.apache.hadoop.hive.conf.HiveConf v;
org.apache.hive.service.cli.session.HiveSession v;
v := @this: org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor;
v := @parameter: org.apache.hive.service.cli.session.HiveSession;
specialinvoke v.<java.lang.Object: void <init>()>();
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_THRIFT_RESULTSET_DEFAULT_FETCH_SIZE>;
v = virtualinvoke v.<org.apache.hadoop.hive.conf.HiveConf: int getIntVar(org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v);
v.<org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor: long fetchSize> = v;
v.<org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor: org.apache.hive.service.cli.session.HiveSession hiveSession> = v;
return;
}
public org.apache.hive.hplsql.executor.QueryResult executeQuery(java.lang.String, org.antlr.v.runtime.ParserRuleContext)
{
org.apache.hive.service.cli.HiveSQLException v;
org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor$OperationRowResult v;
java.util.HashMap v;
java.util.function.Supplier v, v;
org.apache.hive.service.cli.session.HiveSession v;
org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor v;
org.apache.hive.hplsql.executor.QueryResult v, v;
java.lang.String v;
org.antlr.v.runtime.ParserRuleContext v;
org.apache.hive.service.cli.OperationHandle v;
v := @this: org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor;
v := @parameter: java.lang.String;
v := @parameter: org.antlr.v.runtime.ParserRuleContext;
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("QUERY_EXECUTOR", "HPLSQL");
v = v.<org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor: org.apache.hive.service.cli.session.HiveSession hiveSession>;
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: org.apache.hive.service.cli.OperationHandle executeStatement(java.lang.String,java.util.Map)>(v, v);
v = new org.apache.hive.hplsql.executor.QueryResult;
v = new org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor$OperationRowResult;
specialinvoke v.<org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor$OperationRowResult: void <init>(org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor,org.apache.hive.service.cli.OperationHandle)>(v, v);
v = staticinvoke <org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor$lambda_executeQuery_0__18: java.util.function.Supplier bootstrap$(org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor,org.apache.hive.service.cli.OperationHandle)>(v, v);
specialinvoke v.<org.apache.hive.hplsql.executor.QueryResult: void <init>(org.apache.hive.hplsql.executor.RowResult,java.util.function.Supplier,java.lang.Exception)>(v, v, null);
label:
return v;
label:
v := @caughtexception;
v = new org.apache.hive.hplsql.executor.QueryResult;
v = staticinvoke <org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor$lambda_executeQuery_1__19: java.util.function.Supplier bootstrap$()>();
specialinvoke v.<org.apache.hive.hplsql.executor.QueryResult: void <init>(org.apache.hive.hplsql.executor.RowResult,java.util.function.Supplier,java.lang.Exception)>(null, v, v);
return v;
catch org.apache.hive.service.cli.HiveSQLException from label to label with label;
}
public org.apache.hive.hplsql.executor.Metadata metadata(org.apache.hive.service.cli.OperationHandle)
{
org.apache.hive.hplsql.executor.QueryException v;
org.apache.hive.hplsql.executor.ColumnMeta v;
org.apache.hive.service.cli.TableSchema v;
java.util.ArrayList v;
org.apache.hadoop.hive.serde.thrift.Type v;
org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor v;
int v, v, v;
java.lang.String v, v;
org.apache.hive.service.cli.HiveSQLException v;
org.apache.hive.hplsql.executor.Metadata v;
org.apache.hive.service.cli.session.HiveSession v;
org.apache.hive.service.cli.ColumnDescriptor v;
org.apache.hive.service.cli.OperationHandle v;
v := @this: org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor;
v := @parameter: org.apache.hive.service.cli.OperationHandle;
label:
v = v.<org.apache.hive.service.cli.operation.hplsql.HplSqlQueryExecutor: org.apache.hive.service.cli.session.HiveSession hiveSession>;
v = interfaceinvoke v.<org.apache.hive.service.cli.session.HiveSession: org.apache.hive.service.cli.TableSchema getResultSetMetadata(org.apache.hive.service.cli.OperationHandle)>(v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = 0;
label:
v = virtualinvoke v.<org.apache.hive.service.cli.TableSchema: int getSize()>();
if v >= v goto label;
v = virtualinvoke v.<org.apache.hive.service.cli.TableSchema: org.apache.hive.service.cli.ColumnDescriptor getColumnDescriptorAt(int)>(v);
v = new org.apache.hive.hplsql.executor.ColumnMeta;
v = virtualinvoke v.<org.apache.hive.service.cli.ColumnDescriptor: java.lang.String getName()>();
v = virtualinvoke v.<org.apache.hive.service.cli.ColumnDescriptor: java.lang.String getTypeName()>();
v = virtualinvoke v.<org.apache.hive.service.cli.ColumnDescriptor: org.apache.hadoop.hive.serde.thrift.Type getType()>();
v = virtualinvoke v.<org.apache.hadoop.hive.serde.thrift.Type: int toJavaSQLType()>();
specialinvoke v.<org.apache.hive.hplsql.executor.ColumnMeta: void <init>(java.lang.String,java.lang.String,int)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = new org.apache.hive.hplsql.executor.Metadata;
specialinvoke v.<org.apache.hive.hplsql.executor.Metadata: void <init>(java.util.List)>(v);
label:
return v;
label:
v := @caughtexception;
v = new org.apache.hive.hplsql.executor.QueryException;
specialinvoke v.<org.apache.hive.hplsql.executor.QueryException: void <init>(java.lang.Throwable)>(v);
throw v;
catch org.apache.hive.service.cli.HiveSQLException from label to label with label;
}
}