Java 类org.apache.hadoop.mapred.TaskController.TaskControllerPathDeletionContext 实例源码

static PathDeletionContext[] buildTaskControllerPathDeletionContexts(
    FileSystem fs, Path[] paths, Task task, boolean isWorkDir,
    TaskController taskController)
    throws IOException {
  int i = 0;
  PathDeletionContext[] contexts =
                        new TaskControllerPathDeletionContext[paths.length];

  for (Path p : paths) {
    contexts[i++] = new TaskControllerPathDeletionContext(fs, p, task,
                        isWorkDir, taskController);
  }
  return contexts;
}

static PathDeletionContext[] buildTaskControllerPathDeletionContexts(
    FileSystem fs, Path[] paths, Task task, boolean isWorkDir,
    TaskController taskController)
    throws IOException {
  int i = 0;
  PathDeletionContext[] contexts =
                        new TaskControllerPathDeletionContext[paths.length];

  for (Path p : paths) {
    contexts[i++] = new TaskControllerPathDeletionContext(fs, p, task,
                        isWorkDir, taskController);
  }
  return contexts;
}

/**
 * Builds list of {@link TaskControllerJobPathDeletionContext} objects for a 
 * job each pointing to the job's jobLocalDir.
 * @param fs    : FileSystem in which the dirs to be deleted
 * @param paths : mapred-local-dirs
 * @param id    : {@link JobID} of the job for which the local-dir needs to 
 *                be cleaned up.
 * @param user  : Job owner's username
 * @param taskController : the task-controller to be used for deletion of
 *                         jobLocalDir
 */
static PathDeletionContext[] buildTaskControllerJobPathDeletionContexts(
    FileSystem fs, Path[] paths, JobID id, String user,
    TaskController taskController)
    throws IOException {
  int i = 0;
  PathDeletionContext[] contexts =
                        new TaskControllerPathDeletionContext[paths.length];

  for (Path p : paths) {
    contexts[i++] = new TaskControllerJobPathDeletionContext(fs, p, id, user,
                                                             taskController);
  }
  return contexts;
}

/**
 * Builds list of TaskControllerTaskPathDeletionContext objects for a task
 * @param fs    : FileSystem in which the dirs to be deleted
 * @param paths : mapred-local-dirs
 * @param task  : the task whose taskDir or taskWorkDir is going to be deleted
 * @param isWorkDir : the dir to be deleted is workDir or taskDir
 * @param taskController : the task-controller to be used for deletion of
 *                         taskDir or taskWorkDir
 */
static PathDeletionContext[] buildTaskControllerTaskPathDeletionContexts(
    FileSystem fs, Path[] paths, Task task, boolean isWorkDir,
    TaskController taskController)
    throws IOException {
  int i = 0;
  PathDeletionContext[] contexts =
                        new TaskControllerPathDeletionContext[paths.length];

  for (Path p : paths) {
    contexts[i++] = new TaskControllerTaskPathDeletionContext(fs, p, task,
                        isWorkDir, taskController);
  }
  return contexts;
}