Package org.apache.avro.io

Class DirectBinaryEncoder

java.lang.Object

org.apache.avro.io.Encoder

org.apache.avro.io.BinaryEncoder

org.apache.avro.io.DirectBinaryEncoder

All Implemented Interfaces:

Flushable

Direct Known Subclasses:

BlockingDirectBinaryEncoder

public class DirectBinaryEncoder
extends BinaryEncoder

An Encoder for Avro's binary encoding that does not buffer output.

This encoder does not buffer writes, and as a result is slower than BufferedBinaryEncoder. However, it is lighter-weight and useful when the buffering in BufferedBinaryEncoder is not desired and/or the Encoder is very short-lived.

To construct, use EncoderFactory.directBinaryEncoder(OutputStream, BinaryEncoder)

DirectBinaryEncoder is not thread-safe

See Also:

• BinaryEncoder
• EncoderFactory
• Encoder
• Decoder

Field Summary

Fields

Modifier and Type	Field	Description
protected OutputStream	out

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DirectBinaryEncoder(OutputStream out)	Create a writer that sends its output to the underlying stream out.

Method Summary

Modifier and Type	Method	Description
int	bytesBuffered()	Returns the number of bytes currently buffered by this encoder.
void	flush()
void	writeBoolean(boolean b)	Write a boolean value.
void	writeDouble(double d)	Write a double.
void	writeFixed(byte[] bytes, int start, int len)	Writes a fixed size binary object.
void	writeFloat(float f)	Write a float.
void	writeInt(int n)	Writes a 32-bit integer.
void	writeLong(long n)	Write a 64-bit integer.
protected void	writeZero()	Write a zero byte to the underlying output.

Methods inherited from class org.apache.avro.io.BinaryEncoder

setItemCount, startItem, writeArrayEnd, writeArrayStart, writeBytes, writeBytes, writeEnum, writeIndex, writeMapEnd, writeMapStart, writeNull, writeString, writeString

Methods inherited from class org.apache.avro.io.Encoder

writeBytes, writeFixed, writeFixed, writeString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

out

protected OutputStream out

Constructor Details

DirectBinaryEncoder

protected DirectBinaryEncoder(OutputStream out)

Create a writer that sends its output to the underlying stream out.

Method Details

flush

public void flush()
           throws IOException

Throws:

IOException

writeBoolean

public void writeBoolean(boolean b)
                  throws IOException

Description copied from class: Encoder

Write a boolean value.

Specified by:

writeBoolean in class Encoder

Throws:

IOException

writeInt

public void writeInt(int n)
              throws IOException

Description copied from class: Encoder

Writes a 32-bit integer.

Specified by:

writeInt in class Encoder

Throws:

IOException

writeLong

public void writeLong(long n)
               throws IOException

Description copied from class: Encoder

Write a 64-bit integer.

Specified by:

writeLong in class Encoder

Throws:

IOException

writeFloat

public void writeFloat(float f)
                throws IOException

Description copied from class: Encoder

Write a float.

Specified by:

writeFloat in class Encoder

Throws:

IOException

writeDouble

public void writeDouble(double d)
                 throws IOException

Description copied from class: Encoder

Write a double.

Specified by:

writeDouble in class Encoder

Throws:

IOException

writeFixed

public void writeFixed(byte[] bytes,
 int start,
 int len)
                throws IOException

Description copied from class: Encoder

Writes a fixed size binary object.

Specified by:

writeFixed in class Encoder

Parameters:

bytes - The contents to write

start - The position within bytes where the contents start.

len - The number of bytes to write.

Throws:

IOException

writeZero

protected void writeZero()
                  throws IOException

Description copied from class: BinaryEncoder

Write a zero byte to the underlying output.

Specified by:

writeZero in class BinaryEncoder

Throws:

IOException

bytesBuffered

public int bytesBuffered()

Description copied from class: BinaryEncoder

Returns the number of bytes currently buffered by this encoder. If this Encoder does not buffer, this will always return zero.

Call Flushable.flush() to empty the buffer to the underlying output.

Specified by:

bytesBuffered in class BinaryEncoder