Package com.linkedin.davinci.utils

Class ClientRmdSerDe

java.lang.Object

com.linkedin.davinci.utils.ClientRmdSerDe

public class ClientRmdSerDe
extends Object

Similar to RmdSerDe except it's intended to be used as a utility on client side to serialize/deserialize RMD record. The main difference is that it doesn't need to handle RMD protocol evolution and uses the only and latest RMD protocol RmdSchemaGeneratorV1 to generate the corresponding RMD schema used for serialization and deserialization. In the future we can support RMD protocol evolution by extending StoreSchemaFetcher to fetch the RMD protocol since we don't want clients to use the controller client as part of a utility for fetching the RMD protocol.

Constructor Summary

Constructors

Constructor	Description
ClientRmdSerDe(StoreSchemaFetcher schemaFetcher)
ClientRmdSerDe(StoreSchemaFetcher schemaFetcher, boolean fastAvroEnabled)

Method Summary

Modifier and Type	Method	Description
org.apache.avro.generic.GenericRecord	deserializeRmdBytes(int writerSchemaId, int readerSchemaId, ByteBuffer rmdBytes)
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

ClientRmdSerDe

public ClientRmdSerDe(StoreSchemaFetcher schemaFetcher)

ClientRmdSerDe

public ClientRmdSerDe(StoreSchemaFetcher schemaFetcher,
 boolean fastAvroEnabled)

Method Details

getRmdSchema

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

deserializeRmdBytes

public org.apache.avro.generic.GenericRecord deserializeRmdBytes(int writerSchemaId,
 int readerSchemaId,
 ByteBuffer rmdBytes)

serializeRmdRecord

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