Package com.linkedin.venice.status.protocol

Class BatchJobHeartbeatKey

  • All Implemented Interfaces:
    java.io.Externalizable, java.io.Serializable, java.lang.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 BatchJobHeartbeatKey
extends org.apache.avro.specific.SpecificRecordBase
implements org.apache.avro.specific.SpecificRecord
    Key part of the heartbeat sent by a push job. Each key represents a session of heartbeats from one push job instance
    See Also:
    Serialized Form

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static org.apache.avro.Schema SCHEMA$  
      java.lang.CharSequence storeName
      Name of the store which the running push job instance is pushing data to
      int storeVersion
      Version of the store which the running push job instance is pushing data to

    • Constructor Summary

      Constructors 
      Constructor Description
      BatchJobHeartbeatKey()
      Default constructor.
      BatchJobHeartbeatKey​(java.lang.CharSequence storeName, java.lang.Integer storeVersion)
      All-args constructor.

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.lang.Object get​(int field$)  
      static org.apache.avro.Schema getClassSchema()  
      org.apache.avro.Schema getSchema()  
      org.apache.avro.specific.SpecificData getSpecificData()  
      java.lang.CharSequence getStoreName()
      Gets the value of the 'storeName' field.
      int getStoreVersion()
      Gets the value of the 'storeVersion' field.
      void put​(int field$, java.lang.Object value$)  
      void readExternal​(java.io.ObjectInput in)  
      void setStoreName​(java.lang.CharSequence value)
      Sets the value of the 'storeName' field.
      void setStoreVersion​(int value)
      Sets the value of the 'storeVersion' field.
      void writeExternal​(java.io.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 Detail

      • SCHEMA$

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

      • storeName

        public java.lang.CharSequence storeName
        Name of the store which the running push job instance is pushing data to

      • storeVersion

        public int storeVersion
        Version of the store which the running push job instance is pushing data to

    • Constructor Detail

      • BatchJobHeartbeatKey

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

      • BatchJobHeartbeatKey

        public BatchJobHeartbeatKey​(java.lang.CharSequence storeName,
                            java.lang.Integer storeVersion)
        All-args constructor.
        Parameters:
        storeName - Name of the store which the running push job instance is pushing data to
        storeVersion - Version of the store which the running push job instance is pushing data to

    • Method Detail

      • 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 java.lang.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$,
                java.lang.Object value$)
        Specified by:
        put in interface org.apache.avro.generic.IndexedRecord
        Specified by:
        put in class org.apache.avro.specific.SpecificRecordBase

      • getStoreName

        public java.lang.CharSequence getStoreName()
        Gets the value of the 'storeName' field.
        Returns:
        Name of the store which the running push job instance is pushing data to

      • setStoreName

        public void setStoreName​(java.lang.CharSequence value)
        Sets the value of the 'storeName' field. Name of the store which the running push job instance is pushing data to
        Parameters:
        value - the value to set.

      • getStoreVersion

        public int getStoreVersion()
        Gets the value of the 'storeVersion' field.
        Returns:
        Version of the store which the running push job instance is pushing data to

      • setStoreVersion

        public void setStoreVersion​(int value)
        Sets the value of the 'storeVersion' field. Version of the store which the running push job instance is pushing data to
        Parameters:
        value - the value to set.

      • writeExternal

        public void writeExternal​(java.io.ObjectOutput out)
                   throws java.io.IOException
        Specified by:
        writeExternal in interface java.io.Externalizable
        Overrides:
        writeExternal in class org.apache.avro.specific.SpecificRecordBase
        Throws:
        java.io.IOException

      • readExternal

        public void readExternal​(java.io.ObjectInput in)
                  throws java.io.IOException
        Specified by:
        readExternal in interface java.io.Externalizable
        Overrides:
        readExternal in class org.apache.avro.specific.SpecificRecordBase
        Throws:
        java.io.IOException