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

Class PartitionState

java.lang.Object
org.apache.avro.specific.SpecificRecordBase
com.linkedin.venice.kafka.protocol.state.PartitionState
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 PartitionState extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord
This record holds the state necessary for a consumer to checkpoint its progress when consuming a Venice partition. When provided the state in this record, a consumer should thus be able to resume consuming midway through a stream.
See Also:

  • Field Details

    • SCHEMA$

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

    • offset

      public long offset
      The last Kafka offset processed successfully in this partition from version topic.

    • offsetLag

      public long offsetLag
      The last Kafka offset lag in this partition for fast online transition in server restart.

    • endOfPush

      public boolean endOfPush
      Whether the EndOfPush control message was consumed in this partition.

    • lastUpdate

      public long lastUpdate
      The last time this PartitionState was updated. Can be compared against the various messageTimestamp in ProducerPartitionState in order to infer lag time between producers and the consumer maintaining this PartitionState.

    • startOfBufferReplayDestinationOffset

      public Long startOfBufferReplayDestinationOffset
      This is the offset at which the StartOfBufferReplay control message was consumed in the current partition of the destination topic. This is not the same value as the source offsets contained in the StartOfBufferReplay control message itself. The source and destination offsets act together as a synchronization marker. N.B.: null means that the SOBR control message was not received yet.

    • databaseInfo

      public Map<CharSequence,CharSequence> databaseInfo
      A map of string -> string to store database related info, which is necessary to checkpoint

    • incrementalPushInfo

      public IncrementalPush incrementalPushInfo
      metadata of ongoing incremental push in the partition

    • leaderTopic

      public CharSequence leaderTopic
      The topic that leader is consuming from; for leader, leaderTopic can be different from the version topic; for follower, leaderTopic is the same as version topic.

    • leaderOffset

      public long leaderOffset
      The last Kafka offset consumed successfully in this partition from the leader topic. TODO: remove this field once upstreamOffsetMap is used everywhere.

    • upstreamOffsetMap

      public Map<String,Long> upstreamOffsetMap
      A map of upstream Kafka bootstrap server url -> the last Kafka offset consumed from upstream topic.

    • upstreamRealTimeTopicPubSubPositionMap

      public Map<String,ByteBuffer> upstreamRealTimeTopicPubSubPositionMap
      A map of upstream PubSub bootstrap server url -> the last PubSub position consumed from upstream topic.

    • upstreamVersionTopicOffset

      public long upstreamVersionTopicOffset
      The last upstream version topic offset persisted to disk; if the batch native-replication source is the same as local region, this value will always be -1

    • upstreamVersionTopicPubSubPosition

      public ByteBuffer upstreamVersionTopicPubSubPosition
      The last upstream version topic PubSub position persisted to disk; if the batch native-replication source is the same as local region, this value will always be null

    • leaderGUID

      public GUID leaderGUID
      This field is deprecated since GUID is no longer able to identify the split-brain issue once 'pass-through' mode is enabled in venice writer. The field is superseded by leaderHostId and will be removed in the future

    • leaderHostId

      public CharSequence leaderHostId
      An unique identifier (such as host name) that stands for each host. It's used to identify if there is a split-brain happened while the leader(s) re-produce records

    • producerStates

      public Map<CharSequence,ProducerPartitionState> producerStates
      A map of producer GUID -> producer state.

    • previousStatuses

      public Map<CharSequence,CharSequence> previousStatuses
      A map of string -> string which stands for previous PartitionStatus

    • pendingReportIncrementalPushVersions

      public List<CharSequence> pendingReportIncrementalPushVersions
      A list of string which stands for incremental push versions which have received EOIP but not yet reported prior to lag caught up, they will be reported in batch

    • realtimeTopicProducerStates

      public Map<String,Map<CharSequence,ProducerPartitionState>> realtimeTopicProducerStates
      A map that maps upstream Kafka bootstrap server url -> to a map of producer GUID -> producer state for real-time data.

    • recordTransformerClassHash

      public Integer recordTransformerClassHash
      An integer hash code used by the DaVinciRecordTransformer to detect changes to the user's class during bootstrapping.

    • lastProcessedVersionTopicPubSubPosition

      public ByteBuffer lastProcessedVersionTopicPubSubPosition
      The last PubSub position processed successfully in this partition from version topic

    • lastConsumedVersionTopicPubSubPosition

      public ByteBuffer lastConsumedVersionTopicPubSubPosition
      The last PubSub position consumed successfully in this partition from the version topic. This is used during resubscription when the Global RT DIV feature is enabled.

    • latestObservedTermId

      public long latestObservedTermId
      The most recent termId observed by this replica.

    • currentTermStartPubSubPosition

      public ByteBuffer currentTermStartPubSubPosition
      The pubsub position marking the start of the current leader's term in the version topic.

    • lastConsumedVersionTopicOffset

      public long lastConsumedVersionTopicOffset
      The last offset consumed successfully in this partition from the version topic. This is used during resubscription when the Global RT DIV feature is enabled.

    • heartbeatTimestamp

      public long heartbeatTimestamp
      The most stale heartbeat timestamp among all the regions in this partition for fast online transition during server restart.

    • lastCheckpointTimestamp

      public long lastCheckpointTimestamp
      The most recent checkpoint timestamp for fast online transition during server restart.

    • keyUrnCompressionDict

      public KeyUrnCompressionDict keyUrnCompressionDict
      When key compression is enabled, this field keeps all the related information for key URN compression.

  • Constructor Details

    • PartitionState

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

    • PartitionState

      public PartitionState(Long offset, Long offsetLag, Boolean endOfPush, Long lastUpdate, Long startOfBufferReplayDestinationOffset, Map<CharSequence,CharSequence> databaseInfo, IncrementalPush incrementalPushInfo, CharSequence leaderTopic, Long leaderOffset, Map<String,Long> upstreamOffsetMap, Map<String,ByteBuffer> upstreamRealTimeTopicPubSubPositionMap, Long upstreamVersionTopicOffset, ByteBuffer upstreamVersionTopicPubSubPosition, GUID leaderGUID, CharSequence leaderHostId, Map<CharSequence,ProducerPartitionState> producerStates, Map<CharSequence,CharSequence> previousStatuses, List<CharSequence> pendingReportIncrementalPushVersions, Map<String,Map<CharSequence,ProducerPartitionState>> realtimeTopicProducerStates, Integer recordTransformerClassHash, ByteBuffer lastProcessedVersionTopicPubSubPosition, ByteBuffer lastConsumedVersionTopicPubSubPosition, Long latestObservedTermId, ByteBuffer currentTermStartPubSubPosition, Long lastConsumedVersionTopicOffset, Long heartbeatTimestamp, Long lastCheckpointTimestamp, KeyUrnCompressionDict keyUrnCompressionDict)
      All-args constructor.
      Parameters:
      offset - The last Kafka offset processed successfully in this partition from version topic.
      offsetLag - The last Kafka offset lag in this partition for fast online transition in server restart.
      endOfPush - Whether the EndOfPush control message was consumed in this partition.
      lastUpdate - The last time this PartitionState was updated. Can be compared against the various messageTimestamp in ProducerPartitionState in order to infer lag time between producers and the consumer maintaining this PartitionState.
      startOfBufferReplayDestinationOffset - This is the offset at which the StartOfBufferReplay control message was consumed in the current partition of the destination topic. This is not the same value as the source offsets contained in the StartOfBufferReplay control message itself. The source and destination offsets act together as a synchronization marker. N.B.: null means that the SOBR control message was not received yet.
      databaseInfo - A map of string -> string to store database related info, which is necessary to checkpoint
      incrementalPushInfo - metadata of ongoing incremental push in the partition
      leaderTopic - The topic that leader is consuming from; for leader, leaderTopic can be different from the version topic; for follower, leaderTopic is the same as version topic.
      leaderOffset - The last Kafka offset consumed successfully in this partition from the leader topic. TODO: remove this field once upstreamOffsetMap is used everywhere.
      upstreamOffsetMap - A map of upstream Kafka bootstrap server url -> the last Kafka offset consumed from upstream topic.
      upstreamRealTimeTopicPubSubPositionMap - A map of upstream PubSub bootstrap server url -> the last PubSub position consumed from upstream topic.
      upstreamVersionTopicOffset - The last upstream version topic offset persisted to disk; if the batch native-replication source is the same as local region, this value will always be -1
      upstreamVersionTopicPubSubPosition - The last upstream version topic PubSub position persisted to disk; if the batch native-replication source is the same as local region, this value will always be null
      leaderGUID - This field is deprecated since GUID is no longer able to identify the split-brain issue once 'pass-through' mode is enabled in venice writer. The field is superseded by leaderHostId and will be removed in the future
      leaderHostId - An unique identifier (such as host name) that stands for each host. It's used to identify if there is a split-brain happened while the leader(s) re-produce records
      producerStates - A map of producer GUID -> producer state.
      previousStatuses - A map of string -> string which stands for previous PartitionStatus
      pendingReportIncrementalPushVersions - A list of string which stands for incremental push versions which have received EOIP but not yet reported prior to lag caught up, they will be reported in batch
      realtimeTopicProducerStates - A map that maps upstream Kafka bootstrap server url -> to a map of producer GUID -> producer state for real-time data.
      recordTransformerClassHash - An integer hash code used by the DaVinciRecordTransformer to detect changes to the user's class during bootstrapping.
      lastProcessedVersionTopicPubSubPosition - The last PubSub position processed successfully in this partition from version topic
      lastConsumedVersionTopicPubSubPosition - The last PubSub position consumed successfully in this partition from the version topic. This is used during resubscription when the Global RT DIV feature is enabled.
      latestObservedTermId - The most recent termId observed by this replica.
      currentTermStartPubSubPosition - The pubsub position marking the start of the current leader's term in the version topic.
      lastConsumedVersionTopicOffset - The last offset consumed successfully in this partition from the version topic. This is used during resubscription when the Global RT DIV feature is enabled.
      heartbeatTimestamp - The most stale heartbeat timestamp among all the regions in this partition for fast online transition during server restart.
      lastCheckpointTimestamp - The most recent checkpoint timestamp for fast online transition during server restart.
      keyUrnCompressionDict - When key compression is enabled, this field keeps all the related information for key URN compression.

  • 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

    • getOffset

      public long getOffset()
      Gets the value of the 'offset' field.
      Returns:
      The last Kafka offset processed successfully in this partition from version topic.

    • setOffset

      public void setOffset(long value)
      Sets the value of the 'offset' field. The last Kafka offset processed successfully in this partition from version topic.
      Parameters:
      value - the value to set.

    • getOffsetLag

      public long getOffsetLag()
      Gets the value of the 'offsetLag' field.
      Returns:
      The last Kafka offset lag in this partition for fast online transition in server restart.

    • setOffsetLag

      public void setOffsetLag(long value)
      Sets the value of the 'offsetLag' field. The last Kafka offset lag in this partition for fast online transition in server restart.
      Parameters:
      value - the value to set.

    • getEndOfPush

      public boolean getEndOfPush()
      Gets the value of the 'endOfPush' field.
      Returns:
      Whether the EndOfPush control message was consumed in this partition.

    • setEndOfPush

      public void setEndOfPush(boolean value)
      Sets the value of the 'endOfPush' field. Whether the EndOfPush control message was consumed in this partition.
      Parameters:
      value - the value to set.

    • getLastUpdate

      public long getLastUpdate()
      Gets the value of the 'lastUpdate' field.
      Returns:
      The last time this PartitionState was updated. Can be compared against the various messageTimestamp in ProducerPartitionState in order to infer lag time between producers and the consumer maintaining this PartitionState.

    • setLastUpdate

      public void setLastUpdate(long value)
      Sets the value of the 'lastUpdate' field. The last time this PartitionState was updated. Can be compared against the various messageTimestamp in ProducerPartitionState in order to infer lag time between producers and the consumer maintaining this PartitionState.
      Parameters:
      value - the value to set.

    • getStartOfBufferReplayDestinationOffset

      public Long getStartOfBufferReplayDestinationOffset()
      Gets the value of the 'startOfBufferReplayDestinationOffset' field.
      Returns:
      This is the offset at which the StartOfBufferReplay control message was consumed in the current partition of the destination topic. This is not the same value as the source offsets contained in the StartOfBufferReplay control message itself. The source and destination offsets act together as a synchronization marker. N.B.: null means that the SOBR control message was not received yet.

    • setStartOfBufferReplayDestinationOffset

      public void setStartOfBufferReplayDestinationOffset(Long value)
      Sets the value of the 'startOfBufferReplayDestinationOffset' field. This is the offset at which the StartOfBufferReplay control message was consumed in the current partition of the destination topic. This is not the same value as the source offsets contained in the StartOfBufferReplay control message itself. The source and destination offsets act together as a synchronization marker. N.B.: null means that the SOBR control message was not received yet.
      Parameters:
      value - the value to set.

    • getDatabaseInfo

      public Map<CharSequence,CharSequence> getDatabaseInfo()
      Gets the value of the 'databaseInfo' field.
      Returns:
      A map of string -> string to store database related info, which is necessary to checkpoint

    • setDatabaseInfo

      public void setDatabaseInfo(Map<CharSequence,CharSequence> value)
      Sets the value of the 'databaseInfo' field. A map of string -> string to store database related info, which is necessary to checkpoint
      Parameters:
      value - the value to set.

    • getIncrementalPushInfo

      public IncrementalPush getIncrementalPushInfo()
      Gets the value of the 'incrementalPushInfo' field.
      Returns:
      metadata of ongoing incremental push in the partition

    • setIncrementalPushInfo

      public void setIncrementalPushInfo(IncrementalPush value)
      Sets the value of the 'incrementalPushInfo' field. metadata of ongoing incremental push in the partition
      Parameters:
      value - the value to set.

    • getLeaderTopic

      public CharSequence getLeaderTopic()
      Gets the value of the 'leaderTopic' field.
      Returns:
      The topic that leader is consuming from; for leader, leaderTopic can be different from the version topic; for follower, leaderTopic is the same as version topic.

    • setLeaderTopic

      public void setLeaderTopic(CharSequence value)
      Sets the value of the 'leaderTopic' field. The topic that leader is consuming from; for leader, leaderTopic can be different from the version topic; for follower, leaderTopic is the same as version topic.
      Parameters:
      value - the value to set.

    • getLeaderOffset

      public long getLeaderOffset()
      Gets the value of the 'leaderOffset' field.
      Returns:
      The last Kafka offset consumed successfully in this partition from the leader topic. TODO: remove this field once upstreamOffsetMap is used everywhere.

    • setLeaderOffset

      public void setLeaderOffset(long value)
      Sets the value of the 'leaderOffset' field. The last Kafka offset consumed successfully in this partition from the leader topic. TODO: remove this field once upstreamOffsetMap is used everywhere.
      Parameters:
      value - the value to set.

    • getUpstreamOffsetMap

      public Map<String,Long> getUpstreamOffsetMap()
      Gets the value of the 'upstreamOffsetMap' field.
      Returns:
      A map of upstream Kafka bootstrap server url -> the last Kafka offset consumed from upstream topic.

    • setUpstreamOffsetMap

      public void setUpstreamOffsetMap(Map<String,Long> value)
      Sets the value of the 'upstreamOffsetMap' field. A map of upstream Kafka bootstrap server url -> the last Kafka offset consumed from upstream topic.
      Parameters:
      value - the value to set.

    • getUpstreamRealTimeTopicPubSubPositionMap

      public Map<String,ByteBuffer> getUpstreamRealTimeTopicPubSubPositionMap()
      Gets the value of the 'upstreamRealTimeTopicPubSubPositionMap' field.
      Returns:
      A map of upstream PubSub bootstrap server url -> the last PubSub position consumed from upstream topic.

    • setUpstreamRealTimeTopicPubSubPositionMap

      public void setUpstreamRealTimeTopicPubSubPositionMap(Map<String,ByteBuffer> value)
      Sets the value of the 'upstreamRealTimeTopicPubSubPositionMap' field. A map of upstream PubSub bootstrap server url -> the last PubSub position consumed from upstream topic.
      Parameters:
      value - the value to set.

    • getUpstreamVersionTopicOffset

      public long getUpstreamVersionTopicOffset()
      Gets the value of the 'upstreamVersionTopicOffset' field.
      Returns:
      The last upstream version topic offset persisted to disk; if the batch native-replication source is the same as local region, this value will always be -1

    • setUpstreamVersionTopicOffset

      public void setUpstreamVersionTopicOffset(long value)
      Sets the value of the 'upstreamVersionTopicOffset' field. The last upstream version topic offset persisted to disk; if the batch native-replication source is the same as local region, this value will always be -1
      Parameters:
      value - the value to set.

    • getUpstreamVersionTopicPubSubPosition

      public ByteBuffer getUpstreamVersionTopicPubSubPosition()
      Gets the value of the 'upstreamVersionTopicPubSubPosition' field.
      Returns:
      The last upstream version topic PubSub position persisted to disk; if the batch native-replication source is the same as local region, this value will always be null

    • setUpstreamVersionTopicPubSubPosition

      public void setUpstreamVersionTopicPubSubPosition(ByteBuffer value)
      Sets the value of the 'upstreamVersionTopicPubSubPosition' field. The last upstream version topic PubSub position persisted to disk; if the batch native-replication source is the same as local region, this value will always be null
      Parameters:
      value - the value to set.

    • getLeaderGUID

      public GUID getLeaderGUID()
      Gets the value of the 'leaderGUID' field.
      Returns:
      This field is deprecated since GUID is no longer able to identify the split-brain issue once 'pass-through' mode is enabled in venice writer. The field is superseded by leaderHostId and will be removed in the future

    • setLeaderGUID

      public void setLeaderGUID(GUID value)
      Sets the value of the 'leaderGUID' field. This field is deprecated since GUID is no longer able to identify the split-brain issue once 'pass-through' mode is enabled in venice writer. The field is superseded by leaderHostId and will be removed in the future
      Parameters:
      value - the value to set.

    • getLeaderHostId

      public CharSequence getLeaderHostId()
      Gets the value of the 'leaderHostId' field.
      Returns:
      An unique identifier (such as host name) that stands for each host. It's used to identify if there is a split-brain happened while the leader(s) re-produce records

    • setLeaderHostId

      public void setLeaderHostId(CharSequence value)
      Sets the value of the 'leaderHostId' field. An unique identifier (such as host name) that stands for each host. It's used to identify if there is a split-brain happened while the leader(s) re-produce records
      Parameters:
      value - the value to set.

    • getProducerStates

      public Map<CharSequence,ProducerPartitionState> getProducerStates()
      Gets the value of the 'producerStates' field.
      Returns:
      A map of producer GUID -> producer state.

    • setProducerStates

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

    • getPreviousStatuses

      public Map<CharSequence,CharSequence> getPreviousStatuses()
      Gets the value of the 'previousStatuses' field.
      Returns:
      A map of string -> string which stands for previous PartitionStatus

    • setPreviousStatuses

      public void setPreviousStatuses(Map<CharSequence,CharSequence> value)
      Sets the value of the 'previousStatuses' field. A map of string -> string which stands for previous PartitionStatus
      Parameters:
      value - the value to set.

    • getPendingReportIncrementalPushVersions

      public List<CharSequence> getPendingReportIncrementalPushVersions()
      Gets the value of the 'pendingReportIncrementalPushVersions' field.
      Returns:
      A list of string which stands for incremental push versions which have received EOIP but not yet reported prior to lag caught up, they will be reported in batch

    • setPendingReportIncrementalPushVersions

      public void setPendingReportIncrementalPushVersions(List<CharSequence> value)
      Sets the value of the 'pendingReportIncrementalPushVersions' field. A list of string which stands for incremental push versions which have received EOIP but not yet reported prior to lag caught up, they will be reported in batch
      Parameters:
      value - the value to set.

    • getRealtimeTopicProducerStates

      public Map<String,Map<CharSequence,ProducerPartitionState>> getRealtimeTopicProducerStates()
      Gets the value of the 'realtimeTopicProducerStates' field.
      Returns:
      A map that maps upstream Kafka bootstrap server url -> to a map of producer GUID -> producer state for real-time data.

    • setRealtimeTopicProducerStates

      public void setRealtimeTopicProducerStates(Map<String,Map<CharSequence,ProducerPartitionState>> value)
      Sets the value of the 'realtimeTopicProducerStates' field. A map that maps upstream Kafka bootstrap server url -> to a map of producer GUID -> producer state for real-time data.
      Parameters:
      value - the value to set.

    • getRecordTransformerClassHash

      public Integer getRecordTransformerClassHash()
      Gets the value of the 'recordTransformerClassHash' field.
      Returns:
      An integer hash code used by the DaVinciRecordTransformer to detect changes to the user's class during bootstrapping.

    • setRecordTransformerClassHash

      public void setRecordTransformerClassHash(Integer value)
      Sets the value of the 'recordTransformerClassHash' field. An integer hash code used by the DaVinciRecordTransformer to detect changes to the user's class during bootstrapping.
      Parameters:
      value - the value to set.

    • getLastProcessedVersionTopicPubSubPosition

      public ByteBuffer getLastProcessedVersionTopicPubSubPosition()
      Gets the value of the 'lastProcessedVersionTopicPubSubPosition' field.
      Returns:
      The last PubSub position processed successfully in this partition from version topic

    • setLastProcessedVersionTopicPubSubPosition

      public void setLastProcessedVersionTopicPubSubPosition(ByteBuffer value)
      Sets the value of the 'lastProcessedVersionTopicPubSubPosition' field. The last PubSub position processed successfully in this partition from version topic
      Parameters:
      value - the value to set.

    • getLastConsumedVersionTopicPubSubPosition

      public ByteBuffer getLastConsumedVersionTopicPubSubPosition()
      Gets the value of the 'lastConsumedVersionTopicPubSubPosition' field.
      Returns:
      The last PubSub position consumed successfully in this partition from the version topic. This is used during resubscription when the Global RT DIV feature is enabled.

    • setLastConsumedVersionTopicPubSubPosition

      public void setLastConsumedVersionTopicPubSubPosition(ByteBuffer value)
      Sets the value of the 'lastConsumedVersionTopicPubSubPosition' field. The last PubSub position consumed successfully in this partition from the version topic. This is used during resubscription when the Global RT DIV feature is enabled.
      Parameters:
      value - the value to set.

    • getLatestObservedTermId

      public long getLatestObservedTermId()
      Gets the value of the 'latestObservedTermId' field.
      Returns:
      The most recent termId observed by this replica.

    • setLatestObservedTermId

      public void setLatestObservedTermId(long value)
      Sets the value of the 'latestObservedTermId' field. The most recent termId observed by this replica.
      Parameters:
      value - the value to set.

    • getCurrentTermStartPubSubPosition

      public ByteBuffer getCurrentTermStartPubSubPosition()
      Gets the value of the 'currentTermStartPubSubPosition' field.
      Returns:
      The pubsub position marking the start of the current leader's term in the version topic.

    • setCurrentTermStartPubSubPosition

      public void setCurrentTermStartPubSubPosition(ByteBuffer value)
      Sets the value of the 'currentTermStartPubSubPosition' field. The pubsub position marking the start of the current leader's term in the version topic.
      Parameters:
      value - the value to set.

    • getLastConsumedVersionTopicOffset

      public long getLastConsumedVersionTopicOffset()
      Gets the value of the 'lastConsumedVersionTopicOffset' field.
      Returns:
      The last offset consumed successfully in this partition from the version topic. This is used during resubscription when the Global RT DIV feature is enabled.

    • setLastConsumedVersionTopicOffset

      public void setLastConsumedVersionTopicOffset(long value)
      Sets the value of the 'lastConsumedVersionTopicOffset' field. The last offset consumed successfully in this partition from the version topic. This is used during resubscription when the Global RT DIV feature is enabled.
      Parameters:
      value - the value to set.

    • getHeartbeatTimestamp

      public long getHeartbeatTimestamp()
      Gets the value of the 'heartbeatTimestamp' field.
      Returns:
      The most stale heartbeat timestamp among all the regions in this partition for fast online transition during server restart.

    • setHeartbeatTimestamp

      public void setHeartbeatTimestamp(long value)
      Sets the value of the 'heartbeatTimestamp' field. The most stale heartbeat timestamp among all the regions in this partition for fast online transition during server restart.
      Parameters:
      value - the value to set.

    • getLastCheckpointTimestamp

      public long getLastCheckpointTimestamp()
      Gets the value of the 'lastCheckpointTimestamp' field.
      Returns:
      The most recent checkpoint timestamp for fast online transition during server restart.

    • setLastCheckpointTimestamp

      public void setLastCheckpointTimestamp(long value)
      Sets the value of the 'lastCheckpointTimestamp' field. The most recent checkpoint timestamp for fast online transition during server restart.
      Parameters:
      value - the value to set.

    • getKeyUrnCompressionDict

      public KeyUrnCompressionDict getKeyUrnCompressionDict()
      Gets the value of the 'keyUrnCompressionDict' field.
      Returns:
      When key compression is enabled, this field keeps all the related information for key URN compression.

    • setKeyUrnCompressionDict

      public void setKeyUrnCompressionDict(KeyUrnCompressionDict value)
      Sets the value of the 'keyUrnCompressionDict' field. When key compression is enabled, this field keeps all the related information for key URN compression.
      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