Package com.linkedin.venice.kafka.protocol

Class Put

java.lang.Object
org.apache.avro.specific.SpecificRecordBase
com.linkedin.venice.kafka.protocol.Put
All Implemented Interfaces:
Externalizable, Serializable, Comparable<org.apache.avro.specific.SpecificRecord>, org.apache.avro.generic.GenericContainer, org.apache.avro.generic.GenericRecord, org.apache.avro.generic.IndexedRecord, org.apache.avro.specific.SpecificRecord
public class Put extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord
Put payloads contain a record value, and information on how to deserialize it.
See Also:

  • Field Details

    • SCHEMA$

      public static final org.apache.avro.Schema SCHEMA$

    • putValue

      public ByteBuffer putValue
      The record's value to be persisted in the storage engine.

    • schemaId

      public int schemaId
      An identifier used to determine how the PutValue can be deserialized. Also used, in conjunction with the replicationMetadataVersionId, to deserialize the replicationMetadataPayload.

    • replicationMetadataVersionId

      public int replicationMetadataVersionId
      The A/A replication metadata schema version ID that will be used to deserialize replicationMetadataPayload.

    • replicationMetadataPayload

      public ByteBuffer replicationMetadataPayload
      The serialized value of the replication metadata schema.

  • Constructor Details

    • Put

      public Put()
      Default constructor. Note that this does not initialize fields to their default values from the schema. If that is desired then one should use newBuilder().

    • Put

      public Put(ByteBuffer putValue, Integer schemaId, Integer replicationMetadataVersionId, ByteBuffer replicationMetadataPayload)
      All-args constructor.
      Parameters:
      putValue - The record's value to be persisted in the storage engine.
      schemaId - An identifier used to determine how the PutValue can be deserialized. Also used, in conjunction with the replicationMetadataVersionId, to deserialize the replicationMetadataPayload.
      replicationMetadataVersionId - The A/A replication metadata schema version ID that will be used to deserialize replicationMetadataPayload.
      replicationMetadataPayload - The serialized value of the replication metadata schema.

  • Method Details

    • getClassSchema

      public static org.apache.avro.Schema getClassSchema()

    • getSpecificData

      public org.apache.avro.specific.SpecificData getSpecificData()
      Overrides:
      getSpecificData in class org.apache.avro.specific.SpecificRecordBase

    • getSchema

      public org.apache.avro.Schema getSchema()
      Specified by:
      getSchema in interface org.apache.avro.generic.GenericContainer
      Specified by:
      getSchema in class org.apache.avro.specific.SpecificRecordBase

    • get

      public Object get(int field$)
      Specified by:
      get in interface org.apache.avro.generic.IndexedRecord
      Specified by:
      get in class org.apache.avro.specific.SpecificRecordBase

    • put

      public void put(int field$, Object value$)
      Specified by:
      put in interface org.apache.avro.generic.IndexedRecord
      Specified by:
      put in class org.apache.avro.specific.SpecificRecordBase

    • getPutValue

      public ByteBuffer getPutValue()
      Gets the value of the 'putValue' field.
      Returns:
      The record's value to be persisted in the storage engine.

    • setPutValue

      public void setPutValue(ByteBuffer value)
      Sets the value of the 'putValue' field. The record's value to be persisted in the storage engine.
      Parameters:
      value - the value to set.

    • getSchemaId

      public int getSchemaId()
      Gets the value of the 'schemaId' field.
      Returns:
      An identifier used to determine how the PutValue can be deserialized. Also used, in conjunction with the replicationMetadataVersionId, to deserialize the replicationMetadataPayload.

    • setSchemaId

      public void setSchemaId(int value)
      Sets the value of the 'schemaId' field. An identifier used to determine how the PutValue can be deserialized. Also used, in conjunction with the replicationMetadataVersionId, to deserialize the replicationMetadataPayload.
      Parameters:
      value - the value to set.

    • getReplicationMetadataVersionId

      public int getReplicationMetadataVersionId()
      Gets the value of the 'replicationMetadataVersionId' field.
      Returns:
      The A/A replication metadata schema version ID that will be used to deserialize replicationMetadataPayload.

    • setReplicationMetadataVersionId

      public void setReplicationMetadataVersionId(int value)
      Sets the value of the 'replicationMetadataVersionId' field. The A/A replication metadata schema version ID that will be used to deserialize replicationMetadataPayload.
      Parameters:
      value - the value to set.

    • getReplicationMetadataPayload

      public ByteBuffer getReplicationMetadataPayload()
      Gets the value of the 'replicationMetadataPayload' field.
      Returns:
      The serialized value of the replication metadata schema.

    • setReplicationMetadataPayload

      public void setReplicationMetadataPayload(ByteBuffer value)
      Sets the value of the 'replicationMetadataPayload' field. The serialized value of the replication metadata schema.
      Parameters:
      value - the value to set.

    • writeExternal

      public void writeExternal(ObjectOutput out) throws IOException
      Specified by:
      writeExternal in interface Externalizable
      Overrides:
      writeExternal in class org.apache.avro.specific.SpecificRecordBase
      Throws:
      IOException

    • readExternal

      public void readExternal(ObjectInput in) throws IOException
      Specified by:
      readExternal in interface Externalizable
      Overrides:
      readExternal in class org.apache.avro.specific.SpecificRecordBase
      Throws:
      IOException