Package 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
    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 Details

    • 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)