public abstract class org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler extends java.lang.Object
{
public static org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler newFixedDelaySchedule(java.time.Duration, java.time.Duration)
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler v;
java.time.Duration v, v;
long v, v;
v := @parameter: java.time.Duration;
v := @parameter: java.time.Duration;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Internal: long toNanosSaturated(java.time.Duration)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Internal: long toNanosSaturated(java.time.Duration)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit NANOSECONDS>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler newFixedDelaySchedule(long,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public static org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler newFixedDelaySchedule(long, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler$1 v;
byte v;
long v, v;
boolean v;
v := @parameter: long;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v = v cmp 0L;
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: void checkArgument(boolean,java.lang.String,long)>(v, "delay must be > 0, found %s", v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler$1: void <init>(long,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public static org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler newFixedRateSchedule(java.time.Duration, java.time.Duration)
{
java.util.concurrent.TimeUnit v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler v;
java.time.Duration v, v;
long v, v;
v := @parameter: java.time.Duration;
v := @parameter: java.time.Duration;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Internal: long toNanosSaturated(java.time.Duration)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.Internal: long toNanosSaturated(java.time.Duration)>(v);
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit NANOSECONDS>;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler newFixedRateSchedule(long,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
public static org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler newFixedRateSchedule(long, long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
byte v;
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler$2 v;
long v, v;
boolean v;
v := @parameter: long;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object)>(v);
v = v cmp 0L;
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.base.Preconditions: void checkArgument(boolean,java.lang.String,long)>(v, "period must be > 0, found %s", v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler$2;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler$2: void <init>(long,long,java.util.concurrent.TimeUnit)>(v, v, v);
return v;
}
abstract java.util.concurrent.Future schedule(org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractService, java.util.concurrent.ScheduledExecutorService, java.lang.Runnable);
private void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.com.google.common.util.concurrent.AbstractScheduledService$Scheduler;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
}