final class org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession$1BatchCallback extends java.lang.Object implements org.apache.hive.kudu.com.stumbleupon.async.Callback
{
final org.apache.hive.kudu.org.apache.kudu.client.Batch val$request;
final org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession this$0;
void <init>(org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession, org.apache.hive.kudu.org.apache.kudu.client.Batch)
{
org.apache.hive.kudu.org.apache.kudu.client.Batch v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession$1BatchCallback v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession$1BatchCallback;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.Batch;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession$1BatchCallback: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession this$0> = v;
v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession$1BatchCallback: org.apache.hive.kudu.org.apache.kudu.client.Batch val$request> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public org.apache.hive.kudu.org.apache.kudu.client.BatchResponse call(org.apache.hive.kudu.org.apache.kudu.client.BatchResponse)
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient v;
org.apache.hive.kudu.org.apache.kudu.client.BatchResponse v;
org.apache.hive.kudu.org.apache.kudu.client.ErrorCollector v;
long v;
java.lang.Integer v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession v, v, v;
org.apache.hive.kudu.org.apache.kudu.client.RowError v;
int v;
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession$1BatchCallback v;
boolean v, v;
org.slf4j.Logger v;
java.util.Iterator v;
org.apache.hive.kudu.org.apache.kudu.client.Operation v;
java.util.List v, v;
org.apache.hive.kudu.org.apache.kudu.client.Batch v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.client.SessionConfiguration$FlushMode v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession$1BatchCallback;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.client.BatchResponse;
v = <org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession: org.slf4j.Logger LOG>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession$1BatchCallback: org.apache.hive.kudu.org.apache.kudu.client.Batch val$request>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.Batch: java.util.List operations>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String,java.lang.Object)>("Got a Batch response for {} rows", v);
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession$1BatchCallback: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient client>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.BatchResponse: long getWriteTimestamp()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduClient: void updateLastPropagatedTimestamp(long)>(v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.BatchResponse: java.util.List getIndividualResponses()>();
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 = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession$1BatchCallback: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession: org.apache.hive.kudu.org.apache.kudu.client.SessionConfiguration$FlushMode flushMode>;
v = <org.apache.hive.kudu.org.apache.kudu.client.SessionConfiguration$FlushMode: org.apache.hive.kudu.org.apache.kudu.client.SessionConfiguration$FlushMode AUTO_FLUSH_BACKGROUND>;
if v != v goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.OperationResponse: boolean hasRowError()>();
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession$1BatchCallback: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession this$0>;
v = v.<org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession: org.apache.hive.kudu.org.apache.kudu.client.ErrorCollector errorCollector>;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.OperationResponse: org.apache.hive.kudu.org.apache.kudu.client.RowError getRowError()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.ErrorCollector: void addError(org.apache.hive.kudu.org.apache.kudu.client.RowError)>(v);
label:
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.OperationResponse: org.apache.hive.kudu.org.apache.kudu.client.Operation getOperation()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.client.Operation: void callback(java.lang.Object)>(v);
goto label;
label:
return v;
}
public java.lang.String toString()
{
org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession$1BatchCallback v;
v := @this: org.apache.hive.kudu.org.apache.kudu.client.AsyncKuduSession$1BatchCallback;
return "apply batch response";
}
}