Package com.linkedin.venice.controller.kafka.protocol.admin

Class AddVersion

  • 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 AddVersion
extends org.apache.avro.specific.SpecificRecordBase
implements org.apache.avro.specific.SpecificRecord
    See Also:
    Serialized Form

    • Field Summary

      Fields 
      Modifier and Type Field Description
      java.lang.CharSequence clusterName  
      int numberOfPartitions  
      java.lang.CharSequence pushJobId  
      java.lang.CharSequence pushStreamSourceAddress  
      int pushType
      The push type of the new version, 0 => BATCH, 1 => STREAM_REPROCESSING.
      int repushSourceVersion
      Indicates the source version from which a repush version is created
      long rewindTimeInSecondsOverride
      The overridable rewind time config for this specific version of a hybrid store, and if it is not specified, the new version will use the store-level rewind time config
      static org.apache.avro.Schema SCHEMA$  
      java.lang.CharSequence storeName  
      java.util.List<java.lang.CharSequence> targetedRegions
      The list of regions that is separated by comma for targeted region push.
      int timestampMetadataVersionId
      The A/A metadata schema version ID that will be used to deserialize metadataPayload.
      int versionNum  
      boolean versionSwapDeferred
      Indicates if swapping this version to current version after push completion should be initiated or not

    • Constructor Summary

      Constructors 
      Constructor Description
      AddVersion()
      Default constructor.
      AddVersion​(java.lang.CharSequence clusterName, java.lang.CharSequence storeName, java.lang.CharSequence pushJobId, java.lang.Integer versionNum, java.lang.Integer numberOfPartitions, java.lang.Integer pushType, java.lang.CharSequence pushStreamSourceAddress, java.lang.Long rewindTimeInSecondsOverride, java.lang.Integer timestampMetadataVersionId, java.lang.Boolean versionSwapDeferred, java.util.List<java.lang.CharSequence> targetedRegions, java.lang.Integer repushSourceVersion)
      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()  
      java.lang.CharSequence getClusterName()
      Gets the value of the 'clusterName' field.
      int getNumberOfPartitions()
      Gets the value of the 'numberOfPartitions' field.
      java.lang.CharSequence getPushJobId()
      Gets the value of the 'pushJobId' field.
      java.lang.CharSequence getPushStreamSourceAddress()
      Gets the value of the 'pushStreamSourceAddress' field.
      int getPushType()
      Gets the value of the 'pushType' field.
      int getRepushSourceVersion()
      Gets the value of the 'repushSourceVersion' field.
      long getRewindTimeInSecondsOverride()
      Gets the value of the 'rewindTimeInSecondsOverride' field.
      org.apache.avro.Schema getSchema()  
      org.apache.avro.specific.SpecificData getSpecificData()  
      java.lang.CharSequence getStoreName()
      Gets the value of the 'storeName' field.
      java.util.List<java.lang.CharSequence> getTargetedRegions()
      Gets the value of the 'targetedRegions' field.
      int getTimestampMetadataVersionId()
      Gets the value of the 'timestampMetadataVersionId' field.
      int getVersionNum()
      Gets the value of the 'versionNum' field.
      boolean getVersionSwapDeferred()
      Gets the value of the 'versionSwapDeferred' field.
      void put​(int field$, java.lang.Object value$)  
      void readExternal​(java.io.ObjectInput in)  
      void setClusterName​(java.lang.CharSequence value)
      Sets the value of the 'clusterName' field.
      void setNumberOfPartitions​(int value)
      Sets the value of the 'numberOfPartitions' field.
      void setPushJobId​(java.lang.CharSequence value)
      Sets the value of the 'pushJobId' field.
      void setPushStreamSourceAddress​(java.lang.CharSequence value)
      Sets the value of the 'pushStreamSourceAddress' field.
      void setPushType​(int value)
      Sets the value of the 'pushType' field.
      void setRepushSourceVersion​(int value)
      Sets the value of the 'repushSourceVersion' field.
      void setRewindTimeInSecondsOverride​(long value)
      Sets the value of the 'rewindTimeInSecondsOverride' field.
      void setStoreName​(java.lang.CharSequence value)
      Sets the value of the 'storeName' field.
      void setTargetedRegions​(java.util.List<java.lang.CharSequence> value)
      Sets the value of the 'targetedRegions' field.
      void setTimestampMetadataVersionId​(int value)
      Sets the value of the 'timestampMetadataVersionId' field.
      void setVersionNum​(int value)
      Sets the value of the 'versionNum' field.
      void setVersionSwapDeferred​(boolean value)
      Sets the value of the 'versionSwapDeferred' 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$

      • clusterName

        public java.lang.CharSequence clusterName

      • storeName

        public java.lang.CharSequence storeName

      • pushJobId

        public java.lang.CharSequence pushJobId

      • versionNum

        public int versionNum

      • numberOfPartitions

        public int numberOfPartitions

      • pushType

        public int pushType
        The push type of the new version, 0 => BATCH, 1 => STREAM_REPROCESSING. Previous add version messages will default to BATCH and this is a safe because they were created when BATCH was the only version type

      • pushStreamSourceAddress

        public java.lang.CharSequence pushStreamSourceAddress

      • rewindTimeInSecondsOverride

        public long rewindTimeInSecondsOverride
        The overridable rewind time config for this specific version of a hybrid store, and if it is not specified, the new version will use the store-level rewind time config

      • timestampMetadataVersionId

        public int timestampMetadataVersionId
        The A/A metadata schema version ID that will be used to deserialize metadataPayload.

      • versionSwapDeferred

        public boolean versionSwapDeferred
        Indicates if swapping this version to current version after push completion should be initiated or not

      • targetedRegions

        public java.util.List<java.lang.CharSequence> targetedRegions
        The list of regions that is separated by comma for targeted region push. If set, this admin message should only be consumed by the targeted regions

      • repushSourceVersion

        public int repushSourceVersion
        Indicates the source version from which a repush version is created

    • Constructor Detail

      • AddVersion

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

      • AddVersion

        public AddVersion​(java.lang.CharSequence clusterName,
                  java.lang.CharSequence storeName,
                  java.lang.CharSequence pushJobId,
                  java.lang.Integer versionNum,
                  java.lang.Integer numberOfPartitions,
                  java.lang.Integer pushType,
                  java.lang.CharSequence pushStreamSourceAddress,
                  java.lang.Long rewindTimeInSecondsOverride,
                  java.lang.Integer timestampMetadataVersionId,
                  java.lang.Boolean versionSwapDeferred,
                  java.util.List<java.lang.CharSequence> targetedRegions,
                  java.lang.Integer repushSourceVersion)
        All-args constructor.
        Parameters:
        clusterName - The new value for clusterName
        storeName - The new value for storeName
        pushJobId - The new value for pushJobId
        versionNum - The new value for versionNum
        numberOfPartitions - The new value for numberOfPartitions
        pushType - The push type of the new version, 0 => BATCH, 1 => STREAM_REPROCESSING. Previous add version messages will default to BATCH and this is a safe because they were created when BATCH was the only version type
        pushStreamSourceAddress - The new value for pushStreamSourceAddress
        rewindTimeInSecondsOverride - The overridable rewind time config for this specific version of a hybrid store, and if it is not specified, the new version will use the store-level rewind time config
        timestampMetadataVersionId - The A/A metadata schema version ID that will be used to deserialize metadataPayload.
        versionSwapDeferred - Indicates if swapping this version to current version after push completion should be initiated or not
        targetedRegions - The list of regions that is separated by comma for targeted region push. If set, this admin message should only be consumed by the targeted regions
        repushSourceVersion - Indicates the source version from which a repush version is created

    • 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

      • getClusterName

        public java.lang.CharSequence getClusterName()
        Gets the value of the 'clusterName' field.
        Returns:
        The value of the 'clusterName' field.

      • setClusterName

        public void setClusterName​(java.lang.CharSequence value)
        Sets the value of the 'clusterName' field.
        Parameters:
        value - the value to set.

      • getStoreName

        public java.lang.CharSequence getStoreName()
        Gets the value of the 'storeName' field.
        Returns:
        The value of the 'storeName' field.

      • setStoreName

        public void setStoreName​(java.lang.CharSequence value)
        Sets the value of the 'storeName' field.
        Parameters:
        value - the value to set.

      • getPushJobId

        public java.lang.CharSequence getPushJobId()
        Gets the value of the 'pushJobId' field.
        Returns:
        The value of the 'pushJobId' field.

      • setPushJobId

        public void setPushJobId​(java.lang.CharSequence value)
        Sets the value of the 'pushJobId' field.
        Parameters:
        value - the value to set.

      • getVersionNum

        public int getVersionNum()
        Gets the value of the 'versionNum' field.
        Returns:
        The value of the 'versionNum' field.

      • setVersionNum

        public void setVersionNum​(int value)
        Sets the value of the 'versionNum' field.
        Parameters:
        value - the value to set.

      • getNumberOfPartitions

        public int getNumberOfPartitions()
        Gets the value of the 'numberOfPartitions' field.
        Returns:
        The value of the 'numberOfPartitions' field.

      • setNumberOfPartitions

        public void setNumberOfPartitions​(int value)
        Sets the value of the 'numberOfPartitions' field.
        Parameters:
        value - the value to set.

      • getPushType

        public int getPushType()
        Gets the value of the 'pushType' field.
        Returns:
        The push type of the new version, 0 => BATCH, 1 => STREAM_REPROCESSING. Previous add version messages will default to BATCH and this is a safe because they were created when BATCH was the only version type

      • setPushType

        public void setPushType​(int value)
        Sets the value of the 'pushType' field. The push type of the new version, 0 => BATCH, 1 => STREAM_REPROCESSING. Previous add version messages will default to BATCH and this is a safe because they were created when BATCH was the only version type
        Parameters:
        value - the value to set.

      • getPushStreamSourceAddress

        public java.lang.CharSequence getPushStreamSourceAddress()
        Gets the value of the 'pushStreamSourceAddress' field.
        Returns:
        The value of the 'pushStreamSourceAddress' field.

      • setPushStreamSourceAddress

        public void setPushStreamSourceAddress​(java.lang.CharSequence value)
        Sets the value of the 'pushStreamSourceAddress' field.
        Parameters:
        value - the value to set.

      • getRewindTimeInSecondsOverride

        public long getRewindTimeInSecondsOverride()
        Gets the value of the 'rewindTimeInSecondsOverride' field.
        Returns:
        The overridable rewind time config for this specific version of a hybrid store, and if it is not specified, the new version will use the store-level rewind time config

      • setRewindTimeInSecondsOverride

        public void setRewindTimeInSecondsOverride​(long value)
        Sets the value of the 'rewindTimeInSecondsOverride' field. The overridable rewind time config for this specific version of a hybrid store, and if it is not specified, the new version will use the store-level rewind time config
        Parameters:
        value - the value to set.

      • getTimestampMetadataVersionId

        public int getTimestampMetadataVersionId()
        Gets the value of the 'timestampMetadataVersionId' field.
        Returns:
        The A/A metadata schema version ID that will be used to deserialize metadataPayload.

      • setTimestampMetadataVersionId

        public void setTimestampMetadataVersionId​(int value)
        Sets the value of the 'timestampMetadataVersionId' field. The A/A metadata schema version ID that will be used to deserialize metadataPayload.
        Parameters:
        value - the value to set.

      • getVersionSwapDeferred

        public boolean getVersionSwapDeferred()
        Gets the value of the 'versionSwapDeferred' field.
        Returns:
        Indicates if swapping this version to current version after push completion should be initiated or not

      • setVersionSwapDeferred

        public void setVersionSwapDeferred​(boolean value)
        Sets the value of the 'versionSwapDeferred' field. Indicates if swapping this version to current version after push completion should be initiated or not
        Parameters:
        value - the value to set.

      • getTargetedRegions

        public java.util.List<java.lang.CharSequence> getTargetedRegions()
        Gets the value of the 'targetedRegions' field.
        Returns:
        The list of regions that is separated by comma for targeted region push. If set, this admin message should only be consumed by the targeted regions

      • setTargetedRegions

        public void setTargetedRegions​(java.util.List<java.lang.CharSequence> value)
        Sets the value of the 'targetedRegions' field. The list of regions that is separated by comma for targeted region push. If set, this admin message should only be consumed by the targeted regions
        Parameters:
        value - the value to set.

      • getRepushSourceVersion

        public int getRepushSourceVersion()
        Gets the value of the 'repushSourceVersion' field.
        Returns:
        Indicates the source version from which a repush version is created

      • setRepushSourceVersion

        public void setRepushSourceVersion​(int value)
        Sets the value of the 'repushSourceVersion' field. Indicates the source version from which a repush version is created
        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