Package com.linkedin.venice.samza

Class SerializedRecord

java.lang.Object

com.linkedin.venice.samza.SerializedRecord

public class SerializedRecord
extends Object

A value object holding the Avro-serialized key and value bytes along with the resolved schema IDs and logical timestamp needed to write a record to Venice. Obtain an instance via VeniceSystemProducer.prepareRecord(Object, Object). This class does not defensively copy byte arrays for performance. Callers must treat the provided key/value byte arrays as immutable for the lifetime of the async send operation.

Constructor Summary

Constructors

Constructor	Description
SerializedRecord(byte[] serializedKey, byte[] serializedValue, int valueSchemaId, int derivedSchemaId, long logicalTimestamp)

Method Summary

Modifier and Type	Method	Description
int	getDerivedSchemaId()
long	getLogicalTimestamp()
byte[]	getSerializedKey()
byte[]	getSerializedValue()	Returns the serialized value bytes, or null if this record represents a delete.
int	getValueSchemaId()

Methods inherited from class java.lang.Object

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

Constructor Details

SerializedRecord

public SerializedRecord(byte[] serializedKey,
 byte[] serializedValue,
 int valueSchemaId,
 int derivedSchemaId,
 long logicalTimestamp)

Method Details

getSerializedKey

public byte[] getSerializedKey()

getSerializedValue

public byte[] getSerializedValue()

Returns the serialized value bytes, or null if this record represents a delete.

getValueSchemaId

public int getValueSchemaId()

getDerivedSchemaId

public int getDerivedSchemaId()

getLogicalTimestamp

public long getLogicalTimestamp()