@InterfaceAudience.LimitedPrivate(value="MapReduce")
@InterfaceStability.Unstable
public class MapOutputFile
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.fs.Path |
getInputFile(int mapId)
Return a local reduce input file created earlier
|
org.apache.hadoop.fs.Path |
getInputFileForWrite(TaskID mapId,
long size)
Create a local reduce input file name.
|
org.apache.hadoop.fs.Path |
getOutputFile()
Return the path to local map output file created earlier
|
org.apache.hadoop.fs.Path |
getOutputFileForWrite(long size)
Create a local map output file name.
|
org.apache.hadoop.fs.Path |
getOutputIndexFile()
Return the path to a local map output index file created earlier
|
org.apache.hadoop.fs.Path |
getOutputIndexFileForWrite(long size)
Create a local map output index file name.
|
org.apache.hadoop.fs.Path |
getSpillFile(int spillNumber)
Return a local map spill file created earlier.
|
org.apache.hadoop.fs.Path |
getSpillFileForWrite(int spillNumber,
long size)
Create a local map spill file name.
|
org.apache.hadoop.fs.Path |
getSpillIndexFile(int spillNumber)
Return a local map spill index file created earlier
|
org.apache.hadoop.fs.Path |
getSpillIndexFileForWrite(int spillNumber,
long size)
Create a local map spill index file name.
|
void |
removeAll()
Removes all of the files related to a task.
|
void |
setConf(org.apache.hadoop.conf.Configuration conf) |
public org.apache.hadoop.fs.Path getOutputFile() throws java.io.IOException
java.io.IOException
public org.apache.hadoop.fs.Path getOutputFileForWrite(long size) throws java.io.IOException
size
- the size of the filejava.io.IOException
public org.apache.hadoop.fs.Path getOutputIndexFile() throws java.io.IOException
java.io.IOException
public org.apache.hadoop.fs.Path getOutputIndexFileForWrite(long size) throws java.io.IOException
size
- the size of the filejava.io.IOException
public org.apache.hadoop.fs.Path getSpillFile(int spillNumber) throws java.io.IOException
spillNumber
- the numberjava.io.IOException
public org.apache.hadoop.fs.Path getSpillFileForWrite(int spillNumber, long size) throws java.io.IOException
spillNumber
- the numbersize
- the size of the filejava.io.IOException
public org.apache.hadoop.fs.Path getSpillIndexFile(int spillNumber) throws java.io.IOException
spillNumber
- the numberjava.io.IOException
public org.apache.hadoop.fs.Path getSpillIndexFileForWrite(int spillNumber, long size) throws java.io.IOException
spillNumber
- the numbersize
- the size of the filejava.io.IOException
public org.apache.hadoop.fs.Path getInputFile(int mapId) throws java.io.IOException
mapId
- a map task idjava.io.IOException
public org.apache.hadoop.fs.Path getInputFileForWrite(TaskID mapId, long size) throws java.io.IOException
mapId
- a map task idsize
- the size of the filejava.io.IOException
public void removeAll() throws java.io.IOException
java.io.IOException
public void setConf(org.apache.hadoop.conf.Configuration conf)
Copyright © 2009 The Apache Software Foundation