Java 类org.apache.hadoop.mapreduce.v2.hs.JobHistory 实例源码

项目：hadoop 文件：TestHsWebServices.java

@Override
protected void configureServlets() {

  appContext = new MockHistoryContext(0, 1, 1, 1);
  JobHistory jobHistoryService = new JobHistory();
  HistoryContext historyContext = (HistoryContext) jobHistoryService;
  webApp = new HsWebApp(historyContext);

  bind(JAXBContextResolver.class);
  bind(HsWebServices.class);
  bind(GenericExceptionHandler.class);
  bind(WebApp.class).toInstance(webApp);
  bind(AppContext.class).toInstance(appContext);
  bind(HistoryContext.class).toInstance(appContext);
  bind(Configuration.class).toInstance(conf);

  serve("/*").with(GuiceContainer.class);
}

项目：hadoop 文件：JobHistoryUtils.java

/**
 * Extracts jobID string from the given job conf xml file name.
 * @param fileName name of the job conf xml file
 * @return job id if the given <code>fileName</code> is a valid job conf xml
 *         file name, <code>null</code> otherwise.
 */
private static String extractJobIDFromConfFileName(String fileName) {
  // History conf file name could be in one of the following formats
  // (1) old pre21 job history file name format
  // (2) new pre21 job history file name format
  // (3) current job history file name format i.e. 0.22
  String pre21JobID = applyParser(fileName,
                        Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V1);
  if (pre21JobID == null) {
    pre21JobID = applyParser(fileName,
                   Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V2);
  }
  if (pre21JobID != null) {
    return pre21JobID;
  }
  return applyParser(fileName, JobHistory.CONF_FILENAME_REGEX);
}

项目：aliyun-oss-hadoop-fs 文件：TestHsWebServices.java

@Override
protected void configureServlets() {

  appContext = new MockHistoryContext(0, 1, 1, 1);
  JobHistory jobHistoryService = new JobHistory();
  HistoryContext historyContext = (HistoryContext) jobHistoryService;
  webApp = new HsWebApp(historyContext);

  bind(JAXBContextResolver.class);
  bind(HsWebServices.class);
  bind(GenericExceptionHandler.class);
  bind(WebApp.class).toInstance(webApp);
  bind(AppContext.class).toInstance(appContext);
  bind(HistoryContext.class).toInstance(appContext);
  bind(Configuration.class).toInstance(conf);

  serve("/*").with(GuiceContainer.class);
}

项目：aliyun-oss-hadoop-fs 文件：JobHistoryUtils.java

/**
 * Extracts jobID string from the given job conf xml file name.
 * @param fileName name of the job conf xml file
 * @return job id if the given <code>fileName</code> is a valid job conf xml
 *         file name, <code>null</code> otherwise.
 */
private static String extractJobIDFromConfFileName(String fileName) {
  // History conf file name could be in one of the following formats
  // (1) old pre21 job history file name format
  // (2) new pre21 job history file name format
  // (3) current job history file name format i.e. 0.22
  String pre21JobID = applyParser(fileName,
                        Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V1);
  if (pre21JobID == null) {
    pre21JobID = applyParser(fileName,
                   Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V2);
  }
  if (pre21JobID != null) {
    return pre21JobID;
  }
  return applyParser(fileName, JobHistory.CONF_FILENAME_REGEX);
}

项目：big-c 文件：TestHsWebServices.java

@Override
protected void configureServlets() {

  appContext = new MockHistoryContext(0, 1, 1, 1);
  JobHistory jobHistoryService = new JobHistory();
  HistoryContext historyContext = (HistoryContext) jobHistoryService;
  webApp = new HsWebApp(historyContext);

  bind(JAXBContextResolver.class);
  bind(HsWebServices.class);
  bind(GenericExceptionHandler.class);
  bind(WebApp.class).toInstance(webApp);
  bind(AppContext.class).toInstance(appContext);
  bind(HistoryContext.class).toInstance(appContext);
  bind(Configuration.class).toInstance(conf);

  serve("/*").with(GuiceContainer.class);
}

项目：big-c 文件：JobHistoryUtils.java

/**
 * Extracts jobID string from the given job conf xml file name.
 * @param fileName name of the job conf xml file
 * @return job id if the given <code>fileName</code> is a valid job conf xml
 *         file name, <code>null</code> otherwise.
 */
