class org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1 extends java.lang.Object implements org.apache.hive.kudu.com.stumbleupon.async.Callback
{
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.AsyncKuduScanner$1 v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public org.apache.hive.kudu.com.stumbleupon.async.Deferred call(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response) throws java.lang.Exception
{
byte[] v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$ReadMode v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1 v;
byte v, v, v, v, v;
boolean v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.RowResultIterator v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
long v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ResourceMetricsPB v, v;
int v;
java.lang.String v, v;
org.apache.hive.kudu.com.stumbleupon.async.Deferred v, v;
org.slf4j.Logger v, v;
org.apache.hive.kudu.org.apache.kudu.client.ResourceMetrics v;
org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long htTimestamp>;
v = v cmp -1L;
if v != 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response: long scanTimestamp>;
v = v cmp -1L;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response: long scanTimestamp>;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long htTimestamp> = v;
label:
v = -1L;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1: 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$Response: long scanTimestamp>;
v = v cmp -1L;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response: long scanTimestamp>;
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response: long propagatedTimestamp>;
v = v cmp -1L;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response: long propagatedTimestamp>;
label:
v = v cmp -1L;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1: 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.AsyncKuduClient client>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: void updateLastPropagatedTimestamp(long)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1: 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$Response: byte[] lastPrimaryKey>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response: byte[] lastPrimaryKey>;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] lastPrimaryKey> = v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response: org.apache.hive.kudu.org.apache.kudu.client.RowResultIterator data>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.RowResultIterator: int getNumRows()>();
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: long numRowsReturned> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ResourceMetricsPB resourceMetricsPb>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1: 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.ResourceMetrics resourceMetrics>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response: org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ResourceMetricsPB resourceMetricsPb>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.ResourceMetrics: void update(org.apache.hive.kudu.org.apache.kudu.tserver.Tserver$ResourceMetricsPB)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response: boolean more>;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response: byte[] scannerId>;
if v != null goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: void scanFinished()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response: org.apache.hive.kudu.org.apache.kudu.client.RowResultIterator data>;
v = staticinvoke <org.apache.hive.kudu.com.stumbleupon.async.Deferred: org.apache.hive.kudu.com.stumbleupon.async.Deferred fromResult(java.lang.Object)>(v);
return v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response: byte[] scannerId>;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: byte[] scannerId> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: int access$1508(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response: boolean more>;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner: boolean hasMore> = 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 = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1: 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$1: 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 = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,org.apache.hive.kudu.org.apache.kudu.client.RemoteTablet)>(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[])>("Scanner \u opened on \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$Response: org.apache.hive.kudu.org.apache.kudu.client.RowResultIterator data>;
v = staticinvoke <org.apache.hive.kudu.com.stumbleupon.async.Deferred: org.apache.hive.kudu.com.stumbleupon.async.Deferred fromResult(java.lang.Object)>(v);
return v;
}
public java.lang.String toString()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1 v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduScanner$1;
return "scanner opened";
}
}