@Test public void testPurgeCount() throws Exception { PlanTracker tracker = new PlanTracker(10, 0, 5, mMockWorkflowTracker); assertEquals("tracker should be empty", 0, tracker.coordinators().size()); fillJobTracker(tracker, 10); finishAllJobs(tracker); addJob(tracker, 100); assertEquals(6, tracker.coordinators().size()); }
public Collection<PlanCoordinator> coordinators() { return Collections.unmodifiableCollection(mCoordinators.values()); }
PlanTracker { public Collection<PlanCoordinator> coordinators() { return Collections.unmodifiableCollection(mCoordinators.values()); } }
PlanTracker { public Collection<PlanCoordinator> coordinators() { return Collections.unmodifiableCollection(mCoordinators.values()); } PlanTracker(long capacity, long retentionMs,
                     long maxJobPurgeCount, WorkflowTracker workflowTracker); }
PlanTracker { public Collection<PlanCoordinator> coordinators() { return Collections.unmodifiableCollection(mCoordinators.values()); } PlanTracker(long capacity, long retentionMs,
                     long maxJobPurgeCount, WorkflowTracker workflowTracker); @Nullable PlanCoordinator getCoordinator(long jobId); synchronized void run(PlanConfig jobConfig, CommandManager manager,
      JobServerContext ctx, List<WorkerInfo> workers, long jobId); Collection<Long> list(); Collection<PlanCoordinator> coordinators(); Stream<PlanInfo> failed(); }
PlanTracker { public Collection<PlanCoordinator> coordinators() { return Collections.unmodifiableCollection(mCoordinators.values()); } PlanTracker(long capacity, long retentionMs,
                     long maxJobPurgeCount, WorkflowTracker workflowTracker); @Nullable PlanCoordinator getCoordinator(long jobId); synchronized void run(PlanConfig jobConfig, CommandManager manager,
      JobServerContext ctx, List<WorkerInfo> workers, long jobId); Collection<Long> list(); Collection<PlanCoordinator> coordinators(); Stream<PlanInfo> failed();  }