public class org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient extends java.lang.Object implements java.lang.AutoCloseable { public static final org.slf4j.Logger LOG; public static final int SLEEP_TIME; public static final byte[] EMPTY_ARRAY; public static final long NO_TIMESTAMP; public static final long DEFAULT_OPERATION_TIMEOUT_MS; public static final long DEFAULT_KEEP_ALIVE_PERIOD_MS; private static final long MAX_RPC_ATTEMPTS; private static final int FETCH_TABLETS_PER_POINT_LOOKUP; static int FETCH_TABLETS_PER_RANGE_LOOKUP; private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.bootstrap.Bootstrap bootstrap; private final java.util.concurrent.ConcurrentHashMap tableLocations; private final org.apache.hive.kudu.org.apache.kudu.client.ConnectionCache connectionCache; private final java.util.Set sessions; private org.apache.hive.kudu.org.apache.kudu.client.HiveMetastoreConfig hiveMetastoreConfig; static final java.lang.String MASTER_TABLE_NAME_PLACEHOLDER; private final org.apache.hive.kudu.org.apache.kudu.client.KuduTable masterTable; private final java.util.List masterAddresses; private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.HashedWheelTimer timer; private long lastPropagatedTimestamp; private volatile boolean hasConnectedToMaster; private java.lang.String location; private final java.util.concurrent.Semaphore masterLookups; private final java.util.Random sleepRandomizer; private final long defaultOperationTimeoutMs; private final long defaultAdminOperationTimeoutMs; private final org.apache.hive.kudu.org.apache.kudu.client.Statistics statistics; private final boolean statisticsDisabled; private final org.apache.hive.kudu.org.apache.kudu.client.RequestTracker requestTracker; final org.apache.hive.kudu.org.apache.kudu.client.SecurityContext securityContext; private final org.apache.hive.kudu.org.apache.kudu.client.AuthnTokenReacquirer tokenReacquirer; private final org.apache.hive.kudu.org.apache.kudu.client.AuthzTokenCache authzTokenCache; private volatile boolean closed; static final boolean $assertionsDisabled; private void (org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$AsyncKuduClientBuilder) { org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.SecurityContext v, v; java.util.Random v; long v, v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; java.util.HashSet v; org.apache.hive.kudu.org.apache.kudu.client.AuthnTokenReacquirer v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.HashedWheelTimer v; java.lang.String v, v; org.apache.hive.kudu.org.apache.kudu.client.Statistics v; boolean v, v; java.util.concurrent.Semaphore v; java.util.concurrent.ConcurrentHashMap v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.bootstrap.Bootstrap v, v; org.apache.hive.kudu.org.apache.kudu.client.AuthzTokenCache v; org.apache.hive.kudu.org.apache.kudu.client.ConnectionCache v; java.util.UUID v; java.util.List v; org.apache.hive.kudu.org.apache.kudu.client.RequestTracker v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$AsyncKuduClientBuilder v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$AsyncKuduClientBuilder; specialinvoke v.()>(); v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.HashSet; specialinvoke v.()>(); v. = v; v. = null; v. = -1L; v. = 0; v. = ""; v = new java.util.concurrent.Semaphore; specialinvoke v.(int)>(50); v. = v; v = new java.util.Random; specialinvoke v.()>(); v. = v; v = specialinvoke v.(); v. = v; v = v.; v. = v; v = new org.apache.hive.kudu.org.apache.kudu.client.KuduTable; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,java.lang.String,java.lang.String,org.apache.hive.kudu.org.apache.kudu.Schema,org.apache.hive.kudu.org.apache.kudu.client.PartitionSchema,int,java.util.Map)>(v, "Kudu Master", "Kudu Master", null, null, 1, null); v. = v; v = v.; v. = v; v = v.; v. = v; v = v.; v. = v; v = v.; if v == 0 goto label; v = null; goto label; label: v = new org.apache.hive.kudu.org.apache.kudu.client.Statistics; specialinvoke v.()>(); label: v. = v; v = v.; v. = v; v = new org.apache.hive.kudu.org.apache.kudu.client.RequestTracker; v = staticinvoke (); v = virtualinvoke v.(); v = virtualinvoke v.("-", ""); specialinvoke v.(java.lang.String)>(v); v. = v; v = new org.apache.hive.kudu.org.apache.kudu.client.SecurityContext; specialinvoke v.()>(); v. = v; v = new org.apache.hive.kudu.org.apache.kudu.client.ConnectionCache; v = v.; v = v.; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.SecurityContext,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.bootstrap.Bootstrap)>(v, v); v. = v; v = new org.apache.hive.kudu.org.apache.kudu.client.AuthnTokenReacquirer; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient)>(v); v. = v; v = new org.apache.hive.kudu.org.apache.kudu.client.AuthzTokenCache; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient)>(v); v. = v; return; } org.apache.hive.kudu.org.apache.kudu.client.RpcProxy newRpcProxy(org.apache.hive.kudu.org.apache.kudu.client.ServerInfo) { org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy v; org.apache.hive.kudu.org.apache.kudu.client.RpcProxy v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.ServerInfo; v = ; v = specialinvoke v.(v, v); return v; } private org.apache.hive.kudu.org.apache.kudu.client.RpcProxy newRpcProxy(org.apache.hive.kudu.org.apache.kudu.client.ServerInfo, org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy) { org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy v; org.apache.hive.kudu.org.apache.kudu.client.ConnectionCache v; org.apache.hive.kudu.org.apache.kudu.client.RpcProxy v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.ServerInfo; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy; v = v.; v = virtualinvoke v.(v, v); v = new org.apache.hive.kudu.org.apache.kudu.client.RpcProxy; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.client.Connection)>(v, v); return v; } org.apache.hive.kudu.org.apache.kudu.client.RpcProxy newMasterRpcProxy(org.apache.hive.kudu.org.apache.kudu.client.HostAndPort, java.net.InetAddress, org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy) { java.net.InetAddress v; org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v; org.apache.hive.kudu.org.apache.kudu.client.HostAndPort v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy v; org.apache.hive.kudu.org.apache.kudu.client.RpcProxy v; java.lang.String v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.HostAndPort; v := @parameter: java.net.InetAddress; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy; v = new org.apache.hive.kudu.org.apache.kudu.client.ServerInfo; v = staticinvoke (v); specialinvoke v.(java.lang.String,org.apache.hive.kudu.org.apache.kudu.client.HostAndPort,java.net.InetAddress,java.lang.String)>(v, v, v, ""); v = specialinvoke v.(v, v); return v; } static java.lang.String getFakeMasterUuid(org.apache.hive.kudu.org.apache.kudu.client.HostAndPort) { java.lang.String v, v; org.apache.hive.kudu.org.apache.kudu.client.HostAndPort v; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.HostAndPort; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("master-\u0001"); return v; } void reconnectToCluster(org.apache.hive.kudu.com.stumbleupon.async.Callback, org.apache.hive.kudu.com.stumbleupon.async.Callback) { 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.Connection$CredentialsPolicy v; long v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$1ReconnectToClusterCB v; java.util.List v; org.apache.hive.kudu.com.stumbleupon.async.Callback v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.com.stumbleupon.async.Callback; v := @parameter: org.apache.hive.kudu.com.stumbleupon.async.Callback; v = v.; v = v.; v = v.; v = ; v = staticinvoke (v, v, null, v, v); v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$1ReconnectToClusterCB; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.com.stumbleupon.async.Callback)>(v, v); virtualinvoke v.(v, v); return; } public synchronized void updateLastPropagatedTimestamp(long) { byte v, v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; long v, v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: long; v = v.; v = v cmp -1L; if v == 0 goto label; v = v.; v = v cmp v; if v >= 0 goto label; label: v. = v; label: return; } public synchronized long getLastPropagatedTimestamp() { long v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v = v.; return v; } public synchronized boolean hasLastPropagatedTimestamp() { byte v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; long v; boolean v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v = v.; v = v cmp -1L; if v == 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public java.lang.String getLocationString() { java.lang.String v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v = v.; return v; } org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer getTimer() { org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.HashedWheelTimer v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v = v.; return v; } public org.apache.hive.kudu.org.apache.kudu.client.KuduClient syncClient() { 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.AsyncKuduClient; v = new org.apache.hive.kudu.org.apache.kudu.client.KuduClient; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient)>(v); return v; } public 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) { org.apache.hive.kudu.org.apache.kudu.client.CreateTableRequest v; org.apache.hive.kudu.org.apache.kudu.Common$PartitionSchemaPB v, v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; long v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; org.apache.hive.kudu.org.apache.kudu.master.Master$CreateTableRequestPB$Builder v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.HashedWheelTimer v; int v; org.apache.hive.kudu.com.stumbleupon.async.Callback v, v; java.lang.String v; boolean v, v; org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v, v; org.apache.hive.kudu.org.apache.kudu.Schema v; org.apache.hive.kudu.org.apache.kudu.client.CreateTableOptions v; java.lang.IllegalArgumentException v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; 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; specialinvoke v.(); if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("CreateTableOptions may not be null"); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Table partitioning must be specified using setRangePartitionColumns or addHashPartitions"); throw v; label: v = new org.apache.hive.kudu.org.apache.kudu.client.CreateTableRequest; v = v.; v = v.; v = v.; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.KuduTable,java.lang.String,org.apache.hive.kudu.org.apache.kudu.Schema,org.apache.hive.kudu.org.apache.kudu.client.CreateTableOptions,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer,long)>(v, v, v, v, v, v); v = virtualinvoke v.(v); v = staticinvoke (v, v, v); v = virtualinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; return v; label: v = staticinvoke (v, v); v = virtualinvoke v.(v); return v; } public org.apache.hive.kudu.com.stumbleupon.async.Deferred isCreateTableDone(java.lang.String) { org.apache.hive.kudu.com.stumbleupon.async.Deferred v; org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder v, v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; java.lang.String v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: java.lang.String; v = staticinvoke (); v = virtualinvoke v.(v); v = specialinvoke v.(v, null); return v; } private org.apache.hive.kudu.com.stumbleupon.async.Deferred doIsCreateTableDone(org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder, org.apache.hive.kudu.org.apache.kudu.client.KuduRpc) { 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.IsCreateTableDoneRequest v; long v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.HashedWheelTimer v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; specialinvoke v.(); v = new org.apache.hive.kudu.org.apache.kudu.client.IsCreateTableDoneRequest; v = v.; v = v.; v = v.; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.KuduTable,org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer,long)>(v, v, v, v); if v == null goto label; virtualinvoke v.(v); label: v = virtualinvoke v.(v); return v; } public org.apache.hive.kudu.com.stumbleupon.async.Deferred deleteTable(java.lang.String) { org.apache.hive.kudu.com.stumbleupon.async.Deferred v; org.apache.hive.kudu.org.apache.kudu.client.DeleteTableRequest v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.HashedWheelTimer v; long v; java.lang.String v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: java.lang.String; specialinvoke v.(); v = new org.apache.hive.kudu.org.apache.kudu.client.DeleteTableRequest; v = v.; v = v.; v = v.; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.KuduTable,java.lang.String,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer,long)>(v, v, v, v); v = virtualinvoke v.(v); return v; } public org.apache.hive.kudu.com.stumbleupon.async.Deferred alterTable(java.lang.String, org.apache.hive.kudu.org.apache.kudu.client.AlterTableOptions) { org.apache.hive.kudu.org.apache.kudu.client.AlterTableRequest v; org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v, v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$1 v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$2 v; long v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.HashedWheelTimer v; org.apache.hive.kudu.com.stumbleupon.async.Callback v; java.lang.String v; boolean v, v; org.apache.hive.kudu.org.apache.kudu.client.AlterTableOptions v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: java.lang.String; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AlterTableOptions; specialinvoke v.(); v = new org.apache.hive.kudu.org.apache.kudu.client.AlterTableRequest; v = v.; v = v.; v = v.; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.KuduTable,java.lang.String,org.apache.hive.kudu.org.apache.kudu.client.AlterTableOptions,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer,long)>(v, v, v, v, v); v = virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$2; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient)>(v); v = virtualinvoke v.(v); v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$1; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient)>(v); v = virtualinvoke v.(v); label: v = virtualinvoke v.(); if v != 0 goto label; return v; label: v = staticinvoke (v, v); v = virtualinvoke v.(v); return v; } public org.apache.hive.kudu.com.stumbleupon.async.Deferred isAlterTableDone(java.lang.String) { org.apache.hive.kudu.com.stumbleupon.async.Deferred v; org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder v, v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; java.lang.String v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: java.lang.String; v = staticinvoke (); v = virtualinvoke v.(v); v = specialinvoke v.(v, null); return v; } private org.apache.hive.kudu.com.stumbleupon.async.Deferred doIsAlterTableDone(org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder, org.apache.hive.kudu.org.apache.kudu.client.KuduRpc) { org.apache.hive.kudu.com.stumbleupon.async.Deferred v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; long v; org.apache.hive.kudu.org.apache.kudu.client.IsAlterTableDoneRequest v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.HashedWheelTimer v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; specialinvoke v.(); v = new org.apache.hive.kudu.org.apache.kudu.client.IsAlterTableDoneRequest; v = v.; v = v.; v = v.; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.KuduTable,org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer,long)>(v, v, v, v); virtualinvoke v.(v); v = virtualinvoke v.(v); return v; } public org.apache.hive.kudu.com.stumbleupon.async.Deferred listTabletServers() { org.apache.hive.kudu.com.stumbleupon.async.Deferred v; org.apache.hive.kudu.org.apache.kudu.client.ListTabletServersRequest v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.HashedWheelTimer v; long v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; specialinvoke v.(); v = new org.apache.hive.kudu.org.apache.kudu.client.ListTabletServersRequest; v = v.; v = v.; v = v.; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.KuduTable,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer,long)>(v, v, v); v = virtualinvoke v.(v); return v; } private org.apache.hive.kudu.com.stumbleupon.async.Deferred getTableSchema(java.lang.String, java.lang.String, org.apache.hive.kudu.org.apache.kudu.client.KuduRpc) { org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; long v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; org.apache.hive.kudu.org.apache.kudu.client.GetTableSchemaRequest v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.HashedWheelTimer v; org.apache.hive.kudu.com.stumbleupon.async.Callback v; java.lang.String v, v, v; boolean v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; if v != null goto label; if v == null goto label; label: v = 1; goto label; label: v = 0; label: staticinvoke (v); v = new org.apache.hive.kudu.org.apache.kudu.client.GetTableSchemaRequest; v = v.; if v == null goto label; v = null; goto label; label: v = v; label: v = v.; v = v.; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.KuduTable,java.lang.String,java.lang.String,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer,long,boolean)>(v, v, v, v, v, 0); virtualinvoke v.(v); v = virtualinvoke v.(v); v = staticinvoke (v); v = virtualinvoke v.(v); return v; } public org.apache.hive.kudu.com.stumbleupon.async.Deferred getTablesList() { org.apache.hive.kudu.com.stumbleupon.async.Deferred v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v = virtualinvoke v.(null); return v; } public org.apache.hive.kudu.com.stumbleupon.async.Deferred getTablesList(java.lang.String) { 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.shaded.io.netty.util.HashedWheelTimer v; org.apache.hive.kudu.org.apache.kudu.client.ListTablesRequest v; long v; java.lang.String v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: java.lang.String; v = new org.apache.hive.kudu.org.apache.kudu.client.ListTablesRequest; v = v.; v = v.; v = v.; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.KuduTable,java.lang.String,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer,long)>(v, v, v, v); v = virtualinvoke v.(v); return v; } public org.apache.hive.kudu.com.stumbleupon.async.Deferred getTableStatistics(java.lang.String) { org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v; org.apache.hive.kudu.org.apache.kudu.client.GetTableStatisticsRequest v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; long v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.HashedWheelTimer v; org.apache.hive.kudu.com.stumbleupon.async.Callback v; java.lang.String v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: java.lang.String; v = new org.apache.hive.kudu.org.apache.kudu.client.GetTableStatisticsRequest; v = v.; v = v.; v = v.; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.KuduTable,java.lang.String,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer,long)>(v, v, v, v); v = virtualinvoke v.(v); v = staticinvoke (); v = virtualinvoke v.(v); return v; } public org.apache.hive.kudu.com.stumbleupon.async.Deferred tableExists(java.lang.String) { org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.com.stumbleupon.async.Callback v, v; java.lang.String v; java.lang.IllegalArgumentException v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: java.lang.String; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("The table name cannot be null"); throw v; label: v = specialinvoke v.(v, null, null); v = staticinvoke (); v = staticinvoke (); v = staticinvoke (v, v, v); return v; } org.apache.hive.kudu.com.stumbleupon.async.Deferred openTableById(java.lang.String) { org.apache.hive.kudu.com.stumbleupon.async.Deferred 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.AsyncKuduClient; v := @parameter: java.lang.String; specialinvoke v.(); v = specialinvoke v.(null, v, null); return v; } public org.apache.hive.kudu.com.stumbleupon.async.Deferred openTable(java.lang.String) { org.apache.hive.kudu.com.stumbleupon.async.Deferred 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.AsyncKuduClient; v := @parameter: java.lang.String; specialinvoke v.(); v = specialinvoke v.(v, null, null); return v; } public org.apache.hive.kudu.com.stumbleupon.async.Deferred exportAuthenticationCredentials() { org.apache.hive.kudu.com.stumbleupon.async.Deferred v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v = specialinvoke v.("exportAuthenticationCredentials", null); v = virtualinvoke v.(); specialinvoke v.(v); return v; } private void doExportAuthenticationCredentials(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc) { byte[] v; org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v, v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.SecurityContext v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$MasterLookupCB v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.TimerTask v; int v, v; org.apache.hive.kudu.com.stumbleupon.async.Callback v; boolean v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; v = v.; if v == 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); return; label: v = v.; v = v + 1; v. = v; v = virtualinvoke v.(null); v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$MasterLookupCB; v = v.; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.client.KuduTable,byte[],int)>(v, v, null, 1); v = virtualinvoke v.(v); v = staticinvoke (v, v); v = virtualinvoke v.(v); v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback; v = staticinvoke (v, v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.TimerTask)>(v, v, v); virtualinvoke v.(v); return; } public org.apache.hive.kudu.org.apache.kudu.client.AuthzTokenCache getAuthzTokenCache() { org.apache.hive.kudu.org.apache.kudu.client.AuthzTokenCache v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v = v.; return v; } public org.apache.hive.kudu.com.stumbleupon.async.Deferred getHiveMetastoreConfig() { org.apache.hive.kudu.com.stumbleupon.async.Deferred v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v = specialinvoke v.("getHiveMetastoreConfig", null); v = virtualinvoke v.(); specialinvoke v.(v); return v; } private void doGetHiveMetastoreConfig(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc) { java.lang.Throwable v; org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v, v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$MasterLookupCB v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; org.apache.hive.kudu.org.apache.kudu.client.HiveMetastoreConfig v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.TimerTask v; int v, v; org.apache.hive.kudu.com.stumbleupon.async.Callback v; boolean v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; v = v.; if v == 0 goto label; entermonitor v; label: v = v.; exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: virtualinvoke v.(v); return; label: v = v.; v = v + 1; v. = v; v = virtualinvoke v.(null); v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$MasterLookupCB; v = v.; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.client.KuduTable,byte[],int)>(v, v, null, 1); v = virtualinvoke v.(v); v = staticinvoke (v, v); v = virtualinvoke v.(v); v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryTaskErrback; v = staticinvoke (v, v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.TimerTask)>(v, v, v); virtualinvoke v.(v); return; catch java.lang.Throwable from label to label with label; } public void importAuthenticationCredentials(byte[]) { org.apache.hive.kudu.org.apache.kudu.client.SecurityContext v; byte[] v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: byte[]; v = v.; virtualinvoke v.(v); return; } public long getDefaultOperationTimeoutMs() { long v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v = v.; return v; } public long getDefaultAdminOperationTimeoutMs() { long v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v = v.; return v; } public long getDefaultSocketReadTimeoutMs() { org.slf4j.Logger v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v = ; interfaceinvoke v.("getDefaultSocketReadTimeoutMs is deprecated"); return 0L; } public java.lang.String getMasterAddressesAsString() { java.util.List v; org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Joiner v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; java.lang.String v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v = staticinvoke (","); v = v.; v = virtualinvoke v.(v); return v; } public boolean isStatisticsEnabled() { org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; boolean v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v = v.; if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public org.apache.hive.kudu.org.apache.kudu.client.Statistics getStatistics() { java.lang.IllegalStateException v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.Statistics v; boolean v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v = v.; if v == 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("This client\'s statistics is disabled"); throw v; label: v = v.; return v; } org.apache.hive.kudu.org.apache.kudu.client.RequestTracker getRequestTracker() { org.apache.hive.kudu.org.apache.kudu.client.RequestTracker v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v = v.; return v; } org.apache.hive.kudu.org.apache.kudu.client.KuduTable getMasterTable() { org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v = v.; return v; } public org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$AsyncKuduScannerBuilder newScannerBuilder(org.apache.hive.kudu.org.apache.kudu.client.KuduTable) { org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$AsyncKuduScannerBuilder v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduTable; specialinvoke v.(); v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$AsyncKuduScannerBuilder; specialinvoke v.(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.AsyncKuduSession newSession() { java.lang.Throwable v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession v; java.util.Set v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; specialinvoke v.(); v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient)>(v); v = v.; entermonitor v; label: v = v.; interfaceinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return v; catch java.lang.Throwable from label to label with label; } void removeSession(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession) { java.lang.Throwable v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; java.util.Set v, v; java.lang.AssertionError v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession v; boolean v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession; v = v.; entermonitor v; label: v = v.; v = interfaceinvoke v.(v); v = ; if v != 0 goto label; if v != 0 goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; } org.apache.hive.kudu.com.stumbleupon.async.Deferred scanNextRows(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner) { org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v; java.lang.Object[] v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; int v, v; java.lang.String v, v, v; org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v; org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v; org.apache.hive.kudu.org.apache.kudu.client.ConnectionCache v; org.apache.hive.kudu.org.apache.kudu.client.Status v; org.apache.hive.kudu.org.apache.kudu.client.RecoverableException v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v; java.lang.Object v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); v = v.; v = v + 1; v. = v; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(v, v); if v != null goto label; v = new org.apache.hive.kudu.org.apache.kudu.client.RecoverableException; v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v[0] = v; v = staticinvoke ("No information on servers hosting tablet %s, will retry later", v); v = staticinvoke (v); specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v); v = specialinvoke v.(v, v); return v; label: v = virtualinvoke v.(); v = v.; v = ; v = virtualinvoke v.(v, v); staticinvoke (v, v, v); return v; } org.apache.hive.kudu.com.stumbleupon.async.Deferred closeScanner(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner) { org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v, v; org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v; org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection v; org.apache.hive.kudu.org.apache.kudu.client.ConnectionCache v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v; int v, v; java.lang.String v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner; v = virtualinvoke v.(); if v != null goto label; v = staticinvoke (null); return v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(v, v); if v != null goto label; v = staticinvoke (null); return v; label: v = virtualinvoke v.(); v = v.; v = v + 1; v. = v; v = v.; v = ; v = virtualinvoke v.(v, v); staticinvoke (v, v, v); return v; } org.apache.hive.kudu.com.stumbleupon.async.Deferred keepAlive(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner) { org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v, v; org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v; org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection v; org.apache.hive.kudu.org.apache.kudu.client.ConnectionCache v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v; int v, v; java.lang.String v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner; specialinvoke v.(); v = virtualinvoke v.(); if v != null goto label; v = staticinvoke (null); return v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(v, v); if v != null goto label; v = staticinvoke (null); return v; label: v = virtualinvoke v.(); v = v.; v = v + 1; v. = v; v = v.; v = ; v = virtualinvoke v.(v, v); staticinvoke (v, v, v); return v; } org.apache.hive.kudu.com.stumbleupon.async.Deferred sendRpcToTablet(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc) { byte[] v, v, v; org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryRpcErrback v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v, v; org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame v; byte v; org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder v; boolean v, v; org.apache.hive.kudu.org.apache.kudu.client.ConnectionCache v; org.apache.hive.kudu.org.apache.kudu.client.NonCoveredRangeException v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection v; long v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryRpcCB v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; int v, v; java.lang.String v, v, v; org.apache.hive.kudu.org.apache.kudu.client.ExternalConsistencyMode v, v; org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v, v, v, v; org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy v; org.apache.hive.kudu.org.apache.kudu.client.TableLocationsCache$Entry v; org.apache.hive.kudu.org.apache.kudu.client.Connection v; org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v; org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$Action v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; v = staticinvoke (v); if v == 0 goto label; v = staticinvoke (v, null); return v; label: v = v.; v = v + 1; v. = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.hive.kudu.org.apache.kudu.client.NonCoveredRangeException; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(byte[],byte[])>(v, v); v = virtualinvoke v.(); virtualinvoke v.(v); return v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; if v != v goto label; v = v cmp -1L; if v == 0 goto label; virtualinvoke v.(v); label: if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = ; v = virtualinvoke v.(v, v); staticinvoke (v, v, v); return v; label: v = new org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder; v = virtualinvoke v.(); v = ; specialinvoke v.(java.lang.String,org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$Action)>(v, v); v = virtualinvoke v.(); virtualinvoke v.(v); v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryRpcCB; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.client.KuduRpc)>(v, v); v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$RetryRpcErrback; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.client.KuduRpc)>(v, v); v = virtualinvoke v.(); v = specialinvoke v.(v, v, 10, v); v = staticinvoke (v, v, v); return v; } private org.apache.hive.kudu.com.stumbleupon.async.Callback getDelayedIsTableDoneEB(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc) { org.apache.hive.kudu.com.stumbleupon.async.Callback v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; v = staticinvoke (v); return v; } private org.apache.hive.kudu.org.apache.kudu.client.KuduRpc buildFakeRpc(java.lang.String, org.apache.hive.kudu.org.apache.kudu.client.KuduRpc, long) { org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.HashedWheelTimer v; long v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$FakeKuduRpc v; java.lang.String v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: java.lang.String; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; v := @parameter: long; v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$FakeKuduRpc; v = v.; specialinvoke v.(java.lang.String,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer,long)>(v, v, v); virtualinvoke v.(v); return v; } private org.apache.hive.kudu.org.apache.kudu.client.KuduRpc buildFakeRpc(java.lang.String, org.apache.hive.kudu.org.apache.kudu.client.KuduRpc) { org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; long v; java.lang.String v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: java.lang.String; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; v = v.; v = specialinvoke v.(v, v, v); return v; } 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) { 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.KuduRpc v, v; org.apache.hive.kudu.org.apache.kudu.client.AlterTableResponse v; org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder v; org.apache.hive.kudu.com.stumbleupon.async.Callback v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AlterTableResponse; v = specialinvoke v.("IsAlterTableDone", v); v = virtualinvoke v.(); v = specialinvoke v.(v, v, v); v = specialinvoke v.(v); specialinvoke v.(v, v, v, v); return v; } 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) { 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.KuduRpc v, v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder v; org.apache.hive.kudu.com.stumbleupon.async.Callback v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduTable; v = specialinvoke v.("IsCreateTableDone", v); v = virtualinvoke v.(); v = specialinvoke v.(v, v, v); v = specialinvoke v.(v); specialinvoke v.(v, v, v, v); return v; } private org.apache.hive.kudu.com.stumbleupon.async.Callback getDelayedIsAlterTableDoneCB(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc, org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder, org.apache.hive.kudu.org.apache.kudu.client.AlterTableResponse) { org.apache.hive.kudu.org.apache.kudu.client.AlterTableResponse v; org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.com.stumbleupon.async.Callback v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; v := @parameter: org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AlterTableResponse; v = staticinvoke (v, v, v, v); return v; } private org.apache.hive.kudu.com.stumbleupon.async.Callback getDelayedIsCreateTableDoneCB(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc, org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder, org.apache.hive.kudu.org.apache.kudu.client.KuduTable) { org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.com.stumbleupon.async.Callback v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; v := @parameter: org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduTable; v = staticinvoke (v, v, v, v); return v; } private void delayedIsCreateTableDone(org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder, org.apache.hive.kudu.org.apache.kudu.client.KuduRpc, org.apache.hive.kudu.com.stumbleupon.async.Callback, org.apache.hive.kudu.com.stumbleupon.async.Callback) { org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker v; long v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.HashedWheelTimer v; org.apache.hive.kudu.com.stumbleupon.async.Callback v, v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$1RetryTimer v; boolean v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; v := @parameter: org.apache.hive.kudu.com.stumbleupon.async.Callback; v := @parameter: org.apache.hive.kudu.com.stumbleupon.async.Callback; v = specialinvoke v.(v); v = v.; v = virtualinvoke v.(v); if v == 0 goto label; staticinvoke (v, null); return; label: v = v.; v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$1RetryTimer; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder,org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.com.stumbleupon.async.Callback,org.apache.hive.kudu.com.stumbleupon.async.Callback)>(v, v, v, v, v); staticinvoke (v, v, v); return; } private void delayedIsAlterTableDone(org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder, org.apache.hive.kudu.org.apache.kudu.client.KuduRpc, org.apache.hive.kudu.com.stumbleupon.async.Callback, org.apache.hive.kudu.com.stumbleupon.async.Callback) { org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker v; long v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.HashedWheelTimer v; org.apache.hive.kudu.com.stumbleupon.async.Callback v, v; boolean v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$2RetryTimer v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; v := @parameter: org.apache.hive.kudu.com.stumbleupon.async.Callback; v := @parameter: org.apache.hive.kudu.com.stumbleupon.async.Callback; v = specialinvoke v.(v); v = v.; v = virtualinvoke v.(v); if v == 0 goto label; staticinvoke (v, null); return; label: v = v.; v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$2RetryTimer; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.master.Master$TableIdentifierPB$Builder,org.apache.hive.kudu.org.apache.kudu.client.KuduRpc,org.apache.hive.kudu.com.stumbleupon.async.Callback,org.apache.hive.kudu.com.stumbleupon.async.Callback)>(v, v, v, v, v); staticinvoke (v, v, v); return; } private long getSleepTimeForRpcMillis(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc) { org.slf4j.Logger v, v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; java.util.Random v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; java.lang.Integer v; java.lang.Long v; int v, v, v; boolean v; double v, v, v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; v = v.; if v != 0 goto label; return 0L; label: v = staticinvoke (v, 12); v = staticinvoke (2.0, v); v = v.; v = virtualinvoke v.(); v = v * v; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = staticinvoke (v); v = v.; v = staticinvoke (v); interfaceinvoke v.("Going to sleep for {} at retry {}", v, v); label: return v; } void emptyTabletsCacheForTable(java.lang.String) { java.util.concurrent.ConcurrentHashMap 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.AsyncKuduClient; v := @parameter: java.lang.String; v = v.; virtualinvoke v.(v); return; } private static boolean cannotRetryRequest(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc) { byte v; int v; org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; boolean v, v; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = v cmp 100L; if v <= 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } private static org.apache.hive.kudu.com.stumbleupon.async.Deferred tooManyAttemptsOrTimeout(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc, org.apache.hive.kudu.org.apache.kudu.client.KuduException) { org.apache.hive.kudu.com.stumbleupon.async.Deferred v; org.slf4j.Logger v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; org.apache.hive.kudu.org.apache.kudu.client.Status v; byte v; int v; java.lang.String v, v; org.apache.hive.kudu.org.apache.kudu.client.KuduException v; org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException v; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduException; v = v.; v = v cmp 100L; if v <= 0 goto label; v = "too many attempts: "; goto label; label: v = "cannot complete before timeout: "; label: v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001\u0001"); v = staticinvoke (v); v = ; interfaceinvoke v.("Cannot continue with RPC because of: {}", v); v = virtualinvoke v.(); v = new org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.Status,java.lang.Throwable)>(v, v); virtualinvoke v.(v); return v; } private org.apache.hive.kudu.com.stumbleupon.async.Deferred locateTablet(org.apache.hive.kudu.org.apache.kudu.client.KuduTable, byte[], int, org.apache.hive.kudu.org.apache.kudu.client.KuduRpc) { byte[] v; org.apache.hive.kudu.org.apache.kudu.client.ServerInfo v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; long v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v, v; org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.HashedWheelTimer v; int v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$ReleaseMasterLookupPermit v; java.lang.String v; boolean v, v, v; org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v; org.apache.hive.kudu.org.apache.kudu.client.GetTableLocationsRequest v; org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$MasterLookupCB v; org.apache.hive.kudu.org.apache.kudu.client.TableLocationsCache$Entry v; org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduTable; v := @parameter: byte[]; v := @parameter: int; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; v = specialinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = staticinvoke (null); return v; label: v = staticinvoke (v); if v == 0 goto label; v = virtualinvoke v.(v); goto label; label: if v != null goto label; v = v.; goto label; label: v = v.; v = virtualinvoke v.(); label: v = new org.apache.hive.kudu.org.apache.kudu.client.GetTableLocationsRequest; v = v.; v = v.; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.KuduTable,byte[],byte[],java.lang.String,int,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer,long)>(v, v, null, v, v, v, v); virtualinvoke v.(v); v = virtualinvoke v.(v); label: v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$MasterLookupCB; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.client.KuduTable,byte[],int)>(v, v, v, v); virtualinvoke v.(v); if v == 0 goto label; v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient$ReleaseMasterLookupPermit; specialinvoke v.(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient)>(v); virtualinvoke v.(v); label: return v; } org.apache.hive.kudu.com.stumbleupon.async.Deferred getMasterTableLocationsPB(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc) { org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v; org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v; org.apache.hive.kudu.org.apache.kudu.client.Connection$CredentialsPolicy v; long v; org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v; org.apache.hive.kudu.org.apache.kudu.client.KuduTable v; java.util.List v; org.apache.hive.kudu.com.stumbleupon.async.Callback v; v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient; v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc; v = v.; v = v.; v = v.; v = ; v = staticinvoke (v, v, v, v, v); v = staticinvoke