final class org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture extends org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AggregateFuture
{
private org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture$CombinedFutureInterruptibleTask task;
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.ImmutableCollection, boolean, java.util.concurrent.Executor, org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AsyncCallable)
{
java.util.concurrent.Executor v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture$AsyncCallableInterruptibleTask v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.ImmutableCollection v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AsyncCallable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.ImmutableCollection;
v := @parameter: boolean;
v := @parameter: java.util.concurrent.Executor;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AsyncCallable;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AggregateFuture: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.ImmutableCollection,boolean,boolean)>(v, v, 0);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture$AsyncCallableInterruptibleTask;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture$AsyncCallableInterruptibleTask: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture,org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AsyncCallable,java.util.concurrent.Executor)>(v, v, v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture$CombinedFutureInterruptibleTask task> = v;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture: void init()>();
return;
}
void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.ImmutableCollection, boolean, java.util.concurrent.Executor, java.util.concurrent.Callable)
{
java.util.concurrent.Executor v;
java.util.concurrent.Callable v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.ImmutableCollection v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture$CallableInterruptibleTask v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.ImmutableCollection;
v := @parameter: boolean;
v := @parameter: java.util.concurrent.Executor;
v := @parameter: java.util.concurrent.Callable;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AggregateFuture: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.ImmutableCollection,boolean,boolean)>(v, v, 0);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture$CallableInterruptibleTask;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture$CallableInterruptibleTask: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture,java.util.concurrent.Callable,java.util.concurrent.Executor)>(v, v, v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture$CombinedFutureInterruptibleTask task> = v;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture: void init()>();
return;
}
void collectOneValue(int, java.lang.Object)
{
int v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture;
v := @parameter: int;
v := @parameter: java.lang.Object;
return;
}
void handleAllCompleted()
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture$CombinedFutureInterruptibleTask v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture$CombinedFutureInterruptibleTask task>;
if v == null goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture$CombinedFutureInterruptibleTask: void execute()>();
label:
return;
}
void releaseResources(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AggregateFuture$ReleaseResourcesReason)
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AggregateFuture$ReleaseResourcesReason v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AggregateFuture$ReleaseResourcesReason;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AggregateFuture: void releaseResources(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AggregateFuture$ReleaseResourcesReason)>(v);
v = <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AggregateFuture$ReleaseResourcesReason: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AggregateFuture$ReleaseResourcesReason OUTPUT_FUTURE_DONE>;
if v != v goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture$CombinedFutureInterruptibleTask task> = null;
label:
return;
}
protected void interruptTask()
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture$CombinedFutureInterruptibleTask v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture$CombinedFutureInterruptibleTask task>;
if v == null goto label;
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.CombinedFuture$CombinedFutureInterruptibleTask: void interruptTask()>();
label:
return;
}
}