public class org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder extends org.apache.hive.kudu.org.apache.kudu.client.AbstractKuduScannerBuilder
{
private static final int DEFAULT_SPLIT_SIZE_BYTES;
private long timeout;
private long splitSizeBytes;
void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient, org.apache.hive.kudu.org.apache.kudu.client.KuduTable)
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder v;
long v;
org.apache.hive.kudu.org.apache.kudu.client.KuduTable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduTable;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AbstractKuduScannerBuilder: void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient,org.apache.hive.kudu.org.apache.kudu.client.KuduTable)>(v, v);
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: long splitSizeBytes> = -1L;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: long getDefaultOperationTimeoutMs()>();
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: long timeout> = v;
return;
}
public org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder setTimeout(long)
{
org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder v;
long v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder;
v := @parameter: long;
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: long timeout> = v;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder setSplitSizeBytes(long)
{
org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder v;
long v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder;
v := @parameter: long;
v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: long splitSizeBytes> = v;
return v;
}
public java.util.List build()
{
byte[] v, v, v, v, v, v, v, v, v, v, v, v, v;
byte v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString v, v, v, v, v, v, v, v;
java.util.Map v, v;
org.apache.hive.kudu.org.apache.kudu.Common$ReadMode v;
org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder v;
long v, v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder v, v;
org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB v;
org.apache.hive.kudu.org.apache.kudu.Schema v;
org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode v, v, v;
org.apache.hive.kudu.org.apache.kudu.Common$ColumnPredicatePB v;
java.util.Collection v, v;
org.apache.hive.kudu.org.apache.kudu.Common$ReplicaSelection v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection v, v, v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken v;
java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.KuduTable v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.LocatedTablet v;
java.lang.Exception v;
org.apache.hive.kudu.org.apache.kudu.Common$ColumnSchemaPB$Builder v, v, v;
java.util.ArrayList v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.KuduPredicate$PredicateType v, v;
java.lang.String v, v, v, v;
java.lang.RuntimeException v;
org.apache.hive.kudu.org.apache.kudu.ColumnSchema v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.List v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.util.Pair v;
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
java.util.Iterator v, v, v, v, v, v;
java.lang.IllegalArgumentException v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: byte[] lowerBoundPartitionKey>;
v = lengthof v;
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: byte[] upperBoundPartitionKey>;
v = lengthof v;
if v == 0 goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Partition key bounds may not be set on KuduScanTokenBuilder");
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: 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.client.KuduPredicate$PredicateType getType()>();
v = <org.apache.hive.kudu.org.apache.kudu.client.KuduPredicate$PredicateType: org.apache.hive.kudu.org.apache.kudu.client.KuduPredicate$PredicateType NONE>;
if v != v goto label;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
return v;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder newBuilder()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: org.apache.hive.kudu.org.apache.kudu.client.KuduTable table>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduTable: java.lang.String getTableId()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setTableId(java.lang.String)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: org.apache.hive.kudu.org.apache.kudu.client.KuduTable table>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduTable: java.lang.String getName()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setTableName(java.lang.String)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: 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.Schema getSchema()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: java.util.List projectedColumnNames>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: java.util.List projectedColumnNames>;
v = interfaceinvoke v.<java.util.List: 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.Schema: org.apache.hive.kudu.org.apache.kudu.ColumnSchema getColumn(java.lang.String)>(v);
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: void checkArgument(boolean,java.lang.String,java.lang.Object)>(v, "unknown column i%s", v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.Common$ColumnSchemaPB$Builder addProjectedColumnsBuilder()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.Schema: boolean hasColumnIds()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.Schema: int getColumnId(java.lang.String)>(v);
goto label;
label:
v = (int) -1;
v = v;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.ProtobufHelper: org.apache.hive.kudu.org.apache.kudu.Common$ColumnSchemaPB columnToPb(org.apache.hive.kudu.org.apache.kudu.Common$ColumnSchemaPB$Builder,int,org.apache.hive.kudu.org.apache.kudu.ColumnSchema)>(v, v, v);
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: java.util.List projectedColumnIndexes>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: java.util.List projectedColumnIndexes>;
v = interfaceinvoke v.<java.util.List: 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.<java.lang.Integer: int intValue()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.Schema: org.apache.hive.kudu.org.apache.kudu.ColumnSchema getColumnByIndex(int)>(v);
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: void checkArgument(boolean,java.lang.String,int)>(v, "unknown column index %s", v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.Common$ColumnSchemaPB$Builder addProjectedColumnsBuilder()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.Schema: boolean hasColumnIds()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.ColumnSchema: java.lang.String getName()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.Schema: int getColumnId(java.lang.String)>(v);
goto label;
label:
v = (int) -1;
v = v;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.ProtobufHelper: org.apache.hive.kudu.org.apache.kudu.Common$ColumnSchemaPB columnToPb(org.apache.hive.kudu.org.apache.kudu.Common$ColumnSchemaPB$Builder,int,org.apache.hive.kudu.org.apache.kudu.ColumnSchema)>(v, v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.Schema: java.util.List getColumns()>();
v = interfaceinvoke v.<java.util.List: 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.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.Common$ColumnSchemaPB$Builder addProjectedColumnsBuilder()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.Schema: boolean hasColumnIds()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.ColumnSchema: java.lang.String getName()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.Schema: int getColumnId(java.lang.String)>(v);
goto label;
label:
v = (int) -1;
v = v;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.ProtobufHelper: org.apache.hive.kudu.org.apache.kudu.Common$ColumnSchemaPB columnToPb(org.apache.hive.kudu.org.apache.kudu.Common$ColumnSchemaPB$Builder,int,org.apache.hive.kudu.org.apache.kudu.ColumnSchema)>(v, v, v);
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: 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.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$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.KuduScanToken$KuduScanTokenBuilder: byte[] lowerBoundPrimaryKey>;
v = lengthof v;
if v <= 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: byte[] lowerBoundPrimaryKey>;
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.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setLowerBoundPrimaryKey(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: byte[] upperBoundPrimaryKey>;
v = lengthof v;
if v <= 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: byte[] upperBoundPrimaryKey>;
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.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setUpperBoundPrimaryKey(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: long limit>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setLimit(long)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode readMode>;
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.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setReadMode(org.apache.hive.kudu.org.apache.kudu.Common$ReadMode)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection replicaSelection>;
v = <org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection: org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection LEADER_ONLY>;
if v != v goto label;
v = <org.apache.hive.kudu.org.apache.kudu.Common$ReplicaSelection: org.apache.hive.kudu.org.apache.kudu.Common$ReplicaSelection LEADER_ONLY>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setReplicaSelection(org.apache.hive.kudu.org.apache.kudu.Common$ReplicaSelection)>(v);
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection replicaSelection>;
v = <org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection: org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection CLOSEST_REPLICA>;
if v != v goto label;
v = <org.apache.hive.kudu.org.apache.kudu.Common$ReplicaSelection: org.apache.hive.kudu.org.apache.kudu.Common$ReplicaSelection CLOSEST_REPLICA>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setReplicaSelection(org.apache.hive.kudu.org.apache.kudu.Common$ReplicaSelection)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: 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()>();
v = v cmp -1L;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient client>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: long getLastPropagatedTimestamp()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setPropagatedTimestamp(long)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: 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_AT_SNAPSHOT>;
if v != v goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: long htTimestamp>;
v = v cmp -1L;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: long htTimestamp>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setSnapTimestamp(long)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: long startTimestamp>;
v = v cmp -1L;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: long startTimestamp>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setSnapStartTimestamp(long)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: boolean cacheBlocks>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setCacheBlocks(boolean)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: boolean isFaultTolerant>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setFaultTolerant(boolean)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: int batchSizeBytes>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setBatchSizeBytes(int)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: long scanRequestTimeout>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setScanRequestTimeoutMs(long)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: long keepAlivePeriodMs>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setKeepAlivePeriodMs(long)>(v);
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner: org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner create(org.apache.hive.kudu.org.apache.kudu.client.AbstractKuduScannerBuilder)>(v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner: boolean hasMorePartitionKeyRanges()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner: org.apache.hive.kudu.org.apache.kudu.util.Pair nextPartitionKeyRange()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient client>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: org.apache.hive.kudu.org.apache.kudu.client.KuduTable table>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString getLowerBoundPrimaryKey()>();
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.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString getUpperBoundPrimaryKey()>();
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.util.Pair: java.lang.Object getFirst()>();
v = lengthof v;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Pair: java.lang.Object getFirst()>();
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Pair: java.lang.Object getSecond()>();
v = lengthof v;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Pair: java.lang.Object getSecond()>();
label:
v = <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: int FETCH_TABLETS_PER_RANGE_LOOKUP>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: long splitSizeBytes>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken$KuduScanTokenBuilder: long timeout>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.com.stumbleupon.async.Deferred getTableKeyRanges(org.apache.hive.kudu.org.apache.kudu.client.KuduTable,byte[],byte[],byte[],byte[],int,long,long)>(v, v, v, v, v, v, v, v);
v = virtualinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: java.lang.Object join()>();
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.util.Pair: java.lang.Object getSecond()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner: void removePartitionKeyRange(byte[])>(v);
goto label;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
v = v - 1;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KeyRange: byte[] getPartitionKeyEnd()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner: void removePartitionKeyRange(byte[])>(v);
label:
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
goto label;
label:
v = new java.util.ArrayList;
v = interfaceinvoke v.<java.util.List: int size()>();
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = interfaceinvoke v.<java.util.List: 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.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder clone()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KeyRange: byte[] getPartitionKeyStart()>();
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.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setLowerBoundPartitionKey(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KeyRange: byte[] getPartitionKeyEnd()>();
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.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setUpperBoundPartitionKey(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KeyRange: byte[] getPrimaryKeyStart()>();
if v == null goto label;
v = lengthof v;
if v <= 0 goto label;
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.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setLowerBoundPrimaryKey(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString)>(v);
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KeyRange: byte[] getPrimaryKeyEnd()>();
if v == null goto label;
v = lengthof v;
if v <= 0 goto label;
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.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder setUpperBoundPrimaryKey(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.protobuf.ByteString)>(v);
label:
v = new org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KeyRange: org.apache.hive.kudu.org.apache.kudu.client.LocatedTablet getTablet()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB$Builder: org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB build()>();
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduScanToken: void <init>(org.apache.hive.kudu.org.apache.kudu.client.LocatedTablet,org.apache.hive.kudu.org.apache.kudu.client.Client$ScanTokenPB)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
catch java.lang.Exception from label to label with label;
}
}