@InterfaceAudience.Private @InterfaceStability.Unstable public abstract class MapOutputFile extends Object implements Configurable
Constructor and Description |
---|
MapOutputFile() |
Modifier and Type | Method and Description |
---|---|
Configuration |
getConf()
Return the configuration used by this object.
|
abstract Path |
getInputFile(int mapId)
Return a local reduce input file created earlier
|
abstract Path |
getInputFileForWrite(TaskID mapId,
long size)
Create a local reduce input file name.
|
abstract Path |
getOutputFile()
Return the path to local map output file created earlier
|
abstract Path |
getOutputFileForWrite(long size)
Create a local map output file name.
|
abstract Path |
getOutputFileForWriteInVolume(Path existing)
Create a local map output file name on the same volume.
|
abstract Path |
getOutputIndexFile()
Return the path to a local map output index file created earlier
|
abstract Path |
getOutputIndexFileForWrite(long size)
Create a local map output index file name.
|
abstract Path |
getOutputIndexFileForWriteInVolume(Path existing)
Create a local map output index file name on the same volume.
|
abstract Path |
getSpillFile(int spillNumber)
Return a local map spill file created earlier.
|
abstract Path |
getSpillFileForWrite(int spillNumber,
long size)
Create a local map spill file name.
|
abstract Path |
getSpillIndexFile(int spillNumber)
Return a local map spill index file created earlier
|
abstract Path |
getSpillIndexFileForWrite(int spillNumber,
long size)
Create a local map spill index file name.
|
abstract void |
removeAll()
Removes all of the files related to a task.
|
void |
setConf(Configuration conf)
Set the configuration to be used by this object.
|
public abstract Path getOutputFile() throws IOException
IOException
public abstract Path getOutputFileForWrite(long size) throws IOException
size
- the size of the fileIOException
public abstract Path getOutputFileForWriteInVolume(Path existing)
public abstract Path getOutputIndexFile() throws IOException
IOException
public abstract Path getOutputIndexFileForWrite(long size) throws IOException
size
- the size of the fileIOException
public abstract Path getOutputIndexFileForWriteInVolume(Path existing)
public abstract Path getSpillFile(int spillNumber) throws IOException
spillNumber
- the numberIOException
public abstract Path getSpillFileForWrite(int spillNumber, long size) throws IOException
spillNumber
- the numbersize
- the size of the fileIOException
public abstract Path getSpillIndexFile(int spillNumber) throws IOException
spillNumber
- the numberIOException
public abstract Path getSpillIndexFileForWrite(int spillNumber, long size) throws IOException
spillNumber
- the numbersize
- the size of the fileIOException
public abstract Path getInputFile(int mapId) throws IOException
mapId
- a map task idIOException
public abstract Path getInputFileForWrite(TaskID mapId, long size) throws IOException
mapId
- a map task idsize
- the size of the fileIOException
public abstract void removeAll() throws IOException
IOException
public void setConf(Configuration conf)
Configurable
setConf
in interface Configurable
public Configuration getConf()
Configurable
getConf
in interface Configurable
Copyright © 2013 Apache Software Foundation. All rights reserved.