public final class org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner extends java.lang.Object
{
private static final org.slf4j.Logger LOG;
static final java.lang.String DEFAULT_IS_DELETED_COL_NAME;
private final org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient client;
private final org.apache.hive.kudu.org.apache.kudu.client.KuduTable table;
private final org.apache.hive.kudu.org.apache.kudu.Schema schema;
private final org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner pruner;
private final java.util.Map predicates;
private final int batchSizeBytes;
private final long limit;
private final byte[] startPrimaryKey;
private final byte[] endPrimaryKey;
private byte[] lastPrimaryKey;
private final boolean prefetching;
private final boolean cacheBlocks;
private final org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode readMode;
private final org.apache.hive.kudu.org.apache.kudu.Common$OrderMode orderMode;
private final boolean isFaultTolerant;
private final long startTimestamp;
private long htTimestamp;
private long lowerBoundPropagationTimestamp;
private final org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection replicaSelection;
private final long keepAlivePeriodMs;
private boolean reuseRowResult;
private final org.apache.hive.kudu.org.apache.kudu.client.ResourceMetrics resourceMetrics;
private boolean closed;
private boolean hasMore;
private long numRowsReturned;
private org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet tablet;
private byte[] scannerId;
private int sequenceId;
private org.apache.hive.kudu.com.stumbleupon.async.Deferred prefetcherDeferred;
final long scanRequestTimeout;
private final org.apache.hive.kudu.com.stumbleupon.async.Callback prefetch;
private final org.apache.hive.kudu.com.stumbleupon.async.Callback gotNextRow;
void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient, org.apache.hive.kudu.org.apache.kudu.client.KuduTable, java.util.List, java.util.List, org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode, boolean, long, java.util.Map, long, boolean, boolean, byte[], byte[], long, long, int, org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner, org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection, long)
{
byte[] v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.KuduTable v;
org.apache.hive.kudu.org.apache.kudu.Common$OrderMode v, v;
byte v, v, v, v, v, v, v;
java.util.Map v;
long v, v, v, v, v, v;
java.util.ArrayList v;
org.apache.hive.kudu.org.apache.kudu.Schema v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.ColumnSchema v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$3 v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$4 v;
boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
java.util.List v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v, v;
org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection v;
int v, v;
org.slf4j.Logger v;
java.util.Iterator v, v;
org.apache.hive.kudu.org.apache.kudu.client.ResourceMetrics v;
java.lang.Object v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.KuduTable;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode;
v := @parameter: boolean;
v := @parameter: long;
v := @parameter: java.util.Map;
v := @parameter: long;
v := @parameter: boolean;
v := @parameter: boolean;
v := @parameter: byte[];
v := @parameter: byte[];
v := @parameter: long;
v := @parameter: long;
v := @parameter: int;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection;
v := @parameter: long;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long lowerBoundPropagationTimestamp> = -1L;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean reuseRowResult> = 0;
v = new org.apache.hive.kudu.org.apache.kudu.client.ResourceMetrics;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.ResourceMetrics: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.ResourceMetrics resourceMetrics> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean closed> = 0;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean hasMore> = 1;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long numRowsReturned> = 0L;
v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$3;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$3: void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.com.stumbleupon.async.Callback prefetch> = v;
v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$4;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$4: void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.com.stumbleupon.async.Callback gotNextRow> = v;
if v < 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: void checkArgument(boolean,java.lang.String,int)>(v, "Need non-negative number of bytes, got %s", v);
v = v cmp 0L;
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: void checkArgument(boolean,java.lang.String,long)>(v, "Need a strictly positive number for the limit, got %s", v);
v = v cmp -1L;
if v == 0 goto label;
v = v cmp 0L;
if v < 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: void checkArgument(boolean,java.lang.String,long)>(v, "Need non-negative number for the scan,  timestamp got %s", v);
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 = 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.Object)>(v, "When specifying a HybridClock timestamp, the read mode needs to be set to READ_AT_SNAPSHOT");
label:
v = v cmp -1L;
if v == 0 goto label;
v = v cmp 0L;
if v < 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: void checkArgument(boolean,java.lang.Object)>(v, "Must have both start and end timestamps for a diff scan");
v = v cmp v;
if v > 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: void checkArgument(boolean,java.lang.Object)>(v, "Start timestamp must be less than or equal to end timestamp");
label:
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean isFaultTolerant> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean isFaultTolerant>;
if v == 0 goto label;
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 = 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.Object)>(v, "Use of fault tolerance scanner requires the read mode to be set to READ_AT_SNAPSHOT");
v = <org.apache.hive.kudu.org.apache.kudu.Common$OrderMode: org.apache.hive.kudu.org.apache.kudu.Common$OrderMode ORDERED>;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.Common$OrderMode orderMode> = v;
goto label;
label:
v = <org.apache.hive.kudu.org.apache.kudu.Common$OrderMode: org.apache.hive.kudu.org.apache.kudu.Common$OrderMode UNORDERED>;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.Common$OrderMode orderMode> = v;
label:
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient client> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.KuduTable table> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner pruner> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode readMode> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long scanRequestTimeout> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: java.util.Map predicates> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long limit> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean cacheBlocks> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean prefetching> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] startPrimaryKey> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] endPrimaryKey> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long startTimestamp> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long htTimestamp> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: int batchSizeBytes> = v;
v = <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: byte[] EMPTY_ARRAY>;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] lastPrimaryKey> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
if v == null goto label;
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.KuduTable: org.apache.hive.kudu.org.apache.kudu.Schema getSchema()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.Schema: org.apache.hive.kudu.org.apache.kudu.ColumnSchema getColumn(java.lang.String)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.ColumnSchema getStrippedColumnSchema(org.apache.hive.kudu.org.apache.kudu.ColumnSchema)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
if v == null goto label;
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.KuduTable: org.apache.hive.kudu.org.apache.kudu.Schema getSchema()>();
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);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.ColumnSchema getStrippedColumnSchema(org.apache.hive.kudu.org.apache.kudu.ColumnSchema)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduTable: org.apache.hive.kudu.org.apache.kudu.Schema getSchema()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.Schema: java.util.List getColumns()>();
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
label:
v = v cmp -1L;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.KuduTable: org.apache.hive.kudu.org.apache.kudu.Schema getSchema()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.ColumnSchema generateIsDeletedColumn(org.apache.hive.kudu.org.apache.kudu.Schema)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = new org.apache.hive.kudu.org.apache.kudu.Schema;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.Schema: void <init>(java.util.List)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.Schema schema> = v;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner: boolean hasMorePartitionKeyRanges()>();
if v != 0 goto label;
v = <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Short circuiting scan");
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean hasMore> = 0;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean closed> = 1;
label:
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection replicaSelection> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long keepAlivePeriodMs> = v;
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: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient client>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: long getLastPropagatedTimestamp()>();
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long lowerBoundPropagationTimestamp> = v;
label:
return;
}
private static org.apache.hive.kudu.org.apache.kudu.ColumnSchema generateIsDeletedColumn(org.apache.hive.kudu.org.apache.kudu.Schema)
{
org.apache.hive.kudu.org.apache.kudu.Schema v;
org.apache.hive.kudu.org.apache.kudu.ColumnSchema v;
org.apache.hive.kudu.org.apache.kudu.Common$DataType v;
java.lang.Boolean v;
java.lang.StringBuilder v;
java.lang.String v, v;
org.apache.hive.kudu.org.apache.kudu.Type v;
org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder v, v, v, v, v;
boolean v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.Schema;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>(java.lang.String)>("is_deleted");
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.Schema: boolean hasColumn(java.lang.String)>(v);
if v == 0 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("_");
goto label;
label:
v = new org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
v = <org.apache.hive.kudu.org.apache.kudu.Type: org.apache.hive.kudu.org.apache.kudu.Type BOOL>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder: void <init>(java.lang.String,org.apache.hive.kudu.org.apache.kudu.Type)>(v, v);
v = <org.apache.hive.kudu.org.apache.kudu.Common$DataType: org.apache.hive.kudu.org.apache.kudu.Common$DataType IS_DELETED>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder: org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder wireType(org.apache.hive.kudu.org.apache.kudu.Common$DataType)>(v);
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(0);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder: org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder defaultValue(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder: org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder nullable(boolean)>(0);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder: org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder key(boolean)>(0);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder: org.apache.hive.kudu.org.apache.kudu.ColumnSchema build()>();
return v;
}
private static org.apache.hive.kudu.org.apache.kudu.ColumnSchema getStrippedColumnSchema(org.apache.hive.kudu.org.apache.kudu.ColumnSchema)
{
org.apache.hive.kudu.org.apache.kudu.ColumnSchema v, v;
org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder v, v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.ColumnSchema;
v = new org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder: void <init>(org.apache.hive.kudu.org.apache.kudu.ColumnSchema)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder: org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder key(boolean)>(0);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.ColumnSchema$ColumnSchemaBuilder: org.apache.hive.kudu.org.apache.kudu.ColumnSchema build()>();
return v;
}
public long getLimit()
{
long v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long limit>;
return v;
}
public boolean hasMoreRows()
{
boolean v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean hasMore>;
return v;
}
public boolean getCacheBlocks()
{
boolean v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean cacheBlocks>;
return v;
}
public long getBatchSizeBytes()
{
int v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: int batchSizeBytes>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode getReadMode()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode readMode>;
return v;
}
private org.apache.hive.kudu.org.apache.kudu.Common$OrderMode getOrderMode()
{
org.apache.hive.kudu.org.apache.kudu.Common$OrderMode v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.Common$OrderMode orderMode>;
return v;
}
public long getScanRequestTimeout()
{
long v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long scanRequestTimeout>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.Schema getProjectionSchema()
{
org.apache.hive.kudu.org.apache.kudu.Schema v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.Schema schema>;
return v;
}
public long getKeepAlivePeriodMs()
{
long v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long keepAlivePeriodMs>;
return v;
}
long getStartSnapshotTimestamp()
{
long v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long startTimestamp>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.client.ResourceMetrics getResourceMetrics()
{
org.apache.hive.kudu.org.apache.kudu.client.ResourceMetrics v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.ResourceMetrics resourceMetrics>;
return v;
}
long getSnapshotTimestamp()
{
long v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long htTimestamp>;
return v;
}
public void setReuseRowResult(boolean)
{
boolean v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v := @parameter: boolean;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean reuseRowResult> = v;
return;
}
public org.apache.hive.kudu.com.stumbleupon.async.Deferred nextRows()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v, v;
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$2 v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1 v;
org.apache.hive.kudu.com.stumbleupon.async.Callback v, v, v, v;
boolean v, v, v;
org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean closed>;
if v == 0 goto label;
v = staticinvoke <org.apache.hive.kudu.com.stumbleupon.async.Deferred: org.apache.hive.kudu.com.stumbleupon.async.Deferred fromResult(java.lang.Object)>(null);
return v;
label:
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 = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1: void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner)>(v);
v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$2;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$2: void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner)>(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.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.KuduRpc getOpenRequest()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: org.apache.hive.kudu.com.stumbleupon.async.Deferred sendRpcToTablet(org.apache.hive.kudu.org.apache.kudu.client.KuduRpc)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: org.apache.hive.kudu.com.stumbleupon.async.Deferred addCallbackDeferring(org.apache.hive.kudu.com.stumbleupon.async.Callback)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: org.apache.hive.kudu.com.stumbleupon.async.Deferred addErrback(org.apache.hive.kudu.com.stumbleupon.async.Callback)>(v);
return v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean prefetching>;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.com.stumbleupon.async.Deferred prefetcherDeferred>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.com.stumbleupon.async.Deferred prefetcherDeferred>;
v = new org.apache.hive.kudu.com.stumbleupon.async.Deferred;
specialinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: void <init>()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.com.stumbleupon.async.Callback prefetch>;
v = virtualinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: org.apache.hive.kudu.com.stumbleupon.async.Deferred addCallback(org.apache.hive.kudu.com.stumbleupon.async.Callback)>(v);
virtualinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: org.apache.hive.kudu.com.stumbleupon.async.Deferred chain(org.apache.hive.kudu.com.stumbleupon.async.Deferred)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.com.stumbleupon.async.Deferred prefetcherDeferred>;
return v;
label:
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.com.stumbleupon.async.Deferred scanNextRows(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.com.stumbleupon.async.Callback gotNextRow>;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.com.stumbleupon.async.Callback nextRowErrback()>();
v = virtualinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: org.apache.hive.kudu.com.stumbleupon.async.Deferred addCallbacks(org.apache.hive.kudu.com.stumbleupon.async.Callback,org.apache.hive.kudu.com.stumbleupon.async.Callback)>(v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean prefetching>;
if v == 0 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 = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.com.stumbleupon.async.Callback prefetch>;
v = virtualinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: org.apache.hive.kudu.com.stumbleupon.async.Deferred addCallback(org.apache.hive.kudu.com.stumbleupon.async.Callback)>(v);
virtualinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: org.apache.hive.kudu.com.stumbleupon.async.Deferred chain(org.apache.hive.kudu.com.stumbleupon.async.Deferred)>(v);
label:
return v;
}
private final org.apache.hive.kudu.com.stumbleupon.async.Callback nextRowErrback()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$5 v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$5;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$5: void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner)>(v);
return v;
}
void scanFinished()
{
byte[] v, v, v;
java.lang.Object[] v;
org.apache.hive.kudu.org.apache.kudu.client.Partition v, v;
long v, v;
byte v;
java.lang.String v, v;
boolean v, v;
org.slf4j.Logger v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
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: org.apache.hive.kudu.org.apache.kudu.client.Partition getPartition()>();
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.Partition: byte[] getPartitionKeyEnd()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.PartitionPruner: void removePartitionKeyRange(byte[])>(v);
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: boolean hasMorePartitionKeyRanges()>();
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long numRowsReturned>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long limit>;
v = v cmp v;
if v < 0 goto label;
label:
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean hasMore> = 0;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean closed> = 1;
return;
label:
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 = newarray (java.lang.Object)[3];
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[0] = v;
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: org.apache.hive.kudu.org.apache.kudu.client.Partition getPartition()>();
v[1] = v;
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[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("Done scanning tablet {} for partition {} with scanner id {}", v);
label:
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] scannerId> = null;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: int sequenceId> = 0;
v = <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: byte[] EMPTY_ARRAY>;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] lastPrimaryKey> = v;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: void invalidate()>();
return;
}
public boolean isClosed()
{
boolean v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean closed>;
return v;
}
public org.apache.hive.kudu.com.stumbleupon.async.Deferred close()
{
org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
org.apache.hive.kudu.com.stumbleupon.async.Callback v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean closed>;
if v == 0 goto label;
v = staticinvoke <org.apache.hive.kudu.com.stumbleupon.async.Deferred: org.apache.hive.kudu.com.stumbleupon.async.Deferred fromResult(java.lang.Object)>(null);
return v;
label:
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.com.stumbleupon.async.Deferred closeScanner(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner)>(v);
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.com.stumbleupon.async.Callback closedCallback()>();
v = virtualinvoke v.<org.apache.hive.kudu.com.stumbleupon.async.Deferred: org.apache.hive.kudu.com.stumbleupon.async.Deferred addCallback(org.apache.hive.kudu.com.stumbleupon.async.Callback)>(v);
return v;
}
private org.apache.hive.kudu.com.stumbleupon.async.Callback closedCallback()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$6 v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$6;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$6: void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner)>(v);
return v;
}
public java.lang.String toString()
{
byte[] v, v, v, v, v;
long v;
org.apache.hive.kudu.org.apache.kudu.client.KuduTable v;
int v, v;
java.lang.String v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner 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.AsyncKuduScanner;
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 = "null";
goto label;
label:
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()>();
label:
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("KuduScanner(table=");
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: 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.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", tablet=");
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)>(", scannerId=");
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);
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)>(", scanRequestTimeout=");
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long scanRequestTimeout>;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(long)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] startPrimaryKey>;
v = lengthof v;
if v <= 0 goto label;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", startPrimaryKey=");
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] startPrimaryKey>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Bytes: java.lang.String hex(byte[])>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
goto label;
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", startPrimaryKey=<start>");
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] endPrimaryKey>;
v = lengthof v;
if v <= 0 goto label;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", endPrimaryKey=");
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] endPrimaryKey>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.Bytes: java.lang.String hex(byte[])>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
goto label;
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", endPrimaryKey=<end>");
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(41);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
org.apache.hive.kudu.org.apache.kudu.client.KuduTable table()
{
org.apache.hive.kudu.org.apache.kudu.client.KuduTable v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.KuduTable table>;
return v;
}
void invalidate()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet tablet> = null;
return;
}
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet currentTablet()
{
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet tablet>;
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.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.ReplicaSelection replicaSelection>;
return v;
}
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc getOpenRequest()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest v;
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
org.apache.hive.kudu.org.apache.kudu.client.KuduTable v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: void checkScanningNotStarted()>();
v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.KuduTable table>;
v = <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State OPENING>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet tablet>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: 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)>(v, v, v, v);
return v;
}
public org.apache.hive.kudu.com.stumbleupon.async.Deferred keepAlive()
{
java.lang.IllegalStateException v;
org.apache.hive.kudu.com.stumbleupon.async.Deferred v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean closed>;
if v == 0 goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Scanner has already been closed");
throw v;
label:
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.com.stumbleupon.async.Deferred keepAlive(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner)>(v);
return v;
}
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc getNextRowsRequest()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest v;
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
org.apache.hive.kudu.org.apache.kudu.client.KuduTable v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.KuduTable table>;
v = <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State NEXT>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet tablet>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: 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)>(v, v, v, v);
return v;
}
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc getCloseRequest()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest v;
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
org.apache.hive.kudu.org.apache.kudu.client.KuduTable v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.KuduTable table>;
v = <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$State CLOSING>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet tablet>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ScanRequest: 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)>(v, v, v, v);
return v;
}
org.apache.hive.kudu.org.apache.kudu.client.KuduRpc getKeepAliveRequest()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$KeepAliveRequest v;
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
org.apache.hive.kudu.org.apache.kudu.client.KuduTable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v = new org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$KeepAliveRequest;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.KuduTable table>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet tablet>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$KeepAliveRequest: 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.RemoteTablet)>(v, v, v);
return v;
}
private void checkScanningNotStarted()
{
java.lang.IllegalStateException v;
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
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 = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("scanning already started");
throw v;
label:
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/hive/kudu/org/apache/kudu/client/AsyncKuduScanner;");
<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: org.slf4j.Logger LOG> = v;
return;
}
}