org.apache.tez.runtime.library.common.sort.impl
Class TezMerger.Segment<K,V>

java.lang.Object
  org.apache.tez.runtime.library.common.sort.impl.TezMerger.Segment<K,V>

Enclosing class:

TezMerger

@InterfaceAudience.Private
@InterfaceStability.Unstable
public static class TezMerger.Segment<K,V>
extends Object

Constructor Summary

TezMerger.Segment(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, org.apache.hadoop.io.compress.CompressionCodec codec, boolean ifileReadAhead, int ifileReadAheadLength, int bufferSize, boolean preserve)

TezMerger.Segment(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, org.apache.hadoop.io.compress.CompressionCodec codec, boolean ifileReadAhead, int ifileReadAheadLenth, int bufferSize, boolean preserve, org.apache.tez.common.counters.TezCounter mergedMapOutputsCounter)

TezMerger.Segment(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, long segmentOffset, long segmentLength, org.apache.hadoop.io.compress.CompressionCodec codec, boolean ifileReadAhead, int ifileReadAheadLength, int bufferSize, boolean preserve)

TezMerger.Segment(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, long segmentOffset, long segmentLength, org.apache.hadoop.io.compress.CompressionCodec codec, boolean ifileReadAhead, int ifileReadAheadLength, int bufferSize, boolean preserve, org.apache.tez.common.counters.TezCounter mergedMapOutputsCounter)

TezMerger.Segment(IFile.Reader reader, boolean preserve)

TezMerger.Segment(IFile.Reader reader, boolean preserve, org.apache.tez.common.counters.TezCounter mapOutputsCounter)

Method Summary

long	getLength()
long	getPosition()

Methods inherited from class java.lang.Object

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

Constructor Detail

TezMerger.Segment

public TezMerger.Segment(org.apache.hadoop.conf.Configuration conf,
                         org.apache.hadoop.fs.FileSystem fs,
                         org.apache.hadoop.fs.Path file,
                         org.apache.hadoop.io.compress.CompressionCodec codec,
                         boolean ifileReadAhead,
                         int ifileReadAheadLength,
                         int bufferSize,
                         boolean preserve)
                  throws IOException

Throws:

IOException

TezMerger.Segment

public TezMerger.Segment(org.apache.hadoop.conf.Configuration conf,
                         org.apache.hadoop.fs.FileSystem fs,
                         org.apache.hadoop.fs.Path file,
                         org.apache.hadoop.io.compress.CompressionCodec codec,
                         boolean ifileReadAhead,
                         int ifileReadAheadLenth,
                         int bufferSize,
                         boolean preserve,
                         org.apache.tez.common.counters.TezCounter mergedMapOutputsCounter)
                  throws IOException

Throws:

IOException

TezMerger.Segment

public TezMerger.Segment(org.apache.hadoop.conf.Configuration conf,
                         org.apache.hadoop.fs.FileSystem fs,
                         org.apache.hadoop.fs.Path file,
                         long segmentOffset,
                         long segmentLength,
                         org.apache.hadoop.io.compress.CompressionCodec codec,
                         boolean ifileReadAhead,
                         int ifileReadAheadLength,
                         int bufferSize,
                         boolean preserve)
                  throws IOException

Throws:

IOException

TezMerger.Segment

public TezMerger.Segment(org.apache.hadoop.conf.Configuration conf,
                         org.apache.hadoop.fs.FileSystem fs,
                         org.apache.hadoop.fs.Path file,
                         long segmentOffset,
                         long segmentLength,
                         org.apache.hadoop.io.compress.CompressionCodec codec,
                         boolean ifileReadAhead,
                         int ifileReadAheadLength,
                         int bufferSize,
                         boolean preserve,
                         org.apache.tez.common.counters.TezCounter mergedMapOutputsCounter)
                  throws IOException

Throws:

IOException

TezMerger.Segment

public TezMerger.Segment(IFile.Reader reader,
                         boolean preserve)

TezMerger.Segment

public TezMerger.Segment(IFile.Reader reader,
                         boolean preserve,
                         org.apache.tez.common.counters.TezCounter mapOutputsCounter)

Method Detail

getLength

public long getLength()

getPosition

public long getPosition()
                 throws IOException

Throws:

IOException