org.apache.drill.exec.vector.complex.fn

Class DrillBufInputStream

java.lang.Object

java.io.InputStream

io.netty.buffer.ByteBufInputStream

org.apache.drill.exec.vector.complex.fn.DrillBufInputStream

All Implemented Interfaces:

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

public class DrillBufInputStream
extends io.netty.buffer.ByteBufInputStream
implements org.apache.hadoop.fs.Seekable

An InputStream that wraps a DrillBuf and implements the seekable interface.

Method Summary

Modifier and Type	Method and Description
long	getPos()
static DrillBufInputStream	getStream(int start, int end, DrillBuf buffer)
void	seek(long pos)
boolean	seekToNewSource(long targetPos)

Methods inherited from class io.netty.buffer.ByteBufInputStream

available, close, mark, markSupported, read, read, readBoolean, readByte, readBytes, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, readUTF, reset, skip, skipBytes

Methods inherited from class java.io.InputStream

read

Methods inherited from class java.lang.Object

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

Method Detail

seek

public void seek(long pos)
          throws IOException

Specified by:

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

Throws:

IOException

getPos

public long getPos()
            throws IOException

Specified by:

getPos 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

getStream

public static DrillBufInputStream getStream(int start,
                                            int end,
                                            DrillBuf buffer)