org.apache.pig.backend.hadoop.datastorage
Class HSeekableInputStream

java.lang.Object
  extended by java.io.InputStream
      extended by org.apache.pig.backend.datastorage.SeekableInputStream
          extended by org.apache.pig.backend.hadoop.datastorage.HSeekableInputStream
All Implemented Interfaces:
Closeable

public class HSeekableInputStream
extends SeekableInputStream


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.pig.backend.datastorage.SeekableInputStream
SeekableInputStream.FLAGS
 
Field Summary
protected  long contentLength
           
protected  org.apache.hadoop.fs.FSDataInputStream input
           
 
Method Summary
 int available()
           
 void close()
           
 void mark(int readlimit)
           
 boolean markSupported()
           
 int read()
           
 int read(byte[] b)
           
 int read(byte[] b, int off, int len)
           
 void reset()
           
 void seek(long offset, SeekableInputStream.FLAGS whence)
          Seeks to a given offset as specified by whence flags.
 long skip(long n)
           
 long tell()
          Returns current offset
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

input

protected org.apache.hadoop.fs.FSDataInputStream input

contentLength

protected long contentLength
Method Detail

seek

public void seek(long offset,
                 SeekableInputStream.FLAGS whence)
          throws IOException
Description copied from class: SeekableInputStream
Seeks to a given offset as specified by whence flags. If whence is SEEK_SET, offset is added to beginning of stream If whence is SEEK_CUR, offset is added to current position inside stream If whence is SEEK_END, offset is added to end of file position

Specified by:
seek in class SeekableInputStream
Throws:
IOException

tell

public long tell()
          throws IOException
Description copied from class: SeekableInputStream
Returns current offset

Specified by:
tell in class SeekableInputStream
Returns:
offset
Throws:
IOException

read

public int read()
         throws IOException
Specified by:
read in class InputStream
Throws:
IOException

read

public int read(byte[] b)
         throws IOException
Overrides:
read in class InputStream
Throws:
IOException

read

public int read(byte[] b,
                int off,
                int len)
         throws IOException
Overrides:
read in class InputStream
Throws:
IOException

available

public int available()
              throws IOException
Overrides:
available in class InputStream
Throws:
IOException

skip

public long skip(long n)
          throws IOException
Overrides:
skip in class InputStream
Throws:
IOException

close

public void close()
           throws IOException
Specified by:
close in interface Closeable
Overrides:
close in class InputStream
Throws:
IOException

mark

public void mark(int readlimit)
Overrides:
mark in class InputStream

reset

public void reset()
           throws IOException
Overrides:
reset in class InputStream
Throws:
IOException

markSupported

public boolean markSupported()
Overrides:
markSupported in class InputStream


Copyright © 2007-2012 The Apache Software Foundation