public abstract class org.apache.hive.service.cli.CLIServiceClient extends java.lang.Object implements org.apache.hive.service.cli.ICLIService
{
protected int defaultFetchRows;
public void <init>(org.apache.hadoop.conf.Configuration)
{
org.apache.hadoop.hive.conf.HiveConf$ConfVars v, v;
org.apache.hadoop.conf.Configuration v;
int v, v;
org.apache.hive.service.cli.CLIServiceClient v;
v := @this: org.apache.hive.service.cli.CLIServiceClient;
v := @parameter: org.apache.hadoop.conf.Configuration;
specialinvoke v.<java.lang.Object: void <init>()>();
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_RESULTSET_DEFAULT_FETCH_SIZE>;
v = v.<org.apache.hadoop.hive.conf.HiveConf$ConfVars: int defaultIntVal>;
v.<org.apache.hive.service.cli.CLIServiceClient: int defaultFetchRows> = v;
v = <org.apache.hadoop.hive.conf.HiveConf$ConfVars: org.apache.hadoop.hive.conf.HiveConf$ConfVars HIVE_SERVER2_THRIFT_RESULTSET_DEFAULT_FETCH_SIZE>;
v = staticinvoke <org.apache.hadoop.hive.conf.HiveConf: int getIntVar(org.apache.hadoop.conf.Configuration,org.apache.hadoop.hive.conf.HiveConf$ConfVars)>(v, v);
v.<org.apache.hive.service.cli.CLIServiceClient: int defaultFetchRows> = v;
return;
}
public org.apache.hive.service.cli.SessionHandle openSession(java.lang.String, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.SessionHandle v;
java.util.Map v;
java.lang.String v, v;
org.apache.hive.service.cli.CLIServiceClient v;
v := @this: org.apache.hive.service.cli.CLIServiceClient;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = staticinvoke <java.util.Collections: java.util.Map emptyMap()>();
v = virtualinvoke v.<org.apache.hive.service.cli.CLIServiceClient: org.apache.hive.service.cli.SessionHandle openSession(java.lang.String,java.lang.String,java.util.Map)>(v, v, v);
return v;
}
public org.apache.hive.service.cli.RowSet fetchResults(org.apache.hive.service.cli.OperationHandle) throws org.apache.hive.service.cli.HiveSQLException
{
org.apache.hive.service.cli.FetchOrientation v;
org.apache.hive.service.cli.RowSet v;
int v;
org.apache.hive.service.cli.FetchType v;
org.apache.hive.service.cli.OperationHandle v;
org.apache.hive.service.cli.CLIServiceClient v;
v := @this: org.apache.hive.service.cli.CLIServiceClient;
v := @parameter: org.apache.hive.service.cli.OperationHandle;
v = <org.apache.hive.service.cli.FetchOrientation: org.apache.hive.service.cli.FetchOrientation FETCH_NEXT>;
v = v.<org.apache.hive.service.cli.CLIServiceClient: int defaultFetchRows>;
v = <org.apache.hive.service.cli.FetchType: org.apache.hive.service.cli.FetchType QUERY_OUTPUT>;
v = virtualinvoke v.<org.apache.hive.service.cli.CLIServiceClient: org.apache.hive.service.cli.RowSet fetchResults(org.apache.hive.service.cli.OperationHandle,org.apache.hive.service.cli.FetchOrientation,long,org.apache.hive.service.cli.FetchType)>(v, v, v, v);
return v;
}
public abstract java.lang.String getDelegationToken(org.apache.hive.service.cli.SessionHandle, org.apache.hive.service.auth.HiveAuthFactory, java.lang.String, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException;
public abstract void cancelDelegationToken(org.apache.hive.service.cli.SessionHandle, org.apache.hive.service.auth.HiveAuthFactory, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException;
public abstract void renewDelegationToken(org.apache.hive.service.cli.SessionHandle, org.apache.hive.service.auth.HiveAuthFactory, java.lang.String) throws org.apache.hive.service.cli.HiveSQLException;
}