Java 类org.apache.hadoop.mapreduce.jobhistory.JobHistoryEventHandler 实例源码

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  return new JobHistoryEventHandler(context, getStartCount()) {
    @Override
    public void serviceStop() throws Exception {
      numStops++;
      JobHistoryEventHandlerStopped = numStops;
      super.serviceStop();
    }
  };
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  spyHistoryService =
      Mockito.spy((JobHistoryEventHandler) super
          .createJobHistoryHandler(context));
  spyHistoryService.setForcejobCompletion(this.isLastAMRetry);
  return spyHistoryService;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  return new JobHistoryEventHandler(context, getStartCount()) {
    @Override
    protected void serviceStart() {
      // Don't start any event draining thread.
      super.eventHandlingThread = new Thread();
      super.eventHandlingThread.start();
    }
  };
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  return new JobHistoryEventHandler(context, getStartCount()) {
    @Override
    public void serviceStop() throws Exception {
      numStops++;
      JobHistoryEventHandlerStopped = numStops;
      super.serviceStop();
    }
  };
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  spyHistoryService =
      Mockito.spy((JobHistoryEventHandler) super
          .createJobHistoryHandler(context));
  spyHistoryService.setForcejobCompletion(this.isLastAMRetry);
  return spyHistoryService;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  return new JobHistoryEventHandler(context, getStartCount()) {
    @Override
    public void handle(JobHistoryEvent event) {
      if (event.getHistoryEvent().getEventType() == EventType.JOB_INITED) {
        JobInitedEvent jie = (JobInitedEvent) event.getHistoryEvent();
        jobLaunchTime.set(jie.getLaunchTime());
      }
      super.handle(event);
    }
  };
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  return new JobHistoryEventHandler(context, getStartCount()) {
    @Override
    protected void serviceStart() {
      // Don't start any event draining thread.
      super.eventHandlingThread = new Thread();
      super.eventHandlingThread.start();
    }
  };
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  return new JobHistoryEventHandler(context, getStartCount()) {
    @Override
    public void serviceStop() throws Exception {
      numStops++;
      JobHistoryEventHandlerStopped = numStops;
      super.serviceStop();
    }
  };
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  spyHistoryService =
      Mockito.spy((JobHistoryEventHandler) super
          .createJobHistoryHandler(context));
  spyHistoryService.setForcejobCompletion(this.isLastAMRetry);
  return spyHistoryService;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  return new JobHistoryEventHandler(context, getStartCount()) {
    @Override
    protected void serviceStart() {
      // Don't start any event draining thread.
      super.eventHandlingThread = new Thread();
      super.eventHandlingThread.start();
    }
  };
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  return new JobHistoryEventHandler(context, getStartCount()) {
    @Override
    public void serviceStop() throws Exception {
      numStops++;
      JobHistoryEventHandlerStopped = numStops;
      super.serviceStop();
    }
  };
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  spyHistoryService =
      Mockito.spy((JobHistoryEventHandler) super
          .createJobHistoryHandler(context));
  spyHistoryService.setForcejobCompletion(this.isLastAMRetry);
  return spyHistoryService;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  return new JobHistoryEventHandler(context, getStartCount()) {
    @Override
    protected void serviceStart() {
      // Don't start any event draining thread.
      super.eventHandlingThread = new Thread();
      super.eventHandlingThread.start();
    }
  };
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  return new JobHistoryEventHandler(context, getStartCount()) {
    @Override
    protected void serviceStart() {
      // Don't start any event draining thread.
      super.eventHandlingThread = new Thread();
      super.eventHandlingThread.start();
    }
  };
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  return new JobHistoryEventHandler(context, getStartCount()) {
    @Override
    public void serviceStop() throws Exception {
      numStops++;
      JobHistoryEventHandlerStopped = numStops;
      super.serviceStop();
    }
  };
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  spyHistoryService =
      Mockito.spy((JobHistoryEventHandler) super
          .createJobHistoryHandler(context));
  spyHistoryService.setForcejobCompletion(this.isLastAMRetry);
  return spyHistoryService;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  return new JobHistoryEventHandler(context, getStartCount()) {
    @Override
    protected void serviceStart() {
      // Don't start any event draining thread.
      super.eventHandlingThread = new Thread();
      super.eventHandlingThread.start();
    }
  };
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  JobHistoryEventHandler eventHandler = new JobHistoryEventHandler(context, 
      getStartCount());
  return eventHandler;
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  return new JobHistoryEventHandler(context, getStartCount()) {
    @Override
    public void serviceStop() throws Exception {
      numStops++;
      JobHistoryEventHandlerStopped = numStops;
      super.serviceStop();
    }
  };
}

@Override
protected EventHandler<JobHistoryEvent> createJobHistoryHandler(
    AppContext context) {
  spyHistoryService =
      Mockito.spy((JobHistoryEventHandler) super
          .createJobHistoryHandler(context));
  spyHistoryService.setForcejobCompletion(this.isLastAMRetry);
  return spyHistoryService;
}