public class TezSpillRecord extends Object
Constructor and Description |
---|
TezSpillRecord(int numPartitions) |
TezSpillRecord(org.apache.hadoop.fs.Path indexFileName,
org.apache.hadoop.conf.Configuration job) |
TezSpillRecord(org.apache.hadoop.fs.Path indexFileName,
org.apache.hadoop.conf.Configuration job,
Checksum crc,
String expectedIndexOwner) |
TezSpillRecord(org.apache.hadoop.fs.Path indexFileName,
org.apache.hadoop.conf.Configuration job,
String expectedIndexOwner) |
Modifier and Type | Method and Description |
---|---|
TezIndexRecord |
getIndex(int partition)
Get spill offsets for given partition.
|
void |
putIndex(TezIndexRecord 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,
org.apache.hadoop.conf.Configuration job)
Write this spill record to the location provided.
|
void |
writeToFile(org.apache.hadoop.fs.Path loc,
org.apache.hadoop.conf.Configuration job,
Checksum crc) |
public TezSpillRecord(int numPartitions)
public TezSpillRecord(org.apache.hadoop.fs.Path indexFileName, org.apache.hadoop.conf.Configuration job) throws IOException
IOException
public TezSpillRecord(org.apache.hadoop.fs.Path indexFileName, org.apache.hadoop.conf.Configuration job, String expectedIndexOwner) throws IOException
IOException
public TezSpillRecord(org.apache.hadoop.fs.Path indexFileName, org.apache.hadoop.conf.Configuration job, Checksum crc, String expectedIndexOwner) throws IOException
IOException
public int size()
public TezIndexRecord getIndex(int partition)
public void putIndex(TezIndexRecord rec, int partition)
public void writeToFile(org.apache.hadoop.fs.Path loc, org.apache.hadoop.conf.Configuration job) throws IOException
IOException
public void writeToFile(org.apache.hadoop.fs.Path loc, org.apache.hadoop.conf.Configuration job, Checksum crc) throws IOException
IOException
Copyright © 2015 Apache Software Foundation. All rights reserved.