public interface  org.apache.kafkaesque.common.utils.Scheduler extends java.lang.Object
{
public static final org.apache.kafkaesque.common.utils.Scheduler SYSTEM;
public abstract org.apache.kafkaesque.common.utils.Time time();
public abstract java.util.concurrent.Future schedule(java.util.concurrent.ScheduledExecutorService, java.util.concurrent.Callable, long);
static void <clinit>()
{
org.apache.kafkaesque.common.utils.SystemScheduler v;
v = new org.apache.kafkaesque.common.utils.SystemScheduler;
specialinvoke v.<org.apache.kafkaesque.common.utils.SystemScheduler: void <init>()>();
<org.apache.kafkaesque.common.utils.Scheduler: org.apache.kafkaesque.common.utils.Scheduler SYSTEM> = v;
return;
}
}