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

Class IncrementalPushReplicaStatus

java.lang.Object
org.apache.avro.specific.SpecificRecordBase
com.linkedin.venice.kafka.protocol.state.IncrementalPushReplicaStatus
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 IncrementalPushReplicaStatus extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord
A record containing the incremental push replica status, including timestamp and status.
See Also:

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final org.apache.avro.Schema
    SCHEMA$
     
    int
    status
    The current push status for the incremental push
    long
    timestamp
    The broker timestamp of the control message received which can be used to purge stale incremental push entries

  • Constructor Summary

    Constructors
    Constructor
    Description
    IncrementalPushReplicaStatus()
    Default constructor.
    IncrementalPushReplicaStatus(Integer status, Long timestamp)
    All-args constructor.

  • Method Summary

    Modifier and Type
    Method
    Description
    Object
    get(int field$)
     
    static org.apache.avro.Schema
    getClassSchema()
     
    org.apache.avro.Schema
    getSchema()
     
    org.apache.avro.specific.SpecificData
    getSpecificData()
     
    int
    getStatus()
    Gets the value of the 'status' field.
    long
    getTimestamp()
    Gets the value of the 'timestamp' field.
    void
    put(int field$, Object value$)
     
    void
    readExternal(ObjectInput in)
     
    void
    setStatus(int value)
    Sets the value of the 'status' field.
    void
    setTimestamp(long value)
    Sets the value of the 'timestamp' 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$

    • status

      public int status
      The current push status for the incremental push

    • timestamp

      public long timestamp
      The broker timestamp of the control message received which can be used to purge stale incremental push entries

  • Constructor Details

    • IncrementalPushReplicaStatus

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

    • IncrementalPushReplicaStatus

      public IncrementalPushReplicaStatus(Integer status, Long timestamp)
      All-args constructor.
      Parameters:
      status - The current push status for the incremental push
      timestamp - The broker timestamp of the control message received which can be used to purge stale incremental push entries

  • 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

    • getStatus

      public int getStatus()
      Gets the value of the 'status' field.
      Returns:
      The current push status for the incremental push

    • setStatus

      public void setStatus(int value)
      Sets the value of the 'status' field. The current push status for the incremental push
      Parameters:
      value - the value to set.

    • getTimestamp

      public long getTimestamp()
      Gets the value of the 'timestamp' field.
      Returns:
      The broker timestamp of the control message received which can be used to purge stale incremental push entries

    • setTimestamp

      public void setTimestamp(long value)
      Sets the value of the 'timestamp' field. The broker timestamp of the control message received which can be used to purge stale incremental push entries
      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