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