Package org.apache.drill.exec.store.dfs

Class SeekableByteArrayInputStream

java.lang.Object

java.io.InputStream

java.io.ByteArrayInputStream

org.apache.drill.exec.store.dfs.SeekableByteArrayInputStream

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.fs.PositionedReadable, org.apache.hadoop.fs.Seekable

public class SeekableByteArrayInputStream
extends ByteArrayInputStream
implements org.apache.hadoop.fs.Seekable, org.apache.hadoop.fs.PositionedReadable

Field Summary

Fields inherited from class java.io.ByteArrayInputStream

buf, count, mark, pos

Constructor Summary

Constructors

Constructor	Description
SeekableByteArrayInputStream(byte[] buf)

Method Summary

Modifier and Type	Method	Description
long	getPos()
int	read(long position, byte[] buffer, int offset, int length)
void	readFully(long position, byte[] buffer)
void	readFully(long position, byte[] buffer, int offset, int length)
void	seek(long pos)
boolean	seekToNewSource(long targetPos)

Methods inherited from class java.io.ByteArrayInputStream

available, close, mark, markSupported, read, read, readAllBytes, readNBytes, reset, skip, transferTo

Methods inherited from class java.io.InputStream

nullInputStream, read, readNBytes

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.fs.PositionedReadable

maxReadSizeForVectorReads, minSeekForVectorReads, readVectored

Constructor Details

SeekableByteArrayInputStream

public SeekableByteArrayInputStream(byte[] buf)

Method Details

getPos

public long getPos()
            throws IOException

Specified by:

getPos in interface org.apache.hadoop.fs.Seekable

Throws:

IOException

seek

public void seek(long pos)
          throws IOException

Specified by:

seek in interface org.apache.hadoop.fs.Seekable

Throws:

IOException

seekToNewSource

public boolean seekToNewSource(long targetPos)
                        throws IOException

Specified by:

seekToNewSource in interface org.apache.hadoop.fs.Seekable

Throws:

IOException

read

public int read(long position,
 byte[] buffer,
 int offset,
 int length)
         throws IOException

Specified by:

read in interface org.apache.hadoop.fs.PositionedReadable

Throws:

IOException

readFully

public void readFully(long position,
 byte[] buffer)
               throws IOException

Specified by:

readFully in interface org.apache.hadoop.fs.PositionedReadable

Throws:

IOException

readFully

public void readFully(long position,
 byte[] buffer,
 int offset,
 int length)
               throws IOException

Specified by:

readFully in interface org.apache.hadoop.fs.PositionedReadable

Throws:

IOException