public final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup extends java.lang.Object implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup
{
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group;
private final int maxTaskExecutePerRun;
public void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup,int)>(v, 1024);
return;
}
public void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup, int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v, v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup;
v := @parameter: int;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup verify(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group> = v;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: int checkPositive(int,java.lang.String)>(v, "maxTaskExecutePerRun");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: int maxTaskExecutePerRun> = v;
return;
}
private static org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup verify(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup)
{
java.util.Iterator v;
java.lang.IllegalArgumentException v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
java.lang.Object v, v;
java.lang.String v;
boolean v, v;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "group");
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: 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 instanceof org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.OrderedEventExecutor;
if v == 0 goto label;
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor)>(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[])>("EventExecutorGroup \u contains OrderedEventExecutors: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup$NonStickyOrderedEventExecutor newExecutor(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup$NonStickyOrderedEventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup$NonStickyOrderedEventExecutor;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: int maxTaskExecutePerRun>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup$NonStickyOrderedEventExecutor: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor,int)>(v, v);
return v;
}
public boolean isShuttingDown()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: boolean isShuttingDown()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future shutdownGracefully()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future shutdownGracefully()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future shutdownGracefully(long, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
long v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v := @parameter: long;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future shutdownGracefully(long,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future terminationFuture()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future terminationFuture()>();
return v;
}
public void shutdown()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: void shutdown()>();
return;
}
public java.util.List shutdownNow()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
java.util.List v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: java.util.List shutdownNow()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor next()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup$NonStickyOrderedEventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor next()>();
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup$NonStickyOrderedEventExecutor newExecutor(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor)>(v);
return v;
}
public java.util.Iterator iterator()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup$1 v;
java.util.Iterator v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: java.util.Iterator iterator()>();
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup,java.util.Iterator)>(v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future submit(java.lang.Runnable)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
java.lang.Runnable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v := @parameter: java.lang.Runnable;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future submit(java.lang.Runnable)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future submit(java.lang.Runnable, java.lang.Object)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
java.lang.Object v;
java.lang.Runnable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v := @parameter: java.lang.Runnable;
v := @parameter: java.lang.Object;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future submit(java.lang.Runnable,java.lang.Object)>(v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future submit(java.util.concurrent.Callable)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
java.util.concurrent.Callable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v := @parameter: java.util.concurrent.Callable;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future submit(java.util.concurrent.Callable)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture schedule(java.lang.Runnable, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture v;
java.lang.Runnable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v := @parameter: java.lang.Runnable;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture schedule(java.lang.Runnable,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture schedule(java.util.concurrent.Callable, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
java.util.concurrent.Callable v;
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v := @parameter: java.util.concurrent.Callable;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture schedule(java.util.concurrent.Callable,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture scheduleAtFixedRate(java.lang.Runnable, long, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
long v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture v;
java.lang.Runnable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v := @parameter: java.lang.Runnable;
v := @parameter: long;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture scheduleAtFixedRate(java.lang.Runnable,long,long,java.util.concurrent.TimeUnit)>(v, v, v, v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture scheduleWithFixedDelay(java.lang.Runnable, long, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
long v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture v;
java.lang.Runnable v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v := @parameter: java.lang.Runnable;
v := @parameter: long;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ScheduledFuture scheduleWithFixedDelay(java.lang.Runnable,long,long,java.util.concurrent.TimeUnit)>(v, v, v, v);
return v;
}
public boolean isShutdown()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: boolean isShutdown()>();
return v;
}
public boolean isTerminated()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: boolean isTerminated()>();
return v;
}
public boolean awaitTermination(long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
long v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: 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.io.netty.util.concurrent.EventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v := @parameter: java.util.Collection;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: 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;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
long v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v := @parameter: java.util.Collection;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: 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;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
java.lang.Object v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v := @parameter: java.util.Collection;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: 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;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
java.lang.Object v;
long v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v := @parameter: java.util.Collection;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: java.lang.Object invokeAny(java.util.Collection,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public void execute(java.lang.Runnable)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup v;
java.lang.Runnable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup;
v := @parameter: java.lang.Runnable;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.NonStickyEventExecutorGroup: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup group>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutorGroup: void execute(java.lang.Runnable)>(v);
return;
}
}