@InterfaceAudience.LimitedPrivate(value="MapReduce")
@InterfaceStability.Unstable
public class SpillRecord
extends java.lang.Object
Constructor and Description |
---|
SpillRecord(int numPartitions) |
SpillRecord(org.apache.hadoop.fs.Path indexFileName,
JobConf job,
java.util.zip.Checksum crc,
java.lang.String expectedIndexOwner) |
SpillRecord(org.apache.hadoop.fs.Path indexFileName,
JobConf job,
java.lang.String expectedIndexOwner) |
Modifier and Type | Method and Description |
---|---|
IndexRecord |
getIndex(int partition)
Get spill offsets for given partition.
|
void |
putIndex(IndexRecord rec,
int partition)
Set spill offsets for given partition.
|
int |
size()
Return number of IndexRecord entries in this spill.
|
void |
writeToFile(org.apache.hadoop.fs.Path loc,
JobConf job)
Write this spill record to the location provided.
|
void |
writeToFile(org.apache.hadoop.fs.Path loc,
JobConf job,
java.util.zip.Checksum crc) |
public SpillRecord(int numPartitions)
public SpillRecord(org.apache.hadoop.fs.Path indexFileName, JobConf job, java.lang.String expectedIndexOwner) throws java.io.IOException
java.io.IOException
public SpillRecord(org.apache.hadoop.fs.Path indexFileName, JobConf job, java.util.zip.Checksum crc, java.lang.String expectedIndexOwner) throws java.io.IOException
java.io.IOException
public int size()
public IndexRecord getIndex(int partition)
public void putIndex(IndexRecord rec, int partition)
public void writeToFile(org.apache.hadoop.fs.Path loc, JobConf job) throws java.io.IOException
java.io.IOException
public void writeToFile(org.apache.hadoop.fs.Path loc, JobConf job, java.util.zip.Checksum crc) throws java.io.IOException
java.io.IOException
Copyright © 2009 The Apache Software Foundation