Package com.linkedin.venice.writer

Class ProducerBufferRecord<V,U>

java.lang.Object
com.linkedin.venice.writer.ProducerBufferRecord<V,U>
All Implemented Interfaces:
Measurable
public class ProducerBufferRecord<V,U> extends Object implements Measurable

  • Constructor Details

    • ProducerBufferRecord

      public ProducerBufferRecord(MessageType messageType, byte[] serializedKey, V value, U update, int schemaId, int protocolId, PubSubProducerCallback callback, long logicalTimestamp)

  • Method Details

    • shouldSkipProduce

      public boolean shouldSkipProduce()

    • setSkipProduce

      public void setSkipProduce(boolean shouldSkipProduce)

    • getSerializedKey

      public byte[] getSerializedKey()

    • getValue

      public V getValue()

    • getUpdate

      public U getUpdate()

    • getSchemaId

      public int getSchemaId()

    • getProtocolId

      public int getProtocolId()

    • getLogicalTimestamp

      public long getLogicalTimestamp()

    • 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)

    • getHeapSize

      public int getHeapSize()
      Specified by:
      getHeapSize in interface Measurable