org.apache.tez.runtime.library.common.sort.impl
Class TezSpillRecord

java.lang.Object
  org.apache.tez.runtime.library.common.sort.impl.TezSpillRecord

public class TezSpillRecord
extends Object

Constructor Summary

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)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TezSpillRecord

public TezSpillRecord(int numPartitions)

TezSpillRecord

public TezSpillRecord(org.apache.hadoop.fs.Path indexFileName,
                      org.apache.hadoop.conf.Configuration job)
               throws IOException

Throws:

IOException

TezSpillRecord

public TezSpillRecord(org.apache.hadoop.fs.Path indexFileName,
                      org.apache.hadoop.conf.Configuration job,
                      String expectedIndexOwner)
               throws IOException

Throws:

IOException

TezSpillRecord

public TezSpillRecord(org.apache.hadoop.fs.Path indexFileName,
                      org.apache.hadoop.conf.Configuration job,
                      Checksum crc,
                      String expectedIndexOwner)
               throws IOException

Throws:

IOException

Method Detail

size

public int size()

Return number of IndexRecord entries in this spill.

getIndex

public TezIndexRecord getIndex(int partition)

Get spill offsets for given partition.

putIndex

public void putIndex(TezIndexRecord rec,
                     int partition)

Set spill offsets for given partition.

writeToFile

public void writeToFile(org.apache.hadoop.fs.Path loc,
                        org.apache.hadoop.conf.Configuration job)
                 throws IOException

Write this spill record to the location provided.

Throws:

IOException

writeToFile

public void writeToFile(org.apache.hadoop.fs.Path loc,
                        org.apache.hadoop.conf.Configuration job,
                        Checksum crc)
                 throws IOException

Throws:

IOException