org.apache.pig.backend.hadoop.datastorage

Class HSeekableInputStream

java.lang.Object

java.io.InputStream

org.apache.pig.backend.datastorage.SeekableInputStream

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

All Implemented Interfaces:

Closeable, AutoCloseable

public class HSeekableInputStream
extends SeekableInputStream

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pig.backend.datastorage.SeekableInputStream

SeekableInputStream.FLAGS

Field Summary

Fields

Modifier and Type	Field and Description
protected long	contentLength
protected org.apache.hadoop.fs.FSDataInputStream	input

Method Summary

Methods

Modifier and Type	Method and Description
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

Specified by:

close in interface AutoCloseable

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