final class org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest extends org.apache.hive.kudu.org.apache.kudu.client.KuduRpc
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State state;
private org.apache.hive.kudu.org.apache.kudu.security.Token$SignedTokenPB authzToken;
final org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0;
void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner, org.apache.hive.kudu.org.apache.kudu.client.KuduTable, org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State, org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet)
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
long v;
org.apache.hive.kudu.org.apache.kudu.client.KuduTable v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State v;
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduTable;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient client>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.Timer getTimer()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long scanRequestTimeout>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: void <init>(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);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: void setTablet(org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State state> = v;
return;
}
java.lang.String serviceName()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest;
return "kudu.tserver.TabletServerService";
}
java.lang.String method()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest;
return "Scan";
}
java.util.Collection getRequiredFeatures()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.ImmutableList v, v;
java.util.Map v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
java.lang.Integer v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: java.util.Map predicates>;
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
if v == 0 goto label;
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;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
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(java.lang.Object)>(v);
return v;
}
org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection getReplicaSelection()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest v;
org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection replicaSelection>;
return v;
}
boolean needsAuthzToken()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest;
return 1;
}
void bindAuthzToken(org.apache.hive.kudu.org.apache.kudu.security.Token$SignedTokenPB)
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest v;
org.apache.hive.kudu.org.apache.kudu.security.Token$SignedTokenPB v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.security.Token$SignedTokenPB;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.security.Token$SignedTokenPB authzToken> = v;
return;
}
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message createRequestPB()
{
byte[] v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.KuduTable v;
org.apache.hive.kudu.org.apache.kudu.Common$OrderMode v;
byte v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString v, v, v, v, v, v;
java.util.Map v;
org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB v;
org.apache.hive.kudu.org.apache.kudu.Common$ReadMode v;
long v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.Schema v;
java.lang.RuntimeException v;
org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode v, v, v, v, v;
int[] v;
org.apache.hive.kudu.org.apache.kudu.Common$ColumnPredicatePB v;
boolean v, v, v;
java.util.Collection v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
int v, v, v, v, v, v, v, v;
java.util.Iterator v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State v;
org.apache.hive.kudu.org.apache.kudu.security.Token$SignedTokenPB v, v;
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v, v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder newBuilder()>();
v = <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$7: int[] $SwitchMap$org$apache$kudu$client$AsyncKuduScanner$State>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State state>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
default: goto label;
};
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet getTablet()>();
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet tablet> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder newBuilder()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long limit>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long numRowsReturned>;
v = v - v;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder setLimit(long)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.Schema schema>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.ProtobufHelper: java.util.List schemaToListPb(org.apache.hive.kudu.org.apache.kudu.Schema)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder addAllProjectedColumns(java.lang.Iterable)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet tablet>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet: byte[] getTabletIdAsBytes()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.UnsafeByteOperations: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString unsafeWrap(byte[])>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder setTabletId(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.Common$OrderMode getOrderMode()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder setOrderMode(org.apache.hive.kudu.org.apache.kudu.Common$OrderMode)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean cacheBlocks>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder setCacheBlocks(boolean)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode readMode>;
v = <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode READ_YOUR_WRITES>;
if v != v goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long lowerBoundPropagationTimestamp>;
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: 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: long getLastPropagatedTimestamp()>();
label:
v = v cmp -1L;
if v == 0 goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder setPropagatedTimestamp(long)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode getReadMode()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode: org.apache.hive.kudu.org.apache.kudu.Common$ReadMode pbVersion()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder setReadMode(org.apache.hive.kudu.org.apache.kudu.Common$ReadMode)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode getReadMode()>();
v = <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode READ_AT_SNAPSHOT>;
if v != v goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long getSnapshotTimestamp()>();
v = v cmp -1L;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long getSnapshotTimestamp()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder setSnapTimestamp(long)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long getStartSnapshotTimestamp()>();
v = v cmp -1L;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long getStartSnapshotTimestamp()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder setSnapStartTimestamp(long)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean isFaultTolerant>;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] lastPrimaryKey>;
v = lengthof v;
if v <= 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] lastPrimaryKey>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.UnsafeByteOperations: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString unsafeWrap(byte[])>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder setLastPrimaryKey(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] startPrimaryKey>;
v = lengthof v;
if v <= 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] startPrimaryKey>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.UnsafeByteOperations: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString unsafeWrap(byte[])>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder setStartPrimaryKey(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] endPrimaryKey>;
v = lengthof v;
if v <= 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] endPrimaryKey>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.UnsafeByteOperations: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString unsafeWrap(byte[])>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder setStopPrimaryKey(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: java.util.Map predicates>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduPredicate: org.apache.hive.kudu.org.apache.kudu.Common$ColumnPredicatePB toPB()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder addColumnPredicates(org.apache.hive.kudu.org.apache.kudu.Common$ColumnPredicatePB)>(v);
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.security.Token$SignedTokenPB authzToken>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.security.Token$SignedTokenPB authzToken>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder setAuthzToken(org.apache.hive.kudu.org.apache.kudu.security.Token$SignedTokenPB)>(v);
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB build()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder setNewScanRequest(org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$NewScanRequestPB)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: int batchSizeBytes>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder setBatchSizeBytes(int)>(v);
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] scannerId>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.UnsafeByteOperations: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString unsafeWrap(byte[])>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder setScannerId(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: int sequenceId>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder setCallSeqId(int)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: int batchSizeBytes>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder setBatchSizeBytes(int)>(v);
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] scannerId>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.UnsafeByteOperations: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString unsafeWrap(byte[])>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder setScannerId(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder setBatchSizeBytes(int)>(0);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder setCloseScanner(boolean)>(1);
goto label;
label:
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("unreachable!");
throw v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanRequestPB build()>();
return v;
}
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
{
byte[] v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString v, v;
org.apache.hive.kudu.org.apache.kudu.util.Slice v;
org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB$Code v;
org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB v;
org.apache.hive.kudu.org.apache.kudu.client.RowResultIterator v;
long v, v, v;
org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ResourceMetricsPB v, v;
java.lang.String v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException v, v;
org.apache.hive.kudu.org.apache.kudu.Schema v;
org.apache.hive.kudu.org.apache.kudu.WireProtocol$RowwiseRowBlockPB v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest v;
org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB$Builder v;
int[] v;
boolean v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker v;
org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB v, v;
org.apache.hive.kudu.org.apache.kudu.client.FaultTolerantScannerExpiredException v;
org.apache.hive.kudu.org.apache.kudu.client.CallResponse v;
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.util.Pair v, v;
org.slf4j.Logger v, v;
org.apache.hive.kudu.org.apache.kudu.client.Status v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.CallResponse;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB$Builder newBuilder()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.CallResponse: org.apache.hive.kudu.org.apache.kudu.util.Slice getPBMessage()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: void readProtobuf(org.apache.hive.kudu.org.apache.kudu.util.Slice,org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.Message$Builder)>(v, v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB$Builder: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB build()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString getScannerId()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString: byte[] toByteArray()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB: boolean hasError()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB getError()>();
goto label;
label:
v = null;
label:
v = v;
if v == null goto label;
v = <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$7: int[] $SwitchMap$org$apache$kudu$tserver$Tserver$TabletServerErrorPB$Code>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB$Code getCode()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB$Code: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
default: goto label;
};
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State state>;
v = <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State OPENING>;
if v == v goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State state>;
v = <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State NEXT>;
if v != v goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean isFaultTolerant>;
if v == 0 goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.util.Pair;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Pair: void <init>(java.lang.Object,java.lang.Object)>(null, v);
return v;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Status: org.apache.hive.kudu.org.apache.kudu.client.Status Incomplete(java.lang.String)>("Cannot continue scanning, the tablet has moved and this isn\'t a fault tolerant scan");
v = new org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException: void <init>(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v);
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean isFaultTolerant>;
if v == 0 goto label;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Status: org.apache.hive.kudu.org.apache.kudu.client.Status fromTabletServerErrorPB(org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$TabletServerErrorPB)>(v);
v = new org.apache.hive.kudu.org.apache.kudu.client.FaultTolerantScannerExpiredException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.FaultTolerantScannerExpiredException: void <init>(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v);
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker timeoutTracker>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.TimeoutTracker: long getElapsedMillis()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.Schema schema>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB: org.apache.hive.kudu.org.apache.kudu.WireProtocol$RowwiseRowBlockPB getData()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean reuseRowResult>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.RowResultIterator: org.apache.hive.kudu.org.apache.kudu.client.RowResultIterator makeRowResultIterator(long,java.lang.String,org.apache.hive.kudu.org.apache.kudu.Schema,org.apache.hive.kudu.org.apache.kudu.WireProtocol$RowwiseRowBlockPB,org.apache.hive.kudu.org.apache.kudu.client.CallResponse,boolean)>(v, v, v, v, v, v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB: boolean getHasMoreResults()>();
v = lengthof v;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] scannerId>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] scannerId>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Bytes: boolean equals(byte[],byte[])>(v, v);
if v != 0 goto label;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Bytes: java.lang.String pretty(byte[])>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] scannerId>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Bytes: java.lang.String pretty(byte[])>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("Scan RPC response was for scanner ID \u but we expected \u0001");
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Status: org.apache.hive.kudu.org.apache.kudu.client.Status IllegalState(java.lang.String)>(v);
v = new org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.NonRecoverableException: void <init>(org.apache.hive.kudu.org.apache.kudu.client.Status)>(v);
throw v;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB: boolean hasResourceMetrics()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ResourceMetricsPB getResourceMetrics()>();
goto label;
label:
v = null;
label:
v = v;
v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB: boolean hasSnapTimestamp()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB: long getSnapTimestamp()>();
goto label;
label:
v = -1L;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB: boolean hasPropagatedTimestamp()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB: long getPropagatedTimestamp()>();
goto label;
label:
v = -1L;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ScanResponsePB: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString getLastPrimaryKey()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString: byte[] toByteArray()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response: void <init>(byte[],org.apache.hive.kudu.org.apache.kudu.client.RowResultIterator,boolean,long,long,byte[],org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ResourceMetricsPB)>(v, v, v, v, v, v, v);
v = <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response: java.lang.String toString()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{} for scanner {}", v, v);
label:
v = new org.apache.hive.kudu.org.apache.kudu.util.Pair;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Pair: void <init>(java.lang.Object,java.lang.Object)>(v, v);
return v;
}
public java.lang.String toString()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest v;
byte[] v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v, v;
int v;
java.lang.String v, v, v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] scannerId>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Bytes: java.lang.String pretty(byte[])>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet tablet>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: 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()>();
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[])>(", tablet=\u0001");
goto label;
label:
v = "";
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: int attempt>;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduRpc: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,int,java.lang.String)>(v, v, v, 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[])>("ScanRequest(scannerId=\u0001\u, attempt=\u, \u)");
return v;
}
public byte[] partitionKey()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest v;
byte[] v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner pruner>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner: byte[] nextPartitionKey()>();
return v;
}
}