private static String extractJobIDFromConfFileName(String fileName) {
  // History conf file name could be in one of the following formats
  // (1) old pre21 job history file name format
  // (2) new pre21 job history file name format
  // (3) current job history file name format i.e. 0.22
  String pre21JobID = applyParser(fileName,
                        Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V1);
  if (pre21JobID == null) {
    pre21JobID = applyParser(fileName,
                   Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V2);
  }
  if (pre21JobID != null) {
    return pre21JobID;
  }
  return applyParser(fileName, JobHistory.CONF_FILENAME_REGEX);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：TestHsWebServices.java

@Override
protected void configureServlets() {

  appContext = new MockHistoryContext(0, 1, 1, 1);
  JobHistory jobHistoryService = new JobHistory();
  HistoryContext historyContext = (HistoryContext) jobHistoryService;
  webApp = new HsWebApp(historyContext);

  bind(JAXBContextResolver.class);
  bind(HsWebServices.class);
  bind(GenericExceptionHandler.class);
  bind(WebApp.class).toInstance(webApp);
  bind(AppContext.class).toInstance(appContext);
  bind(HistoryContext.class).toInstance(appContext);
  bind(Configuration.class).toInstance(conf);

  serve("/*").with(GuiceContainer.class);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：JobHistoryUtils.java

/**
 * Extracts jobID string from the given job conf xml file name.
 * @param fileName name of the job conf xml file
 * @return job id if the given <code>fileName</code> is a valid job conf xml
 *         file name, <code>null</code> otherwise.
 */
private static String extractJobIDFromConfFileName(String fileName) {
  // History conf file name could be in one of the following formats
  // (1) old pre21 job history file name format
  // (2) new pre21 job history file name format
  // (3) current job history file name format i.e. 0.22
  String pre21JobID = applyParser(fileName,
                        Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V1);
  if (pre21JobID == null) {
    pre21JobID = applyParser(fileName,
                   Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V2);
  }
  if (pre21JobID != null) {
    return pre21JobID;
  }
  return applyParser(fileName, JobHistory.CONF_FILENAME_REGEX);
}

项目：hadoop-plus 文件：TestHsWebServices.java

@Override
protected void configureServlets() {

  appContext = new MockHistoryContext(0, 1, 1, 1);
  JobHistory jobHistoryService = new JobHistory();
  HistoryContext historyContext = (HistoryContext) jobHistoryService;
  webApp = new HsWebApp(historyContext);

  bind(JAXBContextResolver.class);
  bind(HsWebServices.class);
  bind(GenericExceptionHandler.class);
  bind(WebApp.class).toInstance(webApp);
  bind(AppContext.class).toInstance(appContext);
  bind(HistoryContext.class).toInstance(appContext);
  bind(Configuration.class).toInstance(conf);

  serve("/*").with(GuiceContainer.class);
}

项目：hadoop-plus 文件：JobHistoryUtils.java

/**
 * Extracts jobID string from the given job conf xml file name.
 * @param fileName name of the job conf xml file
 * @return job id if the given <code>fileName</code> is a valid job conf xml
 *         file name, <code>null</code> otherwise.
 */
private static String extractJobIDFromConfFileName(String fileName) {
  // History conf file name could be in one of the following formats
  // (1) old pre21 job history file name format
  // (2) new pre21 job history file name format
  // (3) current job history file name format i.e. 0.22
  String pre21JobID = applyParser(fileName,
                        Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V1);
  if (pre21JobID == null) {
    pre21JobID = applyParser(fileName,
                   Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V2);
  }
  if (pre21JobID != null) {
    return pre21JobID;
  }
  return applyParser(fileName, JobHistory.CONF_FILENAME_REGEX);
}

项目：FlexMap 文件：TestHsWebServices.java

@Override
protected void configureServlets() {

  appContext = new MockHistoryContext(0, 1, 1, 1);
  JobHistory jobHistoryService = new JobHistory();
  HistoryContext historyContext = (HistoryContext) jobHistoryService;
  webApp = new HsWebApp(historyContext);

  bind(JAXBContextResolver.class);
  bind(HsWebServices.class);
  bind(GenericExceptionHandler.class);
  bind(WebApp.class).toInstance(webApp);
  bind(AppContext.class).toInstance(appContext);
  bind(HistoryContext.class).toInstance(appContext);
  bind(Configuration.class).toInstance(conf);

  serve("/*").with(GuiceContainer.class);
}

项目：FlexMap 文件：TestHSAdminServer.java

@Before
public void init() throws HadoopIllegalArgumentException, IOException {
  conf = new JobConf();
  conf.set(JHAdminConfig.JHS_ADMIN_ADDRESS, "0.0.0.0:0");
  conf.setClass("hadoop.security.group.mapping", MockUnixGroupsMapping.class,
      GroupMappingServiceProvider.class);
  conf.setLong("hadoop.security.groups.cache.secs", groupRefreshTimeoutSec);
  Groups.getUserToGroupsMappingService(conf);
  jobHistoryService = mock(JobHistory.class);
  alds = mock(AggregatedLogDeletionService.class);

  hsAdminServer = new HSAdminServer(alds, jobHistoryService) {

    @Override
    protected Configuration createConf() {
      return conf;
    }
  };
  hsAdminServer.init(conf);
  hsAdminServer.start();
  conf.setSocketAddr(JHAdminConfig.JHS_ADMIN_ADDRESS,
      hsAdminServer.clientRpcServer.getListenerAddress());
  hsAdminClient = new HSAdmin(conf);
}

项目：hops 文件：TestHsWebServices.java

@Override
protected void configureServlets() {

  appContext = new MockHistoryContext(0, 1, 1, 1);
  JobHistory jobHistoryService = new JobHistory();
  HistoryContext historyContext = (HistoryContext) jobHistoryService;
  webApp = new HsWebApp(historyContext);

  bind(JAXBContextResolver.class);
  bind(HsWebServices.class);
  bind(GenericExceptionHandler.class);
  bind(WebApp.class).toInstance(webApp);
  bind(AppContext.class).toInstance(appContext);
  bind(HistoryContext.class).toInstance(appContext);
  bind(Configuration.class).toInstance(conf);

  serve("/*").with(GuiceContainer.class);
}

项目：hops 文件：JobHistoryUtils.java

/**
 * Extracts jobID string from the given job conf xml file name.
 * @param fileName name of the job conf xml file
 * @return job id if the given <code>fileName</code> is a valid job conf xml
 *         file name, <code>null</code> otherwise.
 */
private static String extractJobIDFromConfFileName(String fileName) {
  // History conf file name could be in one of the following formats
  // (1) old pre21 job history file name format
  // (2) new pre21 job history file name format
  // (3) current job history file name format i.e. 0.22
  String pre21JobID = applyParser(fileName,
                        Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V1);
  if (pre21JobID == null) {
    pre21JobID = applyParser(fileName,
                   Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V2);
  }
  if (pre21JobID != null) {
    return pre21JobID;
  }
  return applyParser(fileName, JobHistory.CONF_FILENAME_REGEX);
}

项目：hadoop-TCP 文件：TestHsWebServices.java

@Override
protected void configureServlets() {

  appContext = new MockHistoryContext(0, 1, 1, 1);
  JobHistory jobHistoryService = new JobHistory();
  HistoryContext historyContext = (HistoryContext) jobHistoryService;
  webApp = new HsWebApp(historyContext);

  bind(JAXBContextResolver.class);
  bind(HsWebServices.class);
  bind(GenericExceptionHandler.class);
  bind(WebApp.class).toInstance(webApp);
  bind(AppContext.class).toInstance(appContext);
  bind(HistoryContext.class).toInstance(appContext);
  bind(Configuration.class).toInstance(conf);

  serve("/*").with(GuiceContainer.class);
}

项目：hadoop-TCP 文件：JobHistoryUtils.java

/**
 * Extracts jobID string from the given job conf xml file name.
 * @param fileName name of the job conf xml file
 * @return job id if the given <code>fileName</code> is a valid job conf xml
 *         file name, <code>null</code> otherwise.
 */
private static String extractJobIDFromConfFileName(String fileName) {
  // History conf file name could be in one of the following formats
  // (1) old pre21 job history file name format
  // (2) new pre21 job history file name format
  // (3) current job history file name format i.e. 0.22
  String pre21JobID = applyParser(fileName,
                        Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V1);
  if (pre21JobID == null) {
    pre21JobID = applyParser(fileName,
                   Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V2);
  }
  if (pre21JobID != null) {
    return pre21JobID;
  }
  return applyParser(fileName, JobHistory.CONF_FILENAME_REGEX);
}

项目：hardfs 文件：TestHsWebServices.java

@Override
protected void configureServlets() {

  appContext = new MockHistoryContext(0, 1, 1, 1);
  JobHistory jobHistoryService = new JobHistory();
  HistoryContext historyContext = (HistoryContext) jobHistoryService;
  webApp = new HsWebApp(historyContext);

  bind(JAXBContextResolver.class);
  bind(HsWebServices.class);
  bind(GenericExceptionHandler.class);
  bind(WebApp.class).toInstance(webApp);
  bind(AppContext.class).toInstance(appContext);
  bind(HistoryContext.class).toInstance(appContext);
  bind(Configuration.class).toInstance(conf);

  serve("/*").with(GuiceContainer.class);
}

项目：hardfs 文件：JobHistoryUtils.java

/**
 * Extracts jobID string from the given job conf xml file name.
 * @param fileName name of the job conf xml file
 * @return job id if the given <code>fileName</code> is a valid job conf xml
 *         file name, <code>null</code> otherwise.
 */
private static String extractJobIDFromConfFileName(String fileName) {
  // History conf file name could be in one of the following formats
  // (1) old pre21 job history file name format
  // (2) new pre21 job history file name format
  // (3) current job history file name format i.e. 0.22
  String pre21JobID = applyParser(fileName,
                        Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V1);
  if (pre21JobID == null) {
    pre21JobID = applyParser(fileName,
                   Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V2);
  }
  if (pre21JobID != null) {
    return pre21JobID;
  }
  return applyParser(fileName, JobHistory.CONF_FILENAME_REGEX);
}

项目：hadoop-on-lustre2 文件：TestHsWebServices.java

@Override
protected void configureServlets() {

  appContext = new MockHistoryContext(0, 1, 1, 1);
  JobHistory jobHistoryService = new JobHistory();
  HistoryContext historyContext = (HistoryContext) jobHistoryService;
  webApp = new HsWebApp(historyContext);

  bind(JAXBContextResolver.class);
  bind(HsWebServices.class);
  bind(GenericExceptionHandler.class);
  bind(WebApp.class).toInstance(webApp);
  bind(AppContext.class).toInstance(appContext);
  bind(HistoryContext.class).toInstance(appContext);
  bind(Configuration.class).toInstance(conf);

  serve("/*").with(GuiceContainer.class);
}

项目：hadoop-on-lustre2 文件：TestHSAdminServer.java

@Before
public void init() throws HadoopIllegalArgumentException, IOException {
  conf = new Configuration();
  conf.set(JHAdminConfig.JHS_ADMIN_ADDRESS, "0.0.0.0:0");
  conf.setClass("hadoop.security.group.mapping", MockUnixGroupsMapping.class,
      GroupMappingServiceProvider.class);
  conf.setLong("hadoop.security.groups.cache.secs", groupRefreshTimeoutSec);
  Groups.getUserToGroupsMappingService(conf);
  jobHistoryService = mock(JobHistory.class);
  alds = mock(AggregatedLogDeletionService.class);

  hsAdminServer = new HSAdminServer(alds, jobHistoryService) {

    @Override
    protected Configuration createConf() {
      return conf;
    }
  };
  hsAdminServer.init(conf);
  hsAdminServer.start();
  conf.setSocketAddr(JHAdminConfig.JHS_ADMIN_ADDRESS,
      hsAdminServer.clientRpcServer.getListenerAddress());
  hsAdminClient = new HSAdmin(conf);
}

项目：hadoop-on-lustre2 文件：JobHistoryUtils.java

/**
 * Extracts jobID string from the given job conf xml file name.
 * @param fileName name of the job conf xml file
 * @return job id if the given <code>fileName</code> is a valid job conf xml
 *         file name, <code>null</code> otherwise.
 */
private static String extractJobIDFromConfFileName(String fileName) {
  // History conf file name could be in one of the following formats
  // (1) old pre21 job history file name format
  // (2) new pre21 job history file name format
  // (3) current job history file name format i.e. 0.22
  String pre21JobID = applyParser(fileName,
                        Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V1);
  if (pre21JobID == null) {
    pre21JobID = applyParser(fileName,
                   Pre21JobHistoryConstants.CONF_FILENAME_REGEX_V2);
  }
  if (pre21JobID != null) {
    return pre21JobID;
  }
  return applyParser(fileName, JobHistory.CONF_FILENAME_REGEX);
}

项目：hadoop 文件：TestHSAdminServer.java

@Before
public void init() throws HadoopIllegalArgumentException, IOException {
  conf = new JobConf();
  conf.set(JHAdminConfig.JHS_ADMIN_ADDRESS, "0.0.0.0:0");
  conf.setClass("hadoop.security.group.mapping", MockUnixGroupsMapping.class,
      GroupMappingServiceProvider.class);
  conf.setLong("hadoop.security.groups.cache.secs", groupRefreshTimeoutSec);
  conf.setBoolean(
        CommonConfigurationKeysPublic.HADOOP_SECURITY_AUTHORIZATION,
        securityEnabled);
  Groups.getUserToGroupsMappingService(conf);
  jobHistoryService = mock(JobHistory.class);
  alds = mock(AggregatedLogDeletionService.class);

  hsAdminServer = new HSAdminServer(alds, jobHistoryService) {

    @Override
    protected Configuration createConf() {
      return conf;
    }
  };
  hsAdminServer.init(conf);
  hsAdminServer.start();
  conf.setSocketAddr(JHAdminConfig.JHS_ADMIN_ADDRESS,
      hsAdminServer.clientRpcServer.getListenerAddress());
  hsAdminClient = new HSAdmin(conf);
}

项目：aliyun-oss-hadoop-fs 文件：TestHSAdminServer.java

@Before
public void init() throws HadoopIllegalArgumentException, IOException {
  conf = new JobConf();
  conf.set(JHAdminConfig.JHS_ADMIN_ADDRESS, "0.0.0.0:0");
  conf.setClass("hadoop.security.group.mapping", MockUnixGroupsMapping.class,
      GroupMappingServiceProvider.class);
  conf.setLong("hadoop.security.groups.cache.secs", groupRefreshTimeoutSec);
  conf.setBoolean(
        CommonConfigurationKeysPublic.HADOOP_SECURITY_AUTHORIZATION,
        securityEnabled);
  Groups.getUserToGroupsMappingService(conf);
  jobHistoryService = mock(JobHistory.class);
  alds = mock(AggregatedLogDeletionService.class);

  hsAdminServer = new HSAdminServer(alds, jobHistoryService) {

    @Override
    protected Configuration createConf() {
      return conf;
    }
  };
  hsAdminServer.init(conf);
  hsAdminServer.start();
  conf.setSocketAddr(JHAdminConfig.JHS_ADMIN_ADDRESS,
      hsAdminServer.clientRpcServer.getListenerAddress());
  hsAdminClient = new HSAdmin(conf);
}

项目：big-c 文件：TestHSAdminServer.java

@Before
public void init() throws HadoopIllegalArgumentException, IOException {
  conf = new JobConf();
  conf.set(JHAdminConfig.JHS_ADMIN_ADDRESS, "0.0.0.0:0");
  conf.setClass("hadoop.security.group.mapping", MockUnixGroupsMapping.class,
      GroupMappingServiceProvider.class);
  conf.setLong("hadoop.security.groups.cache.secs", groupRefreshTimeoutSec);
  conf.setBoolean(
        CommonConfigurationKeysPublic.HADOOP_SECURITY_AUTHORIZATION,
        securityEnabled);
  Groups.getUserToGroupsMappingService(conf);
  jobHistoryService = mock(JobHistory.class);
  alds = mock(AggregatedLogDeletionService.class);

  hsAdminServer = new HSAdminServer(alds, jobHistoryService) {

    @Override
    protected Configuration createConf() {
      return conf;
    }
  };
  hsAdminServer.init(conf);
  hsAdminServer.start();
  conf.setSocketAddr(JHAdminConfig.JHS_ADMIN_ADDRESS,
      hsAdminServer.clientRpcServer.getListenerAddress());
  hsAdminClient = new HSAdmin(conf);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：TestHSAdminServer.java

@Before
public void init() throws HadoopIllegalArgumentException, IOException {
  conf = new JobConf();
  conf.set(JHAdminConfig.JHS_ADMIN_ADDRESS, "0.0.0.0:0");
  conf.setClass("hadoop.security.group.mapping", MockUnixGroupsMapping.class,
      GroupMappingServiceProvider.class);
  conf.setLong("hadoop.security.groups.cache.secs", groupRefreshTimeoutSec);
  conf.setBoolean(
        CommonConfigurationKeysPublic.HADOOP_SECURITY_AUTHORIZATION,
        securityEnabled);
  Groups.getUserToGroupsMappingService(conf);
  jobHistoryService = mock(JobHistory.class);
  alds = mock(AggregatedLogDeletionService.class);

  hsAdminServer = new HSAdminServer(alds, jobHistoryService) {

    @Override
    protected Configuration createConf() {
      return conf;
    }
  };
  hsAdminServer.init(conf);
  hsAdminServer.start();
  conf.setSocketAddr(JHAdminConfig.JHS_ADMIN_ADDRESS,
      hsAdminServer.clientRpcServer.getListenerAddress());
  hsAdminClient = new HSAdmin(conf);
}

项目：hops 文件：TestHSAdminServer.java

@Before
public void init() throws HadoopIllegalArgumentException, IOException {
  conf = new JobConf();
  conf.set(JHAdminConfig.JHS_ADMIN_ADDRESS, "0.0.0.0:0");
  conf.setClass("hadoop.security.group.mapping", MockUnixGroupsMapping.class,
      GroupMappingServiceProvider.class);
  conf.setLong("hadoop.security.groups.cache.secs", groupRefreshTimeoutSec);
  conf.setBoolean(
        CommonConfigurationKeysPublic.HADOOP_SECURITY_AUTHORIZATION,
        securityEnabled);
  Groups.getUserToGroupsMappingService(conf);
  jobHistoryService = mock(JobHistory.class);
  alds = mock(AggregatedLogDeletionService.class);

  hsAdminServer = new HSAdminServer(alds, jobHistoryService) {

    @Override
    protected Configuration createConf() {
      return conf;
    }
  };
  hsAdminServer.init(conf);
  hsAdminServer.start();
  conf.setSocketAddr(JHAdminConfig.JHS_ADMIN_ADDRESS,
      hsAdminServer.clientRpcServer.getListenerAddress());
  hsAdminClient = new HSAdmin(conf);
}

项目：hadoop 文件：HSAdminServer.java

public HSAdminServer(AggregatedLogDeletionService aggLogDelService,
    JobHistory jobHistoryService) {
  super(HSAdminServer.class.getName());
  this.aggLogDelService = aggLogDelService;
  this.jobHistoryService = jobHistoryService;
}

项目：aliyun-oss-hadoop-fs 文件：HSAdminServer.java

public HSAdminServer(AggregatedLogDeletionService aggLogDelService,
    JobHistory jobHistoryService) {
  super(HSAdminServer.class.getName());
  this.aggLogDelService = aggLogDelService;
  this.jobHistoryService = jobHistoryService;
}

项目：big-c 文件：HSAdminServer.java

public HSAdminServer(AggregatedLogDeletionService aggLogDelService,
    JobHistory jobHistoryService) {
  super(HSAdminServer.class.getName());
  this.aggLogDelService = aggLogDelService;
  this.jobHistoryService = jobHistoryService;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：HSAdminServer.java

public HSAdminServer(AggregatedLogDeletionService aggLogDelService,
    JobHistory jobHistoryService) {
  super(HSAdminServer.class.getName());
  this.aggLogDelService = aggLogDelService;
  this.jobHistoryService = jobHistoryService;
}

项目：FlexMap 文件：HSAdminServer.java

public HSAdminServer(AggregatedLogDeletionService aggLogDelService,
    JobHistory jobHistoryService) {
  super(HSAdminServer.class.getName());
  this.aggLogDelService = aggLogDelService;
  this.jobHistoryService = jobHistoryService;
}

项目：hops 文件：HSAdminServer.java

public HSAdminServer(AggregatedLogDeletionService aggLogDelService,
    JobHistory jobHistoryService) {
  super(HSAdminServer.class.getName());
  this.aggLogDelService = aggLogDelService;
  this.jobHistoryService = jobHistoryService;
}

项目：hadoop-on-lustre2 文件：HSAdminServer.java

public HSAdminServer(AggregatedLogDeletionService aggLogDelService,
    JobHistory jobHistoryService) {
  super(HSAdminServer.class.getName());
  this.aggLogDelService = aggLogDelService;
  this.jobHistoryService = jobHistoryService;
}