@Test public void testHandlerResolution() throws Exception{ Properties props = new Properties(); props.setProperty(ConfigurationKeys.TASK_STATE_COLLECTOR_HANDLER_CLASS, "hivereg"); TaskStateCollectorService taskStateCollectorServiceHive = new TaskStateCollectorService(props, this.jobState, this.eventBus, this.taskStateStore, new Path(this.outputTaskStateDir, JOB_ID + "_prime")); Assert.assertEquals(taskStateCollectorServiceHive.getOptionalTaskCollectorHandler().get().getClass().getName(), "org.apache.gobblin.runtime.HiveRegTaskStateCollectorServiceHandlerImpl"); taskStateCollectorServiceHive.shutDown(); return; }
@Override protected void shutDown() throws Exception { LOGGER.info("Stopping the " + TaskStateCollectorService.class.getSimpleName()); try { runOneIteration(); } finally { super.shutDown(); this.handlerCloser.close(); } }
TaskStateCollectorService extends AbstractScheduledService { @Override protected void shutDown() throws Exception { LOGGER.info("Stopping the " + TaskStateCollectorService.class.getSimpleName()); try { runOneIteration(); } finally { super.shutDown(); this.handlerCloser.close(); } } }
TaskStateCollectorService extends AbstractScheduledService { @Override protected void shutDown() throws Exception { LOGGER.info("Stopping the " + TaskStateCollectorService.class.getSimpleName()); try { runOneIteration(); } finally { super.shutDown(); this.handlerCloser.close(); } } TaskStateCollectorService(Properties jobProps, JobState jobState, EventBus eventBus,
      StateStore<TaskState> taskStateStore, Path outputTaskStateDir); }
TaskStateCollectorService extends AbstractScheduledService { @Override protected void shutDown() throws Exception { LOGGER.info("Stopping the " + TaskStateCollectorService.class.getSimpleName()); try { runOneIteration(); } finally { super.shutDown(); this.handlerCloser.close(); } } TaskStateCollectorService(Properties jobProps, JobState jobState, EventBus eventBus,
      StateStore<TaskState> taskStateStore, Path outputTaskStateDir);  }
TaskStateCollectorService extends AbstractScheduledService { @Override protected void shutDown() throws Exception { LOGGER.info("Stopping the " + TaskStateCollectorService.class.getSimpleName()); try { runOneIteration(); } finally { super.shutDown(); this.handlerCloser.close(); } } TaskStateCollectorService(Properties jobProps, JobState jobState, EventBus eventBus,
      StateStore<TaskState> taskStateStore, Path outputTaskStateDir);   }