Package com.linkedin.venice.kafka.protocol

Class Update

  • 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 Update
extends org.apache.avro.specific.SpecificRecordBase
implements org.apache.avro.specific.SpecificRecord
    Partial update operation, which merges the update value with the existing value.
    See Also:
    Serialized Form

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static org.apache.avro.Schema SCHEMA$  
      int schemaId
      The original schema ID.
      int updateSchemaId
      The derived schema ID that will be used to deserialize updateValue.
      java.nio.ByteBuffer updateValue
      New value(s) for parts of the record that need to be updated.

    • Constructor Summary

      Constructors 
      Constructor Description
      Update()
      Default constructor.
      Update​(java.lang.Integer schemaId, java.lang.Integer updateSchemaId, java.nio.ByteBuffer updateValue)
      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()  
      org.apache.avro.Schema getSchema()  
      int getSchemaId()
      Gets the value of the 'schemaId' field.
      org.apache.avro.specific.SpecificData getSpecificData()  
      int getUpdateSchemaId()
      Gets the value of the 'updateSchemaId' field.
      java.nio.ByteBuffer getUpdateValue()
      Gets the value of the 'updateValue' field.
      void put​(int field$, java.lang.Object value$)  
      void readExternal​(java.io.ObjectInput in)  
      void setSchemaId​(int value)
      Sets the value of the 'schemaId' field.
      void setUpdateSchemaId​(int value)
      Sets the value of the 'updateSchemaId' field.
      void setUpdateValue​(java.nio.ByteBuffer value)
      Sets the value of the 'updateValue' 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$

      • schemaId

        public int schemaId
        The original schema ID.

      • updateSchemaId

        public int updateSchemaId
        The derived schema ID that will be used to deserialize updateValue.

      • updateValue

        public java.nio.ByteBuffer updateValue
        New value(s) for parts of the record that need to be updated.

    • Constructor Detail

      • Update

        public Update()
        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().

      • Update

        public Update​(java.lang.Integer schemaId,
              java.lang.Integer updateSchemaId,
              java.nio.ByteBuffer updateValue)
        All-args constructor.
        Parameters:
        schemaId - The original schema ID.
        updateSchemaId - The derived schema ID that will be used to deserialize updateValue.
        updateValue - New value(s) for parts of the record that need to be updated.

    • 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

      • getSchemaId

        public int getSchemaId()
        Gets the value of the 'schemaId' field.
        Returns:
        The original schema ID.

      • setSchemaId

        public void setSchemaId​(int value)
        Sets the value of the 'schemaId' field. The original schema ID.
        Parameters:
        value - the value to set.

      • getUpdateSchemaId

        public int getUpdateSchemaId()
        Gets the value of the 'updateSchemaId' field.
        Returns:
        The derived schema ID that will be used to deserialize updateValue.

      • setUpdateSchemaId

        public void setUpdateSchemaId​(int value)
        Sets the value of the 'updateSchemaId' field. The derived schema ID that will be used to deserialize updateValue.
        Parameters:
        value - the value to set.

      • getUpdateValue

        public java.nio.ByteBuffer getUpdateValue()
        Gets the value of the 'updateValue' field.
        Returns:
        New value(s) for parts of the record that need to be updated.

      • setUpdateValue

        public void setUpdateValue​(java.nio.ByteBuffer value)
        Sets the value of the 'updateValue' field. New value(s) for parts of the record that need to be updated.
        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