Package com.linkedin.venice.pubsub.api

Class PubSubPositionWireFormat

java.lang.Object
org.apache.avro.specific.SpecificRecordBase
com.linkedin.venice.pubsub.api.PubSubPositionWireFormat
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 PubSubPositionWireFormat extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord
See Also:

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    ByteBuffer
    rawBytes
    serialized bytes of the position systems
    static final org.apache.avro.Schema
    SCHEMA$
     
    int
    type
    type of the position; 0 is reserved for Kafka offset (long), positive values are intended to be used for open-source pub-sub systems, and negative values are reserved for internal/proprietary pub-sub systems

  • Constructor Summary

    Constructors
    Constructor
    Description
    PubSubPositionWireFormat()
    Default constructor.
    PubSubPositionWireFormat(Integer type, ByteBuffer rawBytes)
    All-args constructor.

  • Method Summary

    Modifier and Type
    Method
    Description
    Object
    get(int field$)
     
    static org.apache.avro.Schema
    getClassSchema()
     
    ByteBuffer
    getRawBytes()
    Gets the value of the 'rawBytes' field.
    org.apache.avro.Schema
    getSchema()
     
    org.apache.avro.specific.SpecificData
    getSpecificData()
     
    int
    getType()
    Gets the value of the 'type' field.
    void
    put(int field$, Object value$)
     
    void
    readExternal(ObjectInput in)
     
    void
    setRawBytes(ByteBuffer value)
    Sets the value of the 'rawBytes' field.
    void
    setType(int value)
    Sets the value of the 'type' 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$

    • type

      public int type
      type of the position; 0 is reserved for Kafka offset (long), positive values are intended to be used for open-source pub-sub systems, and negative values are reserved for internal/proprietary pub-sub systems

    • rawBytes

      public ByteBuffer rawBytes
      serialized bytes of the position systems

  • Constructor Details

    • PubSubPositionWireFormat

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

    • PubSubPositionWireFormat

      public PubSubPositionWireFormat(Integer type, ByteBuffer rawBytes)
      All-args constructor.
      Parameters:
      type - type of the position; 0 is reserved for Kafka offset (long), positive values are intended to be used for open-source pub-sub systems, and negative values are reserved for internal/proprietary pub-sub systems
      rawBytes - serialized bytes of the position systems

  • 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

    • getType

      public int getType()
      Gets the value of the 'type' field.
      Returns:
      type of the position; 0 is reserved for Kafka offset (long), positive values are intended to be used for open-source pub-sub systems, and negative values are reserved for internal/proprietary pub-sub systems

    • setType

      public void setType(int value)
      Sets the value of the 'type' field. type of the position; 0 is reserved for Kafka offset (long), positive values are intended to be used for open-source pub-sub systems, and negative values are reserved for internal/proprietary pub-sub systems
      Parameters:
      value - the value to set.

    • getRawBytes

      public ByteBuffer getRawBytes()
      Gets the value of the 'rawBytes' field.
      Returns:
      serialized bytes of the position systems

    • setRawBytes

      public void setRawBytes(ByteBuffer value)
      Sets the value of the 'rawBytes' field. serialized bytes of the position systems
      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