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

@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));
}

@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));
}

@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));
}

@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();
}

@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));
}

@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));
}

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

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

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

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

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

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