Package com.linkedin.venice.writer

Class ProducerBufferRecord

java.lang.Object

com.linkedin.venice.writer.ProducerBufferRecord

All Implemented Interfaces:

Measurable

public class ProducerBufferRecord
extends Object
implements Measurable

Constructor Summary

Constructors

Constructor	Description
ProducerBufferRecord(MessageType messageType, byte[] serializedKey, byte[] serializedValue, byte[] serializedUpdate, int schemaId, int protocolId, PubSubProducerCallback callback, long timestamp)

Method Summary

Modifier and Type	Method	Description
void	addDependentCallback(PubSubProducerCallback callback)
void	addRecordToDependentRecordList(ProducerBufferRecord record)
PubSubProducerCallback	getCallback()
List<PubSubProducerCallback>	getDependentCallbackList()
List<ProducerBufferRecord>	getDependentRecordList()
int	getHeapSize()
MessageType	getMessageType()
CompletableFuture<PubSubProduceResult>	getProduceResultFuture()
int	getProtocolId()
int	getSchemaId()
byte[]	getSerializedKey()
byte[]	getSerializedUpdate()
byte[]	getSerializedValue()
long	getTimestamp()
void	setProduceResultFuture(CompletableFuture<PubSubProduceResult> produceResultFuture)
void	setSkipProduce(boolean shouldSkipProduce)
boolean	shouldSkipProduce()
void	updateSerializedUpdate(byte[] serializedUpdate)	This method convert message into a PUT message type.

Methods inherited from class java.lang.Object

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

Constructor Details

ProducerBufferRecord

public ProducerBufferRecord(MessageType messageType,
 byte[] serializedKey,
 byte[] serializedValue,
 byte[] serializedUpdate,
 int schemaId,
 int protocolId,
 PubSubProducerCallback callback,
 long timestamp)

Method Details

shouldSkipProduce

public boolean shouldSkipProduce()

setSkipProduce

public void setSkipProduce(boolean shouldSkipProduce)

getSerializedKey

public byte[] getSerializedKey()

getSerializedValue

public byte[] getSerializedValue()

getSerializedUpdate

public byte[] getSerializedUpdate()

getSchemaId

public int getSchemaId()

getProtocolId

public int getProtocolId()

getTimestamp

public long getTimestamp()

getMessageType

public MessageType getMessageType()

getDependentCallbackList

public List<PubSubProducerCallback> getDependentCallbackList()

addDependentCallback

public void addDependentCallback(PubSubProducerCallback callback)

getCallback

public PubSubProducerCallback getCallback()

getProduceResultFuture

public CompletableFuture<PubSubProduceResult> getProduceResultFuture()

setProduceResultFuture

public void setProduceResultFuture(CompletableFuture<PubSubProduceResult> produceResultFuture)

addRecordToDependentRecordList

public void addRecordToDependentRecordList(ProducerBufferRecord record)

getDependentRecordList

public List<ProducerBufferRecord> getDependentRecordList()

updateSerializedUpdate

public void updateSerializedUpdate(byte[] serializedUpdate)

This method convert message into a PUT message type.

getHeapSize

public int getHeapSize()

Specified by:

getHeapSize in interface Measurable