Modifier and Type	Class and Description
private static class	RawMessageEncoder.BufferOutputStream

Modifier and Type	Field and Description
private final boolean	copyOutputBytes
private static final ThreadLocal<BinaryEncoder>	ENCODER
private static final ThreadLocal<RawMessageEncoder.BufferOutputStream>	TEMP
private final DatumWriter<D>	writer

Constructor Summary

Access	Constructor and Description
public	RawMessageEncoder(GenericData the `data model` for datum instances model, Schema the `Schema` for datum instances schema) Creates a new `RawMessageEncoder` that uses the given `data model` to deconstruct datum instances described by the `schema`.
public	RawMessageEncoder(GenericData the `data model` for datum instances model, Schema the `Schema` for datum instances schema, boolean whether to copy buffers before returning encoded results shouldCopy) Creates a new `RawMessageEncoder` that uses the given `data model` to deconstruct datum instances described by the `schema`.

Method Summary

Modifier and Type	Method and Description
public ByteBuffer	encode(D a datum datum) Implements org.apache.avro.message.MessageEncoder.encode. Serialize a single datum to a ByteBuffer.
public void	encode(D a datum datum, OutputStream an OutputStream to serialize the datum to stream) Implements org.apache.avro.message.MessageEncoder.encode. Serialize a single datum to an OutputStream.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

copyOutputBytes	back to summary
private final boolean copyOutputBytes

ENCODER	back to summary
private static final ThreadLocal<BinaryEncoder> ENCODER

TEMP	back to summary
private static final ThreadLocal<RawMessageEncoder.BufferOutputStream> TEMP

writer	back to summary
private final DatumWriter<D> writer

Constructor Detail

RawMessageEncoder back to summary

RawMessageEncoder	back to summary
public RawMessageEncoder(GenericData model, Schema schema) Creates a new `RawMessageEncoder` that uses the given `data model` to deconstruct datum instances described by the `schema`. Buffers returned by `RawMessageEncoder#encode` are copied and will not be modified by future calls to `encode`. Parameters model:GenericData the `data model` for datum instances schema:Schema the `Schema` for datum instances

public RawMessageEncoder(GenericData model, Schema schema)

Creates a new RawMessageEncoder that uses the given data model to deconstruct datum instances described by the schema.

Buffers returned by RawMessageEncoder#encode are copied and will not be modified by future calls to encode.

Parameters

model:GenericData: the data model for datum instances
schema:Schema: the Schema for datum instances

RawMessageEncoder back to summary

RawMessageEncoder	back to summary
public RawMessageEncoder(GenericData model, Schema schema, boolean shouldCopy) Creates a new `RawMessageEncoder` that uses the given `data model` to deconstruct datum instances described by the `schema`. If `shouldCopy` is true, then buffers returned by `RawMessageEncoder#encode` are copied and will not be modified by future calls to `encode`. If `shouldCopy` is false, then buffers returned by `encode` wrap a thread-local buffer that can be reused by future calls to `encode`, but may not be. Callers should only set `shouldCopy` to false if the buffer will be copied before the current thread's next call to `encode`. Parameters model:GenericData the `data model` for datum instances schema:Schema the `Schema` for datum instances shouldCopy:boolean whether to copy buffers before returning encoded results

public RawMessageEncoder(GenericData model, Schema schema, boolean shouldCopy)

Creates a new RawMessageEncoder that uses the given data model to deconstruct datum instances described by the schema.

If shouldCopy is true, then buffers returned by RawMessageEncoder#encode are copied and will not be modified by future calls to encode.

If shouldCopy is false, then buffers returned by encode wrap a thread-local buffer that can be reused by future calls to encode, but may not be. Callers should only set shouldCopy to false if the buffer will be copied before the current thread's next call to encode.

Parameters

model:GenericData: the data model for datum instances
schema:Schema: the Schema for datum instances
shouldCopy:boolean: whether to copy buffers before returning encoded results

Method Detail

encode	back to summary
public ByteBuffer encode(D datum) throws IOException Implements org.apache.avro.message.MessageEncoder.encode. Doc from org.apache.avro.message.MessageEncoder.encode. Serialize a single datum to a ByteBuffer. Parameters datum:D a datum Returns:ByteBuffer a ByteBuffer containing the serialized datum Annotations @Override

encode

back to summary

public ByteBuffer encode(D datum) throws IOException

Implements org.apache.avro.message.MessageEncoder.encode.

Doc from org.apache.avro.message.MessageEncoder.encode.

Serialize a single datum to a ByteBuffer.

Parameters

datum:D: a datum

Returns:ByteBuffer

a ByteBuffer containing the serialized datum

Annotations

@Override

encode	back to summary
public void encode(D datum, OutputStream stream) throws IOException Implements org.apache.avro.message.MessageEncoder.encode. Doc from org.apache.avro.message.MessageEncoder.encode. Serialize a single datum to an OutputStream. Parameters datum:D a datum stream:OutputStream an OutputStream to serialize the datum to Annotations @Override

encode

back to summary

public void encode(D datum, OutputStream stream) throws IOException

Implements org.apache.avro.message.MessageEncoder.encode.

Doc from org.apache.avro.message.MessageEncoder.encode.

Serialize a single datum to an OutputStream.

Parameters