Package com.linkedin.venice.kafka.protocol

Class Put

  • All Implemented Interfaces:
    java.io.Externalizable, java.io.Serializable, java.lang.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:
    Serialized Form

    • Field Summary

      Fields 
      Modifier and Type Field Description
      java.nio.ByteBuffer putValue
      The record's value to be persisted in the storage engine.
      java.nio.ByteBuffer replicationMetadataPayload
      The serialized value of the replication metadata schema.
      int replicationMetadataVersionId
      The A/A replication metadata schema version ID that will be used to deserialize replicationMetadataPayload.
      static org.apache.avro.Schema SCHEMA$  
      int schemaId
      An identifier used to determine how the PutValue can be deserialized.

    • Constructor Summary

      Constructors 
      Constructor Description
      Put()
      Default constructor.
      Put​(java.nio.ByteBuffer putValue, java.lang.Integer schemaId, java.lang.Integer replicationMetadataVersionId, java.nio.ByteBuffer replicationMetadataPayload)
      All-args constructor.

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.lang.Object get​(int field$)  
      static org.apache.avro.Schema getClassSchema()  
      java.nio.ByteBuffer getPutValue()
      Gets the value of the 'putValue' field.
      java.nio.ByteBuffer getReplicationMetadataPayload()
      Gets the value of the 'replicationMetadataPayload' field.
      int getReplicationMetadataVersionId()
      Gets the value of the 'replicationMetadataVersionId' field.
      org.apache.avro.Schema getSchema()  
      int getSchemaId()
      Gets the value of the 'schemaId' field.
      org.apache.avro.specific.SpecificData getSpecificData()  
      void put​(int field$, java.lang.Object value$)  
      void readExternal​(java.io.ObjectInput in)  
      void setPutValue​(java.nio.ByteBuffer value)
      Sets the value of the 'putValue' field.
      void setReplicationMetadataPayload​(java.nio.ByteBuffer value)
      Sets the value of the 'replicationMetadataPayload' field.
      void setReplicationMetadataVersionId​(int value)
      Sets the value of the 'replicationMetadataVersionId' field.
      void setSchemaId​(int value)
      Sets the value of the 'schemaId' field.
      void writeExternal​(java.io.ObjectOutput out)  

      • Methods inherited from class org.apache.avro.specific.SpecificRecordBase

        compareTo, customDecode, customEncode, equals, get, getConversion, getConversion, hasCustomCoders, hashCode, put, toString

      • Methods inherited from class java.lang.Object

        clone, finalize, getClass, notify, notifyAll, wait, wait, wait

      • Methods inherited from interface org.apache.avro.generic.GenericRecord

        hasField

    • Field Detail

      • SCHEMA$

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

      • putValue

        public java.nio.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 java.nio.ByteBuffer replicationMetadataPayload
        The serialized value of the replication metadata schema.

    • Constructor Detail

      • 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​(java.nio.ByteBuffer putValue,
           java.lang.Integer schemaId,
           java.lang.Integer replicationMetadataVersionId,
           java.nio.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 Detail

      • 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 java.lang.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$,
                java.lang.Object value$)
        Specified by:
        put in interface org.apache.avro.generic.IndexedRecord
        Specified by:
        put in class org.apache.avro.specific.SpecificRecordBase

      • getPutValue

        public java.nio.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​(java.nio.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 java.nio.ByteBuffer getReplicationMetadataPayload()
        Gets the value of the 'replicationMetadataPayload' field.
        Returns:
        The serialized value of the replication metadata schema.

      • setReplicationMetadataPayload

        public void setReplicationMetadataPayload​(java.nio.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​(java.io.ObjectOutput out)
                   throws java.io.IOException
        Specified by:
        writeExternal in interface java.io.Externalizable
        Overrides:
        writeExternal in class org.apache.avro.specific.SpecificRecordBase
        Throws:
        java.io.IOException

      • readExternal

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