Package com.linkedin.davinci.replication.merge

Class RmdSerDe

java.lang.Object

com.linkedin.davinci.replication.merge.RmdSerDe

public class RmdSerDe
extends Object

This class is responsible for serialization and deserialization related tasks. Specifically 3 things: 1. Deserialize RMD from bytes. 2. Serialize RMD record to bytes. 3. Get RMD schema given its value schema ID.

Constructor Summary

Constructors

Constructor	Description
RmdSerDe(StringAnnotatedStoreSchemaCache annotatedStoreSchemaCache, int rmdVersionId)
RmdSerDe(StringAnnotatedStoreSchemaCache annotatedStoreSchemaCache, int rmdVersionId, boolean fastAvroEnabled)

Method Summary

Modifier and Type	Method	Description
org.apache.avro.generic.GenericRecord	deserializeRmdBytes(int writerSchemaID, int readerSchemaID, ByteBuffer rmdBytes)	Given a value schema ID and RMD bytes , find the RMD schema that corresponds to the given value schema ID and use that RMD schema to deserialize RMD bytes in a RMD record.
void	deserializeValueSchemaIdPrependedRmdBytes(byte[] valueSchemaIdPrependedBytes, RmdWithValueSchemaId rmdWithValueSchemaId)	This method takes in the RMD bytes with prepended value schema ID and a RmdWithValueSchemaId container object.
org.apache.avro.Schema	getRmdSchema(int valueSchemaId)
ByteBuffer	serializeRmdRecord(int valueSchemaId, org.apache.avro.generic.GenericRecord rmdRecord)

Methods inherited from class java.lang.Object

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

Constructor Details

RmdSerDe

public RmdSerDe(StringAnnotatedStoreSchemaCache annotatedStoreSchemaCache,
 int rmdVersionId)

RmdSerDe

public RmdSerDe(StringAnnotatedStoreSchemaCache annotatedStoreSchemaCache,
 int rmdVersionId,
 boolean fastAvroEnabled)

Method Details

deserializeValueSchemaIdPrependedRmdBytes

public void deserializeValueSchemaIdPrependedRmdBytes(byte[] valueSchemaIdPrependedBytes,
 RmdWithValueSchemaId rmdWithValueSchemaId)

This method takes in the RMD bytes with prepended value schema ID and a RmdWithValueSchemaId container object. It will deserialize the RMD bytes into RMD record and fill the passed-in container.

deserializeRmdBytes

public org.apache.avro.generic.GenericRecord deserializeRmdBytes(int writerSchemaID,
 int readerSchemaID,
 ByteBuffer rmdBytes)

Given a value schema ID and RMD bytes , find the RMD schema that corresponds to the given value schema ID and use that RMD schema to deserialize RMD bytes in a RMD record.

serializeRmdRecord

public ByteBuffer serializeRmdRecord(int valueSchemaId,
 org.apache.avro.generic.GenericRecord rmdRecord)

getRmdSchema

public org.apache.avro.Schema getRmdSchema(int valueSchemaId)