本文整理了Java中org.apache.hadoop.mapred.Task.createRunner()方法的一些代码示例，展示了Task.createRunner()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Task.createRunner()方法的具体详情如下：
包路径：org.apache.hadoop.mapred.Task
类名称：Task
方法名：createRunner

Task.createRunner介绍

[英]Return an approprate thread runner for this task.
[中]

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-mapred-test

TaskInProgress tip = tt.new TaskInProgress(task, taskConf);
File pidFile = new File(TEST_DIR, "pid_" + i);
final TaskRunner taskRunner = task.createRunner(tt, tip);

代码示例来源：origin: org.apache.hadoop/hadoop-mapred-test

TaskInProgress tip = tt.new TaskInProgress(task, taskConf);
File pidFile = new File(TEST_DIR, "pid");
final TaskRunner taskRunner = task.createRunner(tt, tip);
task.setConf(taskConf);
tip = tt.new TaskInProgress(task, taskConf);
TaskRunner taskRunner2 = task.createRunner(tt, tip);

代码示例来源：origin: org.jvnet.hudson.hadoop/hadoop-core

/**
 * Kick off the task execution
 */
public synchronized void launchTask() throws IOException {
 if (this.taskStatus.getRunState() == TaskStatus.State.UNASSIGNED ||
   this.taskStatus.getRunState() == TaskStatus.State.FAILED_UNCLEAN ||
   this.taskStatus.getRunState() == TaskStatus.State.KILLED_UNCLEAN) {
  localizeTask(task);
  if (this.taskStatus.getRunState() == TaskStatus.State.UNASSIGNED) {
   this.taskStatus.setRunState(TaskStatus.State.RUNNING);
  }
  this.runner = task.createRunner(TaskTracker.this, this);
  this.runner.start();
  this.taskStatus.setStartTime(System.currentTimeMillis());
 } else {
  LOG.info("Not launching task: " + task.getTaskID() + 
    " since it's state is " + this.taskStatus.getRunState());
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapred-test

attemptWorkDir != null);
TaskRunner runner = task.createRunner(tracker, tip);
tip.setTaskRunner(runner);

代码示例来源：origin: com.facebook.hadoop/hadoop-core

/**
 * Kick off the task execution
 */
public synchronized boolean launchTask() throws IOException {
 if (this.taskStatus.getRunState() == TaskStatus.State.UNASSIGNED ||
   this.taskStatus.getRunState() == TaskStatus.State.FAILED_UNCLEAN ||
   this.taskStatus.getRunState() == TaskStatus.State.KILLED_UNCLEAN) {
  localizeTask(task);
  if (this.taskStatus.getRunState() == TaskStatus.State.UNASSIGNED) {
   this.taskStatus.setRunState(TaskStatus.State.RUNNING);
  }
  this.runner = task.createRunner(TaskTracker.this, this);
  this.runner.start();
  this.taskStatus.setStartTime(System.currentTimeMillis());
  return true;
 } else {
  LOG.info("Not launching task: " + task.getTaskID() +
    " since it's state is " + this.taskStatus.getRunState());
  return false;
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapred

/**
 * Kick off the task execution
 */
public synchronized void launchTask() throws IOException {
 if (this.taskStatus.getRunState() == TaskStatus.State.UNASSIGNED ||
   this.taskStatus.getRunState() == TaskStatus.State.FAILED_UNCLEAN ||
   this.taskStatus.getRunState() == TaskStatus.State.KILLED_UNCLEAN) {
  localizeTask(task);
  if (this.taskStatus.getRunState() == TaskStatus.State.UNASSIGNED) {
   this.taskStatus.setRunState(TaskStatus.State.RUNNING);
  }
  setTaskRunner(task.createRunner(TaskTracker.this, this));
  this.runner.start();
  this.taskStatus.setStartTime(System.currentTimeMillis());
 } else {
  LOG.info("Not launching task: " + task.getTaskID() + 
    " since it's state is " + this.taskStatus.getRunState());
 }
}