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

YarnOutputFiles介绍

[英]Manipulate the working area for the transient store for maps and reduces. This class is used by map and reduce tasks to identify the directories that they need to write to/read from for intermediate files. The callers of these methods are from child space.
[中]操纵工作区域，以便临时存储贴图和图像。map and reduce任务使用该类来标识中间文件需要写入/读取的目录。这些方法的调用者来自子空间。

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

/**
 * Return the path to a local map output index file created earlier
 * 
 * @return path
 * @throws IOException
 */
public Path getOutputIndexFile() throws IOException {
 Path attemptIndexOutput =
  new Path(getAttemptOutputDir(), MAP_OUTPUT_FILENAME_STRING +
                  MAP_OUTPUT_INDEX_SUFFIX_STRING);
 return lDirAlloc.getLocalPathToRead(attemptIndexOutput.toString(), conf);
}

代码示例来源：origin: io.hops/hadoop-mapreduce-client-app

/**
 * Return the path to a local map output index file created earlier
 * 
 * @return path
 * @throws IOException
 */
public Path getOutputIndexFile() throws IOException {
 Path attemptIndexOutput =
  new Path(getAttemptOutputDir(), MAP_OUTPUT_FILENAME_STRING +
                  MAP_OUTPUT_INDEX_SUFFIX_STRING);
 return lDirAlloc.getLocalPathToRead(attemptIndexOutput.toString(), conf);
}

代码示例来源：origin: io.hops/hadoop-mapreduce-client-app

/**
 * Create a local map output file name.
 * 
 * @param size the size of the file
 * @return path
 * @throws IOException
 */
public Path getOutputFileForWrite(long size) throws IOException {
 Path attemptOutput = 
  new Path(getAttemptOutputDir(), MAP_OUTPUT_FILENAME_STRING);
 return lDirAlloc.getLocalPathForWrite(attemptOutput.toString(), size, conf);
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

/**
 * Return the path to local map output file created earlier
 * 
 * @return path
 * @throws IOException
 */
public Path getOutputFile() throws IOException {
 Path attemptOutput =
  new Path(getAttemptOutputDir(), MAP_OUTPUT_FILENAME_STRING);
 return lDirAlloc.getLocalPathToRead(attemptOutput.toString(), conf);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-mapreduce-client-app

/**
 * Return the path to local map output file created earlier
 * 
 * @return path
 * @throws IOException
 */
public Path getOutputFile() throws IOException {
 Path attemptOutput =
  new Path(getAttemptOutputDir(), MAP_OUTPUT_FILENAME_STRING);
 return lDirAlloc.getLocalPathToRead(attemptOutput.toString(), conf);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-mapreduce-client-app

/**
 * Return the path to a local map output index file created earlier
 * 
 * @return path
 * @throws IOException
 */
public Path getOutputIndexFile() throws IOException {
 Path attemptIndexOutput =
  new Path(getAttemptOutputDir(), MAP_OUTPUT_FILENAME_STRING +
                  MAP_OUTPUT_INDEX_SUFFIX_STRING);
 return lDirAlloc.getLocalPathToRead(attemptIndexOutput.toString(), conf);
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

/**
 * Create a local map output file name.
 * 
 * @param size the size of the file
 * @return path
 * @throws IOException
 */
public Path getOutputFileForWrite(long size) throws IOException {
 Path attemptOutput = 
  new Path(getAttemptOutputDir(), MAP_OUTPUT_FILENAME_STRING);
 return lDirAlloc.getLocalPathForWrite(attemptOutput.toString(), size, conf);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-mapreduce-client-app

/**
 * Create a local map output file name.
 * 
 * @param size the size of the file
 * @return path
 * @throws IOException
 */
public Path getOutputFileForWrite(long size) throws IOException {
 Path attemptOutput = 
  new Path(getAttemptOutputDir(), MAP_OUTPUT_FILENAME_STRING);
 return lDirAlloc.getLocalPathForWrite(attemptOutput.toString(), size, conf);
}

代码示例来源：origin: io.hops/hadoop-mapreduce-client-app

/**
 * Return the path to local map output file created earlier
 * 
 * @return path
 * @throws IOException
 */
public Path getOutputFile() throws IOException {
 Path attemptOutput =
  new Path(getAttemptOutputDir(), MAP_OUTPUT_FILENAME_STRING);
 return lDirAlloc.getLocalPathToRead(attemptOutput.toString(), conf);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-mapreduce-client-app

/**
 * Create a local map output index file name.
 * 
 * @param size the size of the file
 * @return path
 * @throws IOException
 */
public Path getOutputIndexFileForWrite(long size) throws IOException {
 Path attemptIndexOutput =
  new Path(getAttemptOutputDir(), MAP_OUTPUT_FILENAME_STRING +
                  MAP_OUTPUT_INDEX_SUFFIX_STRING);
 return lDirAlloc.getLocalPathForWrite(attemptIndexOutput.toString(),
   size, conf);
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

/**
 * Create a local map output index file name.
 * 
 * @param size the size of the file
 * @return path
 * @throws IOException
 */
public Path getOutputIndexFileForWrite(long size) throws IOException {
 Path attemptIndexOutput =
  new Path(getAttemptOutputDir(), MAP_OUTPUT_FILENAME_STRING +
                  MAP_OUTPUT_INDEX_SUFFIX_STRING);
 return lDirAlloc.getLocalPathForWrite(attemptIndexOutput.toString(),
   size, conf);
}

代码示例来源：origin: io.hops/hadoop-mapreduce-client-app

/**
 * Create a local map output index file name.
 * 
 * @param size the size of the file
 * @return path
 * @throws IOException
 */
public Path getOutputIndexFileForWrite(long size) throws IOException {
 Path attemptIndexOutput =
  new Path(getAttemptOutputDir(), MAP_OUTPUT_FILENAME_STRING +
                  MAP_OUTPUT_INDEX_SUFFIX_STRING);
 return lDirAlloc.getLocalPathForWrite(attemptIndexOutput.toString(),
   size, conf);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-mapreduce-client-app

/**
 * Create a local reduce input file name.
 * 
 * @param mapId a map task id
 * @param size the size of the file
 * @return path
 * @throws IOException
 */
public Path getInputFileForWrite(org.apache.hadoop.mapreduce.TaskID mapId,
  long size) throws IOException {
 return lDirAlloc.getLocalPathForWrite(String.format(
   REDUCE_INPUT_FILE_FORMAT_STRING,
   getAttemptOutputDir().toString(), mapId.getId()),
   size, conf);
}

代码示例来源：origin: io.hops/hadoop-mapreduce-client-app

/**
 * Create a local reduce input file name.
 * 
 * @param mapId a map task id
 * @param size the size of the file
 * @return path
 * @throws IOException
 */
public Path getInputFileForWrite(org.apache.hadoop.mapreduce.TaskID mapId,
  long size) throws IOException {
 return lDirAlloc.getLocalPathForWrite(String.format(
   REDUCE_INPUT_FILE_FORMAT_STRING,
   getAttemptOutputDir().toString(), mapId.getId()),
   size, conf);
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-app

/**
 * Create a local reduce input file name.
 * 
 * @param mapId a map task id
 * @param size the size of the file
 * @return path
 * @throws IOException
 */
public Path getInputFileForWrite(org.apache.hadoop.mapreduce.TaskID mapId,
  long size) throws IOException {
 return lDirAlloc.getLocalPathForWrite(String.format(
   REDUCE_INPUT_FILE_FORMAT_STRING,
   getAttemptOutputDir().toString(), mapId.getId()),
   size, conf);
}