Skip to content

Commit

Permalink
AVRO-4052: Inline BufferedBinaryEncoder writeZero method (#3145)
Browse files Browse the repository at this point in the history
  • Loading branch information
belugabehr authored Sep 15, 2024
1 parent 67ed331 commit d6f755f
Showing 1 changed file with 4 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@
* <p/>
* To change the buffer size, configure the factory instance used to create
* instances with {@link EncoderFactory#configureBufferSize(int)}
*
*
* @see Encoder
* @see EncoderFactory
* @see BlockingBinaryEncoder
Expand Down Expand Up @@ -105,7 +105,7 @@ private void flushBuffer() throws IOException {
* current position and the end. This will not expand the buffer larger than its
* current size, for writes larger than or near to the size of the buffer, we
* flush the buffer and write directly to the output, bypassing the buffer.
*
*
* @param num
* @throws IOException
*/
Expand Down Expand Up @@ -175,14 +175,11 @@ public void writeFixed(ByteBuffer bytes) throws IOException {

@Override
protected void writeZero() throws IOException {
writeByte(0);
}

private void writeByte(int b) throws IOException {
// inlined, shorter version of writeZero
if (pos == buf.length) {
flushBuffer();
}
buf[pos++] = (byte) (b & 0xFF);
buf[pos++] = (byte) 0;
}

@Override
Expand Down

0 comments on commit d6f755f

Please sign in to comment.