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

Class AddVersion

java.lang.Object
org.apache.avro.specific.SpecificRecordBase
com.linkedin.venice.controller.kafka.protocol.admin.AddVersion
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 AddVersion extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord
See Also:

  • Field Details

    • SCHEMA$

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

    • clusterName

      public CharSequence clusterName

    • storeName

      public CharSequence storeName

    • pushJobId

      public 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 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 List<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

    • currentRTVersionNumber

      public int currentRTVersionNumber
      current RT version number that should be used to formulate real time topic name during add version

  • Constructor Details

    • 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(CharSequence clusterName, CharSequence storeName, CharSequence pushJobId, Integer versionNum, Integer numberOfPartitions, Integer pushType, CharSequence pushStreamSourceAddress, Long rewindTimeInSecondsOverride, Integer timestampMetadataVersionId, Boolean versionSwapDeferred, List<CharSequence> targetedRegions, Integer repushSourceVersion, Integer currentRTVersionNumber)
      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
      currentRTVersionNumber - current RT version number that should be used to formulate real time topic name during add version

  • 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

    • getClusterName

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

    • setClusterName

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

    • getStoreName

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

    • setStoreName

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

    • getPushJobId

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

    • setPushJobId

      public void setPushJobId(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 CharSequence getPushStreamSourceAddress()
      Gets the value of the 'pushStreamSourceAddress' field.
      Returns:
      The value of the 'pushStreamSourceAddress' field.

    • setPushStreamSourceAddress

      public void setPushStreamSourceAddress(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 List<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(List<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.

    • getCurrentRTVersionNumber

      public int getCurrentRTVersionNumber()
      Gets the value of the 'currentRTVersionNumber' field.
      Returns:
      current RT version number that should be used to formulate real time topic name during add version

    • setCurrentRTVersionNumber

      public void setCurrentRTVersionNumber(int value)
      Sets the value of the 'currentRTVersionNumber' field. current RT version number that should be used to formulate real time topic name during add version
      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