Package org.apache.druid.segment.writeout

Class ByteBufferWriteOutBytes

java.lang.Object
java.io.OutputStream
org.apache.druid.segment.writeout.WriteOutBytes
org.apache.druid.segment.writeout.ByteBufferWriteOutBytes
All Implemented Interfaces:
Closeable, Flushable, AutoCloseable, Channel, WritableByteChannel
Direct Known Subclasses:
HeapByteBufferWriteOutBytes
public abstract class ByteBufferWriteOutBytes extends WriteOutBytes

  • Method Details

    • size

      public long size()
      Description copied from class: WriteOutBytes
      Returns the number of bytes written to this WriteOutBytes so far.
      Specified by:
      size in class WriteOutBytes

    • allocateBuffer

      protected abstract ByteBuffer allocateBuffer()

    • write

      public void write(int b)
      Specified by:
      write in class OutputStream

    • writeInt

      public void writeInt(int v)
      Description copied from class: WriteOutBytes
      Writes 4 bytes of the given value in big-endian order, i. e. similar to DataOutput.writeInt(int).
      Specified by:
      writeInt in class WriteOutBytes

    • write

      public void write(byte[] b)
      Overrides:
      write in class OutputStream

    • write

      public void write(byte[] b, int off, int len)
      Overrides:
      write in class WriteOutBytes

    • write

      public int write(ByteBuffer src)

    • writeTo

      public void writeTo(WritableByteChannel channel) throws IOException
      Description copied from class: WriteOutBytes
      Takes all bytes that are written to this WriteOutBytes so far and writes them into the given channel.
      Specified by:
      writeTo in class WriteOutBytes
      Throws:
      IOException

    • writeTo

      public void writeTo(ByteBuffer out)
      Takes all bytes that are written to this WriteOutBytes so far and writes them into the given ByteBuffer. This method changes the position of the out buffer by the size() of this WriteOutBytes.
      Throws:
      BufferOverflowException - if the Buffer.remaining() capacity of the given buffer is smaller than the size of this WriteOutBytes

    • readFully

      public void readFully(long pos, ByteBuffer buffer)
      Description copied from class: WriteOutBytes
      Reads bytes from the byte sequences, represented by this WriteOutBytes, at the random position, into the given buffer.
      Specified by:
      readFully in class WriteOutBytes

    • asInputStream

      public InputStream asInputStream() throws IOException
      Description copied from class: WriteOutBytes
      Creates a finite InputStream with the bytes that are written to this WriteOutBytes so far. The returned InputStream must be closed properly after it's used up.
      Specified by:
      asInputStream in class WriteOutBytes
      Throws:
      IOException

    • isOpen

      public boolean isOpen()

    • free

      public void free()