@@ -0,0 +1,910 @@
+package edu.berkeley.sparrow.daemon.scheduler;%0A%0Aimport edu.berkeley.sparrow.thrift.TSchedulingRequest;%0Aimport org.apache.log4j.Logger;%0A%0Aimport java.util.concurrent.atomic.AtomicInteger;%0A%0A/**%0A * Created by wdm on 4/30/17.%0A */%0Apublic class JobTracker %7B%0A        private static final Logger LOG = Logger.getLogger(JobTracker.class);%0A        private String appId;%0A        private int jobId;%0A        private int jobSize;%0A        private AtomicInteger numFinishedTasks;%0A        JobTracker(String appId, int jobId,int jobSize)%7B%0A                this.appId = appId;%0A                this.jobId = jobId;%0A                this.jobSize = jobSize;%0A                this.numFinishedTasks = new AtomicInteger(0);%0A        %7D%0A%0A        void oneTaskFinish()%7B%0A                this.numFinishedTasks.incrementAndGet();%0A        %7D%0A%0A        boolean allTasksFinished()%7B%0A                return numFinishedTasks.get() %3E= jobSize;%0A        %7D%0A%0A%7D%0A

filename case-sensitive