Package com.linkedin.venice.etl

Class VeniceKafkaDecodedRecord

  • 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 VeniceKafkaDecodedRecord
extends org.apache.avro.specific.SpecificRecordBase
implements org.apache.avro.specific.SpecificRecord
    See Also:
    Serialized Form

    • Field Summary

      Fields 
      Modifier and Type Field Description
      java.lang.Long DELETED_TS
      If the current record is a PUT, this field will be null; if it's a DELETE, this field will be the offset of the record in Kafka
      java.nio.ByteBuffer key
      Raw bytes of the key
      java.util.Map<java.lang.CharSequence,​java.lang.CharSequence> metadata
      Metadata of the record; currently it contains the schemaId of the record
      long offset
      The offset of this record in Kafka
      static org.apache.avro.Schema SCHEMA$  
      java.nio.ByteBuffer value
      Raw bytes of the value

    • Constructor Summary

      Constructors 
      Constructor Description
      VeniceKafkaDecodedRecord()
      Default constructor.
      VeniceKafkaDecodedRecord​(java.nio.ByteBuffer key, java.nio.ByteBuffer value, java.lang.Long offset, java.lang.Long DELETED_TS, java.util.Map<java.lang.CharSequence,​java.lang.CharSequence> metadata)
      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.lang.Long getDELETEDTS()
      Gets the value of the 'DELETED_TS' field.
      java.nio.ByteBuffer getKey()
      Gets the value of the 'key' field.
      java.util.Map<java.lang.CharSequence,​java.lang.CharSequence> getMetadata()
      Gets the value of the 'metadata' field.
      long getOffset()
      Gets the value of the 'offset' field.
      org.apache.avro.Schema getSchema()  
      org.apache.avro.specific.SpecificData getSpecificData()  
      java.nio.ByteBuffer getValue()
      Gets the value of the 'value' field.
      void put​(int field$, java.lang.Object value$)  
      void readExternal​(java.io.ObjectInput in)  
      void setDELETEDTS​(java.lang.Long value)
      Sets the value of the 'DELETED_TS' field.
      void setKey​(java.nio.ByteBuffer value)
      Sets the value of the 'key' field.
      void setMetadata​(java.util.Map<java.lang.CharSequence,​java.lang.CharSequence> value)
      Sets the value of the 'metadata' field.
      void setOffset​(long value)
      Sets the value of the 'offset' field.
      void setValue​(java.nio.ByteBuffer value)
      Sets the value of the 'value' 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$

      • key

        public java.nio.ByteBuffer key
        Raw bytes of the key

      • value

        public java.nio.ByteBuffer value
        Raw bytes of the value

      • offset

        public long offset
        The offset of this record in Kafka

      • DELETED_TS

        public java.lang.Long DELETED_TS
        If the current record is a PUT, this field will be null; if it's a DELETE, this field will be the offset of the record in Kafka

      • metadata

        public java.util.Map<java.lang.CharSequence,​java.lang.CharSequence> metadata
        Metadata of the record; currently it contains the schemaId of the record

    • Constructor Detail

      • VeniceKafkaDecodedRecord

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

      • VeniceKafkaDecodedRecord

        public VeniceKafkaDecodedRecord​(java.nio.ByteBuffer key,
                                java.nio.ByteBuffer value,
                                java.lang.Long offset,
                                java.lang.Long DELETED_TS,
                                java.util.Map<java.lang.CharSequence,​java.lang.CharSequence> metadata)
        All-args constructor.
        Parameters:
        key - Raw bytes of the key
        value - Raw bytes of the value
        offset - The offset of this record in Kafka
        DELETED_TS - If the current record is a PUT, this field will be null; if it's a DELETE, this field will be the offset of the record in Kafka
        metadata - Metadata of the record; currently it contains the schemaId of the record

    • 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

      • getKey

        public java.nio.ByteBuffer getKey()
        Gets the value of the 'key' field.
        Returns:
        Raw bytes of the key

      • setKey

        public void setKey​(java.nio.ByteBuffer value)
        Sets the value of the 'key' field. Raw bytes of the key
        Parameters:
        value - the value to set.

      • getValue

        public java.nio.ByteBuffer getValue()
        Gets the value of the 'value' field.
        Returns:
        Raw bytes of the value

      • setValue

        public void setValue​(java.nio.ByteBuffer value)
        Sets the value of the 'value' field. Raw bytes of the value
        Parameters:
        value - the value to set.

      • getOffset

        public long getOffset()
        Gets the value of the 'offset' field.
        Returns:
        The offset of this record in Kafka

      • setOffset

        public void setOffset​(long value)
        Sets the value of the 'offset' field. The offset of this record in Kafka
        Parameters:
        value - the value to set.

      • getDELETEDTS

        public java.lang.Long getDELETEDTS()
        Gets the value of the 'DELETED_TS' field.
        Returns:
        If the current record is a PUT, this field will be null; if it's a DELETE, this field will be the offset of the record in Kafka

      • setDELETEDTS

        public void setDELETEDTS​(java.lang.Long value)
        Sets the value of the 'DELETED_TS' field. If the current record is a PUT, this field will be null; if it's a DELETE, this field will be the offset of the record in Kafka
        Parameters:
        value - the value to set.

      • getMetadata

        public java.util.Map<java.lang.CharSequence,​java.lang.CharSequence> getMetadata()
        Gets the value of the 'metadata' field.
        Returns:
        Metadata of the record; currently it contains the schemaId of the record

      • setMetadata

        public void setMetadata​(java.util.Map<java.lang.CharSequence,​java.lang.CharSequence> value)
        Sets the value of the 'metadata' field. Metadata of the record; currently it contains the schemaId of the record
        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