@Test public void testGetCoordinator() throws Exception { long jobId = addJob(100); assertNull("job id should not exist", mTracker.getCoordinator(-1)); assertNotNull("job should exist", mTracker.getCoordinator(jobId)); assertFalse("job should not be finished", mTracker.getCoordinator(jobId).isJobFinished()); finishAllJobs(); assertTrue("job should be finished", mTracker.getCoordinator(jobId).isJobFinished()); assertEquals("finished should be of size 1", 1, ((Queue) Whitebox.getInternalState(mTracker, "mFinished")).size()); }
@Nullable public PlanCoordinator getCoordinator(long jobId) { return mCoordinators.get(jobId); }
PlanTracker { @Nullable public PlanCoordinator getCoordinator(long jobId) { return mCoordinators.get(jobId); } }
PlanTracker { @Nullable public PlanCoordinator getCoordinator(long jobId) { return mCoordinators.get(jobId); } PlanTracker(long capacity, long retentionMs,
                     long maxJobPurgeCount, WorkflowTracker workflowTracker); }
PlanTracker { @Nullable public PlanCoordinator getCoordinator(long jobId) { return mCoordinators.get(jobId); } 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 { @Nullable public PlanCoordinator getCoordinator(long jobId) { return mCoordinators.get(jobId); } 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();  }