Package com.linkedin.venice.serializer

Class AvroSerializer<K>

java.lang.Object

com.linkedin.venice.serializer.AvroSerializer<K>

All Implemented Interfaces:

RecordSerializer<K>

Direct Known Subclasses:

FastAvroSerializer, MapOrderPreservingFastSerializer, MapOrderPreservingSerializer, VsonAvroGenericSerializer

public class AvroSerializer<K>
extends Object
implements RecordSerializer<K>

AvroSerializer provides the functionality to serialize objects by using Avro.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AvroSerializer(org.apache.avro.io.DatumWriter<K> genericDatumWriter, org.apache.avro.io.DatumWriter<K> specificDatumWriter)
protected	AvroSerializer(org.apache.avro.io.DatumWriter<K> genericDatumWriter, org.apache.avro.io.DatumWriter<K> specificDatumWriter, boolean buffered)
	AvroSerializer(org.apache.avro.Schema schema)
	AvroSerializer(org.apache.avro.Schema schema, boolean buffered)

Method Summary

Modifier and Type	Method	Description
byte[]	serialize(K object)
byte[]	serializeObjects(Iterable<K> objects)
byte[]	serializeObjects(Iterable<K> objects, ByteBuffer prefix)	Serialize a list of objects and put the prefix before the serialized objects.
protected byte[]	serializeObjects(Iterable<K> objects, org.apache.avro.io.BinaryEncoder reusedEncoder, ByteArrayOutputStream outputStream)
protected void	write(K object, org.apache.avro.io.Encoder encoder)

Methods inherited from class java.lang.Object

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

Constructor Details

AvroSerializer

public AvroSerializer(org.apache.avro.Schema schema)

AvroSerializer

public AvroSerializer(org.apache.avro.Schema schema,
 boolean buffered)

AvroSerializer

protected AvroSerializer(org.apache.avro.io.DatumWriter<K> genericDatumWriter,
 org.apache.avro.io.DatumWriter<K> specificDatumWriter)

AvroSerializer

protected AvroSerializer(org.apache.avro.io.DatumWriter<K> genericDatumWriter,
 org.apache.avro.io.DatumWriter<K> specificDatumWriter,
 boolean buffered)

Method Details

serialize

public byte[] serialize(K object)
                 throws VeniceException

Specified by:

serialize in interface RecordSerializer<K>

Throws:

VeniceException

serializeObjects

public byte[] serializeObjects(Iterable<K> objects)
                        throws VeniceException

Specified by:

serializeObjects in interface RecordSerializer<K>

Throws:

VeniceException

serializeObjects

public byte[] serializeObjects(Iterable<K> objects,
 ByteBuffer prefix)
                        throws VeniceException

Serialize a list of objects and put the prefix before the serialized objects. This function could avoid unnecessary byte array copy when you want to serialize two different kinds of objects together. Essentially, the will be the serialized byte array of the first kind of objects.

Specified by:

serializeObjects in interface RecordSerializer<K>

Parameters:

objects -

prefix -

Returns:

Throws:

VeniceException

serializeObjects

protected byte[] serializeObjects(Iterable<K> objects,
 org.apache.avro.io.BinaryEncoder reusedEncoder,
 ByteArrayOutputStream outputStream)
                           throws VeniceException

Throws:

VeniceException

write

protected void write(K object,
 org.apache.avro.io.Encoder encoder)
              throws IOException

Throws:

IOException