Java 类org.apache.hadoop.mapred.ClusterWithLinuxTaskController.MyLinuxTaskController 实例源码

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

@Override
protected void setUp()
    throws IOException, InterruptedException {

  if (!ClusterWithLinuxTaskController.shouldRun()) {
    return;
  }

  TEST_ROOT_DIR =
      new File(System.getProperty("test.build.data", "/tmp"),
          TestTrackerDistributedCacheManagerWithLinuxTaskController.class
              .getSimpleName()).getAbsolutePath();

  super.setUp();

  taskController = new MyLinuxTaskController();
  String path =
      System.getProperty(ClusterWithLinuxTaskController.TASKCONTROLLER_PATH);
  String execPath = path + "/task-controller";
  ((MyLinuxTaskController)taskController).setTaskControllerExe(execPath);
  taskController.setConf(conf);
  UtilsForTests.setupTC(taskController, localDirAllocator,
      conf.getStrings(JobConf.MAPRED_LOCAL_DIR_PROPERTY));
}

项目：hadoop-on-lustre 文件：TestTrackerDistributedCacheManagerWithLinuxTaskController.java

@Override
protected void setUp()
    throws IOException, InterruptedException {

  if (!ClusterWithLinuxTaskController.shouldRun()) {
    return;
  }

  TEST_ROOT_DIR =
      new File(System.getProperty("test.build.data", "/tmp"),
          TestTrackerDistributedCacheManagerWithLinuxTaskController.class
              .getSimpleName()).getAbsolutePath();

  super.setUp();

  taskController = new MyLinuxTaskController();
  String path =
      System.getProperty(ClusterWithLinuxTaskController.TASKCONTROLLER_PATH);
  String execPath = path + "/task-controller";
  ((MyLinuxTaskController)taskController).setTaskControllerExe(execPath);
  taskController.setConf(conf);
  UtilsForTests.setupTC(taskController, localDirAllocator,
      conf.getStrings(JobConf.MAPRED_LOCAL_DIR_PROPERTY));
}

项目：hanoi-hadoop-2.0.0-cdh 文件：TestTrackerDistributedCacheManagerWithLinuxTaskController.java

@Override
protected void setUp()
    throws IOException, InterruptedException {

  if (!ClusterWithLinuxTaskController.shouldRun()) {
    return;
  }

  TEST_ROOT_DIR =
      new File(System.getProperty("test.build.data", "/tmp"),
          TestTrackerDistributedCacheManagerWithLinuxTaskController.class
              .getSimpleName()).getAbsolutePath();

  super.setUp();

  taskController = new MyLinuxTaskController();
  String path =
      System.getProperty(ClusterWithLinuxTaskController.TASKCONTROLLER_PATH);
  String execPath = path + "/task-controller";
  ((MyLinuxTaskController)taskController).setTaskControllerExe(execPath);
  taskController.setConf(conf);
  UtilsForTests.setupTC(taskController, localDirAllocator,
      conf.getStrings(JobConf.MAPRED_LOCAL_DIR_PROPERTY));
}

项目：mapreduce-fork 文件：TestTrackerDistributedCacheManagerWithLinuxTaskController.java

@Override
protected void setUp()
    throws IOException, InterruptedException {

  if (!ClusterWithLinuxTaskController.shouldRun()) {
    return;
  }

  TEST_ROOT_DIR =
      new File(System.getProperty("test.build.data", "/tmp"),
          TestTrackerDistributedCacheManagerWithLinuxTaskController.class
              .getSimpleName()).getAbsolutePath();

  super.setUp();

  taskController = new MyLinuxTaskController();
  String path =
      System.getProperty(ClusterWithLinuxTaskController.TASKCONTROLLER_PATH);
  String execPath = path + "/task-controller";
  ((MyLinuxTaskController)taskController).setTaskControllerExe(execPath);
  taskController.setConf(conf);
  taskController.setup();
}

项目：hortonworks-extension 文件：TestTrackerDistributedCacheManagerWithLinuxTaskController.java

@Override
protected void setUp()
    throws IOException, InterruptedException {

  if (!ClusterWithLinuxTaskController.shouldRun()) {
    return;
  }

  TEST_ROOT_DIR =
      new File(System.getProperty("test.build.data", "/tmp"),
          TestTrackerDistributedCacheManagerWithLinuxTaskController.class
              .getSimpleName()).getAbsolutePath();

  super.setUp();

  taskController = new MyLinuxTaskController();
  String path =
      System.getProperty(ClusterWithLinuxTaskController.TASKCONTROLLER_PATH);
  String execPath = path + "/task-controller";
  ((MyLinuxTaskController)taskController).setTaskControllerExe(execPath);
  taskController.setConf(conf);
  UtilsForTests.setupTC(taskController, localDirAllocator,
      conf.getStrings(JobConf.MAPRED_LOCAL_DIR_PROPERTY));
}

项目：hortonworks-extension 文件：TestTrackerDistributedCacheManagerWithLinuxTaskController.java

@Override
protected void setUp()
    throws IOException, InterruptedException {

  if (!ClusterWithLinuxTaskController.shouldRun()) {
    return;
  }

  TEST_ROOT_DIR =
      new File(System.getProperty("test.build.data", "/tmp"),
          TestTrackerDistributedCacheManagerWithLinuxTaskController.class
              .getSimpleName()).getAbsolutePath();

  super.setUp();

  taskController = new MyLinuxTaskController();
  String path =
      System.getProperty(ClusterWithLinuxTaskController.TASKCONTROLLER_PATH);
  String execPath = path + "/task-controller";
  ((MyLinuxTaskController)taskController).setTaskControllerExe(execPath);
  taskController.setConf(conf);
  UtilsForTests.setupTC(taskController, localDirAllocator,
      conf.getStrings(JobConf.MAPRED_LOCAL_DIR_PROPERTY));
}

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

protected TaskController getTaskController() {
  return new MyLinuxTaskController();
}

项目：hadoop-on-lustre 文件：TestLocalizationWithLinuxTaskController.java

protected TaskController getTaskController() {
  return new MyLinuxTaskController();
}

项目：hanoi-hadoop-2.0.0-cdh 文件：TestLocalizationWithLinuxTaskController.java

protected TaskController getTaskController() {
  return new MyLinuxTaskController();
}

项目：mapreduce-fork 文件：TestLocalizationWithLinuxTaskController.java

protected TaskController createTaskController() {
  return new MyLinuxTaskController();
}

项目：hortonworks-extension 文件：TestLocalizationWithLinuxTaskController.java

protected TaskController getTaskController() {
  return new MyLinuxTaskController();
}

项目：hortonworks-extension 文件：TestLocalizationWithLinuxTaskController.java

protected TaskController getTaskController() {
  return new MyLinuxTaskController();
}