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