Package com.linkedin.venice.kafka.protocol.state

Class GlobalRtDivState

java.lang.Object
org.apache.avro.specific.SpecificRecordBase
com.linkedin.venice.kafka.protocol.state.GlobalRtDivState
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 GlobalRtDivState extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord
Global Realtime Topic Data Integrity Validator is the RT DIV snapshot propagated from the leader to the followers via local VT
See Also:

  • Field Details

    • SCHEMA$

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

    • srcUrl

      public CharSequence srcUrl
      Upstream broker bootstrap server url.

    • producerStates

      public Map<CharSequence,ProducerPartitionState> producerStates

    • latestOffset

      public long latestOffset
      The last Kafka offset consumed successfully in this partition.

    • latestPubSubPosition

      public ByteBuffer latestPubSubPosition
      The last PubSubPosition consumed successfully in this partition. Will be used once offset is deprecated.

  • Constructor Details

    • GlobalRtDivState

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

    • GlobalRtDivState

      public GlobalRtDivState(CharSequence srcUrl, Map<CharSequence,ProducerPartitionState> producerStates, Long latestOffset, ByteBuffer latestPubSubPosition)
      All-args constructor.
      Parameters:
      srcUrl - Upstream broker bootstrap server url.
      producerStates - The new value for producerStates
      latestOffset - The last Kafka offset consumed successfully in this partition.
      latestPubSubPosition - The last PubSubPosition consumed successfully in this partition. Will be used once offset is deprecated.

  • 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

    • getSrcUrl

      public CharSequence getSrcUrl()
      Gets the value of the 'srcUrl' field.
      Returns:
      Upstream broker bootstrap server url.

    • setSrcUrl

      public void setSrcUrl(CharSequence value)
      Sets the value of the 'srcUrl' field. Upstream broker bootstrap server url.
      Parameters:
      value - the value to set.

    • getProducerStates

      public Map<CharSequence,ProducerPartitionState> getProducerStates()
      Gets the value of the 'producerStates' field.
      Returns:
      The value of the 'producerStates' field.

    • setProducerStates

      public void setProducerStates(Map<CharSequence,ProducerPartitionState> value)
      Sets the value of the 'producerStates' field.
      Parameters:
      value - the value to set.

    • getLatestOffset

      public long getLatestOffset()
      Gets the value of the 'latestOffset' field.
      Returns:
      The last Kafka offset consumed successfully in this partition.

    • setLatestOffset

      public void setLatestOffset(long value)
      Sets the value of the 'latestOffset' field. The last Kafka offset consumed successfully in this partition.
      Parameters:
      value - the value to set.

    • getLatestPubSubPosition

      public ByteBuffer getLatestPubSubPosition()
      Gets the value of the 'latestPubSubPosition' field.
      Returns:
      The last PubSubPosition consumed successfully in this partition. Will be used once offset is deprecated.

    • setLatestPubSubPosition

      public void setLatestPubSubPosition(ByteBuffer value)
      Sets the value of the 'latestPubSubPosition' field. The last PubSubPosition consumed successfully in this partition. Will be used once offset is deprecated.
      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