org.apache.hadoop.mapred

Class Merger.Segment<K,V>

java.lang.Object

org.apache.hadoop.mapred.Merger.Segment<K,V>

Enclosing class:

Merger

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

Constructor Summary

Constructors

Constructor and Description
Merger.Segment(Configuration conf, FileSystem fs, Path file, CompressionCodec codec, boolean preserve)
Merger.Segment(Configuration conf, FileSystem fs, Path file, CompressionCodec codec, boolean preserve, Counters.Counter mergedMapOutputsCounter)
Merger.Segment(Configuration conf, FileSystem fs, Path file, CompressionCodec codec, boolean preserve, Counters.Counter mergedMapOutputsCounter, long rawDataLength)
Merger.Segment(Configuration conf, FileSystem fs, Path file, long segmentOffset, long segmentLength, CompressionCodec codec, boolean preserve)
Merger.Segment(Configuration conf, FileSystem fs, Path file, long segmentOffset, long segmentLength, CompressionCodec codec, boolean preserve, Counters.Counter mergedMapOutputsCounter)
Merger.Segment(IFile.Reader<K,V> reader, boolean preserve)
Merger.Segment(IFile.Reader<K,V> reader, boolean preserve, Counters.Counter mapOutputsCounter)
Merger.Segment(IFile.Reader<K,V> reader, boolean preserve, long rawDataLength)

Method Summary

Methods

Modifier and Type	Method and Description
long	getLength()
long	getPosition()
long	getRawDataLength()

Methods inherited from class java.lang.Object

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

Constructor Detail

Merger.Segment

public Merger.Segment(Configuration conf,
              FileSystem fs,
              Path file,
              CompressionCodec codec,
              boolean preserve)
               throws IOException

Throws:

IOException

Merger.Segment

public Merger.Segment(Configuration conf,
              FileSystem fs,
              Path file,
              CompressionCodec codec,
              boolean preserve,
              Counters.Counter mergedMapOutputsCounter)
               throws IOException

Throws:

IOException

Merger.Segment

public Merger.Segment(Configuration conf,
              FileSystem fs,
              Path file,
              CompressionCodec codec,
              boolean preserve,
              Counters.Counter mergedMapOutputsCounter,
              long rawDataLength)
               throws IOException

Throws:

IOException

Merger.Segment

public Merger.Segment(Configuration conf,
              FileSystem fs,
              Path file,
              long segmentOffset,
              long segmentLength,
              CompressionCodec codec,
              boolean preserve)
               throws IOException

Throws:

IOException

Merger.Segment

public Merger.Segment(Configuration conf,
              FileSystem fs,
              Path file,
              long segmentOffset,
              long segmentLength,
              CompressionCodec codec,
              boolean preserve,
              Counters.Counter mergedMapOutputsCounter)
               throws IOException

Throws:

IOException

Merger.Segment

public Merger.Segment(IFile.Reader<K,V> reader,
              boolean preserve)

Merger.Segment

public Merger.Segment(IFile.Reader<K,V> reader,
              boolean preserve,
              long rawDataLength)

Merger.Segment

public Merger.Segment(IFile.Reader<K,V> reader,
              boolean preserve,
              Counters.Counter mapOutputsCounter)

Method Detail

getLength

public long getLength()

getRawDataLength

public long getRawDataLength()

getPosition

public long getPosition()
                 throws IOException

Throws:

IOException