Package com.linkedin.venice.hadoop.input.kafka.avro

Class KafkaInputMapperKey

java.lang.Object
org.apache.avro.specific.SpecificRecordBase
com.linkedin.venice.hadoop.input.kafka.avro.KafkaInputMapperKey
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 KafkaInputMapperKey extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord
The protocol between Mapper and Reducer with KafkaInputFormat for key field
See Also:

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    ByteBuffer
    key
    The raw key bytes excluding any chunking suffix
    long
    offset
    The offset of the record in the original Kafka topic partition
    static final org.apache.avro.Schema
    SCHEMA$
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    KafkaInputMapperKey()
    Default constructor.
    KafkaInputMapperKey(ByteBuffer key, Long offset)
    All-args constructor.

  • Method Summary

    Modifier and Type
    Method
    Description
    Object
    get(int field$)
     
    static org.apache.avro.Schema
    getClassSchema()
     
    ByteBuffer
    getKey()
    Gets the value of the 'key' field.
    long
    getOffset()
    Gets the value of the 'offset' field.
    org.apache.avro.Schema
    getSchema()
     
    org.apache.avro.specific.SpecificData
    getSpecificData()
     
    void
    put(int field$, Object value$)
     
    void
    readExternal(ObjectInput in)
     
    void
    setKey(ByteBuffer value)
    Sets the value of the 'key' field.
    void
    setOffset(long value)
    Sets the value of the 'offset' field.
    void
    writeExternal(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 Details

    • SCHEMA$

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

    • key

      public ByteBuffer key
      The raw key bytes excluding any chunking suffix

    • offset

      public long offset
      The offset of the record in the original Kafka topic partition

  • Constructor Details

    • KafkaInputMapperKey

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

    • KafkaInputMapperKey

      public KafkaInputMapperKey(ByteBuffer key, Long offset)
      All-args constructor.
      Parameters:
      key - The raw key bytes excluding any chunking suffix
      offset - The offset of the record in the original Kafka topic partition

  • 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

    • getKey

      public ByteBuffer getKey()
      Gets the value of the 'key' field.
      Returns:
      The raw key bytes excluding any chunking suffix

    • setKey

      public void setKey(ByteBuffer value)
      Sets the value of the 'key' field. The raw key bytes excluding any chunking suffix
      Parameters:
      value - the value to set.

    • getOffset

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

    • setOffset

      public void setOffset(long value)
      Sets the value of the 'offset' field. The offset of the record in the original Kafka topic partition
      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