public abstract class org.apache.hive.kudu.org.apache.kudu.client.KuduRpc extends java.lang.Object
{
public static final int MAX_TRACES_SIZE;
static final int MAX_RPC_SIZE;
protected static final java.lang.String MASTER_SERVICE_NAME;
protected static final java.lang.String TABLET_SERVER_SERVICE_NAME;
private static final org.slf4j.Logger LOG;
private final java.util.List traces;
private org.apache.hive.kudu.org.apache.kudu.client.KuduRpc parentRpc;
private org.apache.hive.kudu.com.stumbleupon.async.Deferred deferred;
private org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet tablet;
final org.apache.hive.kudu.org.apache.kudu.client.KuduTable table;
final org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker timeoutTracker;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timeout timeoutTask;
long propagatedTimestamp;
org.apache.hive.kudu.org.apache.kudu.client.ExternalConsistencyMode externalConsistencyMode;
int attempt;
private long sequenceId;
static final boolean $assertionsDisabled;
byte[] partitionKey()
{
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
return null;
}
void bindAuthzToken(org.apache.hive.kudu.org.apache.kudu.security.Token$SignedTokenPB)
{
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
org.apache.hive.kudu.org.apache.kudu.security.Token$SignedTokenPB v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.security.Token$SignedTokenPB;
return;
}
boolean needsAuthzToken()
{
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
return 0;
}
void <init>(org.apache.hive.kudu.org.apache.kudu.client.KuduTable, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer, long)
{
org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker v, 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.ArrayList v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timeout v;
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer v;
org.apache.hive.kudu.org.apache.kudu.client.ExternalConsistencyMode v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc$RpcTimeoutTask v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduTable;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer;
v := @parameter: long;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = staticinvoke <java.util.Collections: java.util.List synchronizedList(java.util.List)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: java.util.List traces> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: long propagatedTimestamp> = -1L;
v = <org.apache.hive.kudu.org.apache.kudu.client.ExternalConsistencyMode: org.apache.hive.kudu.org.apache.kudu.client.ExternalConsistencyMode CLIENT_PROPAGATED>;
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.ExternalConsistencyMode externalConsistencyMode> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: long sequenceId> = -1L;
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.KuduTable table> = v;
v = new org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker timeoutTracker> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker timeoutTracker>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker: void setTimeout(long)>(v);
if v == null goto label;
v = new org.apache.hive.kudu.org.apache.kudu.client.KuduRpc$RpcTimeoutTask;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc$RpcTimeoutTask: void <init>(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timeout newTimeout(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.TimerTask,long)>(v, v, v);
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timeout timeoutTask> = v;
label:
return;
}
abstract org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message createRequestPB();
abstract java.lang.String serviceName();
abstract java.lang.String method();
java.util.Collection getRequiredFeatures()
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.ImmutableList v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.ImmutableList: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.ImmutableList of()>();
return v;
}
abstract org.apache.hive.kudu.org.apache.kudu.util.Pair deserialize(org.apache.hive.kudu.org.apache.kudu.client.CallResponse, java.lang.String) throws org.apache.hive.kudu.org.apache.kudu.client.KuduException;
void updateStatistics(org.apache.hive.kudu.org.apache.kudu.client.Statistics, java.lang.Object)
{
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
org.apache.hive.kudu.org.apache.kudu.client.Statistics v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.Statistics;
v := @parameter: java.lang.Object;
return;
}
public void setExternalConsistencyMode(org.apache.hive.kudu.org.apache.kudu.client.ExternalConsistencyMode)
{
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
org.apache.hive.kudu.org.apache.kudu.client.ExternalConsistencyMode v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.ExternalConsistencyMode;
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.ExternalConsistencyMode externalConsistencyMode> = v;
return;
}
public org.apache.hive.kudu.org.apache.kudu.client.ExternalConsistencyMode getExternalConsistencyMode()
{
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
org.apache.hive.kudu.org.apache.kudu.client.ExternalConsistencyMode v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.ExternalConsistencyMode externalConsistencyMode>;
return v;
}
public void setPropagatedTimestamp(long)
{
long v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: long;
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: long propagatedTimestamp> = v;
return;
}
private void handleCallback(java.lang.Object)
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.slf4j.Logger v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker v;
long v, 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.Timeout v, v;
java.util.List v;
byte v;
org.apache.hive.kudu.org.apache.kudu.client.RequestTracker v;
java.lang.Object v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: java.lang.Object;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.com.stumbleupon.async.Deferred deferred>;
if v != null goto label;
v = <org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Handling a callback on RPC {} with no deferred attached!", v);
return;
label:
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.com.stumbleupon.async.Deferred deferred> = null;
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: int attempt> = 0;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: boolean isRequestTracked()>();
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: long sequenceId>;
v = v cmp -1L;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.KuduTable table>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduTable: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient getAsyncClient()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.org.apache.kudu.client.RequestTracker getRequestTracker()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: long sequenceId>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RequestTracker: void rpcCompleted(long)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: long sequenceId> = -1L;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timeout timeoutTask>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timeout timeoutTask>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timeout: boolean cancel()>();
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker timeoutTracker>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker: void reset()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: java.util.List traces>;
interfaceinvoke v.<java.util.List: void clear()>();
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc parentRpc> = null;
virtualinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: void callback(java.lang.Object)>(v);
return;
}
void addTrace(org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame)
{
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v, v, v;
java.util.List v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame v, v;
org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$Action v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc parentRpc>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc parentRpc>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: void addTrace(org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: java.util.List traces>;
v = interfaceinvoke v.<java.util.List: int size()>();
if v != 100 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: java.util.List traces>;
v = new org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: java.lang.String method()>();
v = <org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$Action: org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$Action TRACE_TRUNCATED>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder: void <init>(java.lang.String,org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$Action)>(v, v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame$RpcTraceFrameBuilder: org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame build()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: java.util.List traces>;
v = interfaceinvoke v.<java.util.List: int size()>();
if v >= 100 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: java.util.List traces>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return;
}
void setParentRpc(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc)
{
java.lang.AssertionError v, v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v, v, v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v = <org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc parentRpc>;
if v == null goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = <org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: boolean $assertionsDisabled>;
if v != 0 goto label;
if v != v goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc parentRpc> = v;
return;
}
final void callback(java.lang.Object)
{
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: java.lang.Object;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: void handleCallback(java.lang.Object)>(v);
return;
}
final void errback(java.lang.Exception)
{
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
java.lang.Exception v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: java.lang.Exception;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: void handleCallback(java.lang.Object)>(v);
return;
}
final org.apache.hive.kudu.com.stumbleupon.async.Deferred getDeferred()
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.com.stumbleupon.async.Deferred deferred>;
if v != null goto label;
v = new org.apache.hive.kudu.com.stumbleupon.async.Deferred;
specialinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.com.stumbleupon.async.Deferred deferred> = v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.com.stumbleupon.async.Deferred deferred>;
return v;
}
boolean hasDeferred()
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.com.stumbleupon.async.Deferred deferred>;
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet getTablet()
{
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet tablet>;
return v;
}
void setTablet(org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet)
{
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet;
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet tablet> = v;
return;
}
public org.apache.hive.kudu.org.apache.kudu.client.KuduTable getTable()
{
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.KuduRpc;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.KuduTable table>;
return v;
}
boolean isRequestTracked()
{
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
return 0;
}
long getSequenceId()
{
long v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: long sequenceId>;
return v;
}
org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection getReplicaSelection()
{
org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v = <org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection: org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection LEADER_ONLY>;
return v;
}
java.util.List getImmutableTraces()
{
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.ImmutableList v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: java.util.List traces>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.ImmutableList: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.ImmutableList copyOf(java.util.Collection)>(v);
return v;
}
void setSequenceId(long)
{
byte v;
long v, v;
java.lang.AssertionError v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v := @parameter: long;
v = <org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: long sequenceId>;
v = v cmp -1L;
if v == 0 goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: long sequenceId> = v;
return;
}
public java.lang.String toString()
{
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
int v;
java.lang.String v, v, v, v, v;
boolean v;
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.slf4j.Logger v;
org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker v;
java.util.List v, v;
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v, v;
java.lang.StringBuilder v, v, v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("KuduRpc(method=");
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: java.lang.String method()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", tablet=");
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet tablet>;
if v != null goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("null");
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet tablet>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet: java.lang.String getTabletId()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", attempt=");
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: int attempt>;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", ");
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker timeoutTracker>;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", ");
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: java.util.List traces>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame: java.lang.String getHumanReadableStringForTraces(java.util.List)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", deferred=");
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.com.stumbleupon.async.Deferred deferred>;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", ");
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: java.util.List traces>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.RpcTraceFrame: java.lang.String getHumanReadableSummaryStringForTraces(java.util.List)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(41);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
static void readProtobuf(org.apache.hive.kudu.org.apache.kudu.util.Slice, org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message$Builder)
{
org.apache.hive.kudu.org.apache.kudu.util.Slice v;
byte[] v;
java.lang.RuntimeException v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message$Builder v;
int v, v;
java.lang.String v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.InvalidProtocolBufferException v;
boolean v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.util.Slice;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message$Builder;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Slice: int length()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Slice: byte[] getRawArray()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Slice: int getRawOffset()>();
label:
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message$Builder: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message$Builder mergeFrom(byte[],int,int)>(v, v, v);
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message$Builder: boolean isInitialized()>();
if v != 0 goto label;
v = new java.lang.RuntimeException;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message$Builder: java.lang.String getInitializationErrorString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Could not deserialize the response, incompatible RPC? Error is: \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Invalid RPC response: length=\u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.InvalidProtocolBufferException from label to label with label;
}
static void toByteBuf(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf, org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message, org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message)
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
java.io.IOException v;
java.lang.RuntimeException v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.CodedOutputStream v;
int v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message v, v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufOutputStream v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message;
v = newarray (org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message)[2];
v[0] = v;
v[1] = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.IPCUtil: int getTotalSizeWhenWrittenDelimited(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message[])>(v);
v = v + 4;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf capacity(int)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf writeInt(int)>(v);
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufOutputStream;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufOutputStream: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.CodedOutputStream: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.CodedOutputStream newInstance(java.io.OutputStream,int)>(v, v);
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message: int getSerializedSize()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.CodedOutputStream: void writeUInt32NoTag(int)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message: void writeTo(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.CodedOutputStream)>(v);
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message: int getSerializedSize()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.CodedOutputStream: void writeUInt32NoTag(int)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message: void writeTo(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.CodedOutputStream)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.CodedOutputStream: void flush()>();
label:
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBufOutputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Cannot serialize the following message \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
catch java.io.IOException from label to label with label;
}
static void <clinit>()
{
org.slf4j.Logger v;
java.lang.Class v;
boolean v, v;
v = class "Lorg/apache/hive/kudu/org/apache/kudu/client/KuduRpc;";
v = virtualinvoke v.<java.lang.Class: boolean desiredAssertionStatus()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: boolean $assertionsDisabled> = v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/client/KuduRpc;");
<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.slf4j.Logger LOG> = v;
return;
}
}