org.apache.hadoop.io.compress
Class SplitCompressionInputStream

java.lang.Object
  extended by java.io.InputStream
      extended by org.apache.hadoop.io.compress.CompressionInputStream
          extended by org.apache.hadoop.io.compress.SplitCompressionInputStream
All Implemented Interfaces:
Closeable, Seekable

public abstract class SplitCompressionInputStream
extends CompressionInputStream

An InputStream covering a range of compressed data. The start and end offsets requested by a client may be modified by the codec to fit block boundaries or other algorithm-dependent requirements.


Field Summary
 
Fields inherited from class org.apache.hadoop.io.compress.CompressionInputStream
in, maxAvailableData
 
Constructor Summary
SplitCompressionInputStream(InputStream in, long start, long end)
           
 
Method Summary
 long getAdjustedEnd()
          After calling createInputStream, the values of start or end might change.
 long getAdjustedStart()
          After calling createInputStream, the values of start or end might change.
protected  void setEnd(long end)
           
protected  void setStart(long start)
           
 
Methods inherited from class org.apache.hadoop.io.compress.CompressionInputStream
close, getPos, read, resetState, seek, seekToNewSource
 
Methods inherited from class java.io.InputStream
available, mark, markSupported, read, read, reset, skip
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SplitCompressionInputStream

public SplitCompressionInputStream(InputStream in,
                                   long start,
                                   long end)
                            throws IOException
Throws:
IOException
Method Detail

setStart

protected void setStart(long start)

setEnd

protected void setEnd(long end)

getAdjustedStart

public long getAdjustedStart()
After calling createInputStream, the values of start or end might change. So this method can be used to get the new value of start.

Returns:
The changed value of start

getAdjustedEnd

public long getAdjustedEnd()
After calling createInputStream, the values of start or end might change. So this method can be used to get the new value of end.

Returns:
The changed value of end


Copyright © 2009 The Apache Software Foundation