Package com.linkedin.venice.client.change.capture.protocol

Class RecordChangeEvent

  • 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 RecordChangeEvent
extends org.apache.avro.specific.SpecificRecordBase
implements org.apache.avro.specific.SpecificRecord
    Schema which describes a record change event in a Venice store.
    See Also:
    Serialized Form

    • Constructor Summary

      Constructors 
      Constructor Description
      RecordChangeEvent()
      Default constructor.
      RecordChangeEvent​(ValueBytes previousValue, ValueBytes currentValue, java.nio.ByteBuffer key, java.util.List<java.lang.Long> replicationCheckpointVector)
      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()  
      ValueBytes getCurrentValue()
      Gets the value of the 'currentValue' field.
      java.nio.ByteBuffer getKey()
      Gets the value of the 'key' field.
      ValueBytes getPreviousValue()
      Gets the value of the 'previousValue' field.
      java.util.List<java.lang.Long> getReplicationCheckpointVector()
      Gets the value of the 'replicationCheckpointVector' field.
      org.apache.avro.Schema getSchema()  
      org.apache.avro.specific.SpecificData getSpecificData()  
      void put​(int field$, java.lang.Object value$)  
      void readExternal​(java.io.ObjectInput in)  
      void setCurrentValue​(ValueBytes value)
      Sets the value of the 'currentValue' field.
      void setKey​(java.nio.ByteBuffer value)
      Sets the value of the 'key' field.
      void setPreviousValue​(ValueBytes value)
      Sets the value of the 'previousValue' field.
      void setReplicationCheckpointVector​(java.util.List<java.lang.Long> value)
      Sets the value of the 'replicationCheckpointVector' 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$

      • currentValue

        public ValueBytes currentValue
        The current value of this record as of this change event. Can be null to signify a delete.

      • key

        public java.nio.ByteBuffer key
        The key which corresponds to this record which was just updated.

      • replicationCheckpointVector

        public java.util.List<java.lang.Long> replicationCheckpointVector
        The array which represents where

    • Constructor Detail

      • RecordChangeEvent

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

      • RecordChangeEvent

        public RecordChangeEvent​(ValueBytes previousValue,
                         ValueBytes currentValue,
                         java.nio.ByteBuffer key,
                         java.util.List<java.lang.Long> replicationCheckpointVector)
        All-args constructor.
        Parameters:
        previousValue - The new value for previousValue
        currentValue - The current value of this record as of this change event. Can be null to signify a delete.
        key - The key which corresponds to this record which was just updated.
        replicationCheckpointVector - The array which represents where

    • 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

      • getPreviousValue

        public ValueBytes getPreviousValue()
        Gets the value of the 'previousValue' field.
        Returns:
        The value of the 'previousValue' field.

      • setPreviousValue

        public void setPreviousValue​(ValueBytes value)
        Sets the value of the 'previousValue' field.
        Parameters:
        value - the value to set.

      • getCurrentValue

        public ValueBytes getCurrentValue()
        Gets the value of the 'currentValue' field.
        Returns:
        The current value of this record as of this change event. Can be null to signify a delete.

      • setCurrentValue

        public void setCurrentValue​(ValueBytes value)
        Sets the value of the 'currentValue' field. The current value of this record as of this change event. Can be null to signify a delete.
        Parameters:
        value - the value to set.

      • getKey

        public java.nio.ByteBuffer getKey()
        Gets the value of the 'key' field.
        Returns:
        The key which corresponds to this record which was just updated.

      • setKey

        public void setKey​(java.nio.ByteBuffer value)
        Sets the value of the 'key' field. The key which corresponds to this record which was just updated.
        Parameters:
        value - the value to set.

      • getReplicationCheckpointVector

        public java.util.List<java.lang.Long> getReplicationCheckpointVector()
        Gets the value of the 'replicationCheckpointVector' field.
        Returns:
        The array which represents where

      • setReplicationCheckpointVector

        public void setReplicationCheckpointVector​(java.util.List<java.lang.Long> value)
        Sets the value of the 'replicationCheckpointVector' field. The array which represents where
        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