public abstract class org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService extends org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.ForwardingObject implements java.util.concurrent.ExecutorService
{
protected void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.collect.ForwardingObject: void <init>()>();
return;
}
protected abstract java.util.concurrent.ExecutorService delegate();
public boolean awaitTermination(long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
{
java.util.concurrent.TimeUnit v;
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService v;
java.util.concurrent.ExecutorService v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService: java.util.concurrent.ExecutorService delegate()>();
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: boolean awaitTermination(long,java.util.concurrent.TimeUnit)>(v, v);
return v;
}
public java.util.List invokeAll(java.util.Collection) throws java.lang.InterruptedException
{
java.util.List v;
java.util.Collection v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService;
v := @parameter: java.util.Collection;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService: java.util.concurrent.ExecutorService delegate()>();
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.List invokeAll(java.util.Collection)>(v);
return v;
}
public java.util.List invokeAll(java.util.Collection, long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
{
java.util.concurrent.TimeUnit v;
java.util.List v;
java.util.Collection v;
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService;
v := @parameter: java.util.Collection;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService: java.util.concurrent.ExecutorService delegate()>();
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.List invokeAll(java.util.Collection,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public java.lang.Object invokeAny(java.util.Collection) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
{
java.util.Collection v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService;
v := @parameter: java.util.Collection;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService: java.util.concurrent.ExecutorService delegate()>();
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.lang.Object invokeAny(java.util.Collection)>(v);
return v;
}
public java.lang.Object invokeAny(java.util.Collection, long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException, java.util.concurrent.TimeoutException
{
java.util.concurrent.TimeUnit v;
java.util.Collection v;
java.lang.Object v;
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService;
v := @parameter: java.util.Collection;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService: java.util.concurrent.ExecutorService delegate()>();
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.lang.Object invokeAny(java.util.Collection,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public boolean isShutdown()
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService v;
java.util.concurrent.ExecutorService v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService: java.util.concurrent.ExecutorService delegate()>();
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: boolean isShutdown()>();
return v;
}
public boolean isTerminated()
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService v;
java.util.concurrent.ExecutorService v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService: java.util.concurrent.ExecutorService delegate()>();
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: boolean isTerminated()>();
return v;
}
public void shutdown()
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService: java.util.concurrent.ExecutorService delegate()>();
interfaceinvoke v.<java.util.concurrent.ExecutorService: void shutdown()>();
return;
}
public java.util.List shutdownNow()
{
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService: java.util.concurrent.ExecutorService delegate()>();
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.List shutdownNow()>();
return v;
}
public void execute(java.lang.Runnable)
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService v;
java.lang.Runnable v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService;
v := @parameter: java.lang.Runnable;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService: java.util.concurrent.ExecutorService delegate()>();
interfaceinvoke v.<java.util.concurrent.ExecutorService: void execute(java.lang.Runnable)>(v);
return;
}
public java.util.concurrent.Future submit(java.util.concurrent.Callable)
{
java.util.concurrent.Future v;
java.util.concurrent.Callable v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService;
v := @parameter: java.util.concurrent.Callable;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService: java.util.concurrent.ExecutorService delegate()>();
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.concurrent.Future submit(java.util.concurrent.Callable)>(v);
return v;
}
public java.util.concurrent.Future submit(java.lang.Runnable)
{
java.util.concurrent.Future v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService v;
java.lang.Runnable v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService;
v := @parameter: java.lang.Runnable;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService: java.util.concurrent.ExecutorService delegate()>();
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.concurrent.Future submit(java.lang.Runnable)>(v);
return v;
}
public java.util.concurrent.Future submit(java.lang.Runnable, java.lang.Object)
{
java.util.concurrent.Future v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService v;
java.lang.Runnable v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService;
v := @parameter: java.lang.Runnable;
v := @parameter: java.lang.Object;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.ForwardingExecutorService: java.util.concurrent.ExecutorService delegate()>();
v = interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.concurrent.Future submit(java.lang.Runnable,java.lang.Object)>(v, v);
return v;
}
}