Class RateLimitedIndexOutput

    • Field Detail

      • bytesSinceLastPause

        private long bytesSinceLastPause
        How many bytes we've written since we last called rateLimiter.pause.
      • currentMinPauseCheckBytes

        private long currentMinPauseCheckBytes
        Cached here not not always have to call RateLimiter#getMinPauseCheckBytes() which does volatile read.
    • Constructor Detail

    • Method Detail

      • writeByte

        public void writeByte​(byte b)
                       throws java.io.IOException
        Description copied from class: DataOutput
        Writes a single byte.

        The most primitive data type is an eight-bit byte. Files are accessed as sequences of bytes. All other data types are defined as sequences of bytes, so file formats are byte-order independent.

        Overrides:
        writeByte in class FilterIndexOutput
        Throws:
        java.io.IOException
        See Also:
        DataInput.readByte()
      • writeBytes

        public void writeBytes​(byte[] b,
                               int offset,
                               int length)
                        throws java.io.IOException
        Description copied from class: DataOutput
        Writes an array of bytes.
        Overrides:
        writeBytes in class FilterIndexOutput
        Parameters:
        b - the bytes to write
        offset - the offset in the byte array
        length - the number of bytes to write
        Throws:
        java.io.IOException
        See Also:
        DataInput.readBytes(byte[],int,int)
      • checkRate

        private void checkRate()
                        throws java.io.IOException
        Throws:
        java.io.IOException