public class org.apache.hive.kudu.org.apache.kudu.client.KuduClient extends java.lang.Object implements java.lang.AutoCloseable
{
private static final org.slf4j.Logger LOG;
public static final long NO_TIMESTAMP;
final org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient;
void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient)
{
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient> = v;
return;
}
public void updateLastPropagatedTimestamp(long)
{
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
long v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v := @parameter: long;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: void updateLastPropagatedTimestamp(long)>(v);
return;
}
public long getLastPropagatedTimestamp()
{
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
long v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: long getLastPropagatedTimestamp()>();
return v;
}
public boolean hasLastPropagatedTimestamp()
{
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: boolean hasLastPropagatedTimestamp()>();
return v;
}
public java.lang.String getLocationString()
{
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: java.lang.String getLocationString()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.client.HiveMetastoreConfig getHiveMetastoreConfig() throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
java.lang.Object v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.com.stumbleupon.async.Deferred getHiveMetastoreConfig()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.KuduClient: java.lang.Object joinAndHandleException(org.apache.hive.kudu.com.stumbleupon.async.Deferred)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.client.KuduTable createTable(java.lang.String, org.apache.hive.kudu.org.apache.kudu.Schema, org.apache.hive.kudu.org.apache.kudu.client.CreateTableOptions) throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.Schema v;
org.apache.hive.kudu.org.apache.kudu.client.CreateTableOptions v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.Schema;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.CreateTableOptions;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.com.stumbleupon.async.Deferred createTable(java.lang.String,org.apache.hive.kudu.org.apache.kudu.Schema,org.apache.hive.kudu.org.apache.kudu.client.CreateTableOptions)>(v, v, v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.KuduClient: java.lang.Object joinAndHandleException(org.apache.hive.kudu.com.stumbleupon.async.Deferred)>(v);
return v;
}
public boolean isCreateTableDone(java.lang.String) throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.Status v;
org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder v, v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.client.KuduException v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB: org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder newBuilder()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder: org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder setTableName(java.lang.String)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.com.stumbleupon.async.Deferred getDelayedIsCreateTableDoneDeferred(org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder,org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.client.KuduTable)>(v, null, null);
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.KuduClient: java.lang.Object joinAndHandleException(org.apache.hive.kudu.com.stumbleupon.async.Deferred)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduException: org.apache.hive.kudu.org.apache.kudu.client.Status getStatus()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Status: boolean isTimedOut()>();
if v == 0 goto label;
return 0;
label:
throw v;
label:
return 1;
catch org.apache.hive.kudu.org.apache.kudu.client.KuduException from label to label with label;
}
public org.apache.hive.kudu.org.apache.kudu.client.DeleteTableResponse deleteTable(java.lang.String) throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v := @parameter: java.lang.String;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.com.stumbleupon.async.Deferred deleteTable(java.lang.String)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.KuduClient: java.lang.Object joinAndHandleException(org.apache.hive.kudu.com.stumbleupon.async.Deferred)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.client.AlterTableResponse alterTable(java.lang.String, org.apache.hive.kudu.org.apache.kudu.client.AlterTableOptions) throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
java.lang.Object v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.client.AlterTableOptions v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v := @parameter: java.lang.String;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AlterTableOptions;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.com.stumbleupon.async.Deferred alterTable(java.lang.String,org.apache.hive.kudu.org.apache.kudu.client.AlterTableOptions)>(v, v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.KuduClient: java.lang.Object joinAndHandleException(org.apache.hive.kudu.com.stumbleupon.async.Deferred)>(v);
return v;
}
public boolean isAlterTableDone(java.lang.String) throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.Status v;
org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder v, v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.client.KuduException v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB: org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder newBuilder()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder: org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder setTableName(java.lang.String)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.com.stumbleupon.async.Deferred getDelayedIsAlterTableDoneDeferred(org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder,org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.client.AlterTableResponse)>(v, null, null);
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.KuduClient: java.lang.Object joinAndHandleException(org.apache.hive.kudu.com.stumbleupon.async.Deferred)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduException: org.apache.hive.kudu.org.apache.kudu.client.Status getStatus()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Status: boolean isTimedOut()>();
if v == 0 goto label;
return 0;
label:
throw v;
label:
return 1;
catch org.apache.hive.kudu.org.apache.kudu.client.KuduException from label to label with label;
}
public org.apache.hive.kudu.org.apache.kudu.client.ListTabletServersResponse listTabletServers() throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
java.lang.Object v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.com.stumbleupon.async.Deferred listTabletServers()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.KuduClient: java.lang.Object joinAndHandleException(org.apache.hive.kudu.com.stumbleupon.async.Deferred)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.client.ListTablesResponse getTablesList() throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.org.apache.kudu.client.ListTablesResponse v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.ListTablesResponse getTablesList(java.lang.String)>(null);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.client.ListTablesResponse getTablesList(java.lang.String) throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v := @parameter: java.lang.String;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.com.stumbleupon.async.Deferred getTablesList(java.lang.String)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.KuduClient: java.lang.Object joinAndHandleException(org.apache.hive.kudu.com.stumbleupon.async.Deferred)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.client.KuduTableStatistics getTableStatistics(java.lang.String) throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v := @parameter: java.lang.String;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.com.stumbleupon.async.Deferred getTableStatistics(java.lang.String)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.KuduClient: java.lang.Object joinAndHandleException(org.apache.hive.kudu.com.stumbleupon.async.Deferred)>(v);
return v;
}
public boolean tableExists(java.lang.String) throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
java.lang.Object v;
java.lang.String v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v := @parameter: java.lang.String;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.com.stumbleupon.async.Deferred tableExists(java.lang.String)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.KuduClient: java.lang.Object joinAndHandleException(org.apache.hive.kudu.com.stumbleupon.async.Deferred)>(v);
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
return v;
}
org.apache.hive.kudu.org.apache.kudu.client.KuduTable openTableById(java.lang.String) throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v := @parameter: java.lang.String;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.com.stumbleupon.async.Deferred openTableById(java.lang.String)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.KuduClient: java.lang.Object joinAndHandleException(org.apache.hive.kudu.com.stumbleupon.async.Deferred)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.client.KuduTable openTable(java.lang.String) throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v := @parameter: java.lang.String;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.com.stumbleupon.async.Deferred openTable(java.lang.String)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.KuduClient: java.lang.Object joinAndHandleException(org.apache.hive.kudu.com.stumbleupon.async.Deferred)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.client.KuduSession newSession()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduSession v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession newSession()>();
v = new org.apache.hive.kudu.org.apache.kudu.client.KuduSession;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduSession: void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession)>(v);
return v;
}
public boolean isStatisticsEnabled()
{
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: boolean isStatisticsEnabled()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.client.Statistics getStatistics()
{
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.Statistics v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.org.apache.kudu.client.Statistics getStatistics()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.client.KuduScanner$KuduScannerBuilder newScannerBuilder(org.apache.hive.kudu.org.apache.kudu.client.KuduTable)
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduScanner$KuduScannerBuilder v;
org.apache.hive.kudu.org.apache.kudu.client.KuduTable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduTable;
v = new org.apache.hive.kudu.org.apache.kudu.client.KuduScanner$KuduScannerBuilder;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanner$KuduScannerBuilder: void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.client.KuduTable)>(v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder newScanTokenBuilder(org.apache.hive.kudu.org.apache.kudu.client.KuduTable)
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduTable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduTable;
v = new org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.client.KuduTable)>(v, v);
return v;
}
public void close() throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduException v;
java.lang.Exception v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: void close()>();
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.KuduException: org.apache.hive.kudu.org.apache.kudu.client.KuduException transformException(java.lang.Exception)>(v);
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
public void shutdown() throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.com.stumbleupon.async.Deferred shutdown()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.KuduClient: java.lang.Object joinAndHandleException(org.apache.hive.kudu.com.stumbleupon.async.Deferred)>(v);
return;
}
public byte[] exportAuthenticationCredentials() throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
java.lang.Object v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.com.stumbleupon.async.Deferred exportAuthenticationCredentials()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.KuduClient: java.lang.Object joinAndHandleException(org.apache.hive.kudu.com.stumbleupon.async.Deferred)>(v);
return v;
}
public void importAuthenticationCredentials(byte[])
{
byte[] v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v := @parameter: byte[];
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: void importAuthenticationCredentials(byte[])>(v);
return;
}
public long getDefaultOperationTimeoutMs()
{
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
long v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: long getDefaultOperationTimeoutMs()>();
return v;
}
public long getDefaultAdminOperationTimeoutMs()
{
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
long v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: long getDefaultAdminOperationTimeoutMs()>();
return v;
}
public java.lang.String getMasterAddressesAsString()
{
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: java.lang.String getMasterAddressesAsString()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.client.HostAndPort findLeaderMasterServer() throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v, v;
org.apache.hive.kudu.org.apache.kudu.client.KuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.TableLocationsCache$Entry v;
org.apache.hive.kudu.org.apache.kudu.client.HostAndPort v;
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduClient;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.org.apache.kudu.client.TableLocationsCache$Entry getTableLocationEntry(java.lang.String,byte[])>("Kudu Master", null);
if v != null goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.ListTabletServersResponse listTabletServers()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient asyncClient>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.org.apache.kudu.client.TableLocationsCache$Entry getTableLocationEntry(java.lang.String,byte[])>("Kudu Master", null);
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.TableLocationsCache$Entry: boolean isNonCoveredRange()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: void checkState(boolean)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.TableLocationsCache$Entry: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet getTablet()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet: org.apache.hive.kudu.org.apache.kudu.client.ServerInfo getLeaderServerInfo()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.ServerInfo: org.apache.hive.kudu.org.apache.kudu.client.HostAndPort getHostAndPort()>();
return v;
}
static java.lang.Object joinAndHandleException(org.apache.hive.kudu.com.stumbleupon.async.Deferred) throws org.apache.hive.kudu.org.apache.kudu.client.KuduException
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.client.KuduException v;
java.lang.Exception v;
v := @parameter: org.apache.hive.kudu.com.stumbleupon.async.Deferred;
label:
v = virtualinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: java.lang.Object join()>();
label:
return v;
label:
v := @caughtexception;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.KuduException: org.apache.hive.kudu.org.apache.kudu.client.KuduException transformException(java.lang.Exception)>(v);
throw v;
catch java.lang.Exception from label to label with label;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/client/AsyncKuduClient;");
<org.apache.hive.kudu.org.apache.kudu.client.KuduClient: org.slf4j.Logger LOG> = v;
return;
}
}