Enum Class VersionStatus

java.lang.Object
java.lang.Enum<VersionStatus>
com.linkedin.venice.meta.VersionStatus
All Implemented Interfaces:
VeniceEnumValue, Serializable, Comparable<VersionStatus>, Constable

public enum VersionStatus extends Enum<VersionStatus> implements VeniceEnumValue
Enums of status of version.
  • Enum Constant Details

    • NOT_CREATED

      public static final VersionStatus NOT_CREATED
      This version hasn't been created yet. It is not persisted in ZK
    • STARTED

      public static final VersionStatus STARTED
      Version has been created and started to ingest new data, but has not completed ingestion and is not ready to serve read traffic
    • PUSHED

      public static final VersionStatus PUSHED
      Version has been pushed to venice and is ready to serve read request. Intermediate status after a push job succeeds in all child regions before DeferredVersionSwapService flips the status to ONLINE. This status only exists in the parent
    • ONLINE

      public static final VersionStatus ONLINE
      Version is serving read requests
    • ERROR

      public static final VersionStatus ERROR
      Version is not serving read requests, and it's relevant push job has failed
    • CREATED

      public static final VersionStatus CREATED
      Version is created and persisted inside ZK. Currently not used
    • PARTIALLY_ONLINE

      public static final VersionStatus PARTIALLY_ONLINE
      Version has been pushed to Venice and is serving read traffic in some regions, but failed in other regions. This status only exists in the parent
    • KILLED

      public static final VersionStatus KILLED
      Version is killed. Intermediate status after a push job is killed or fails before DeferredVersionSwapService flips the status to either ERROR or PARTIALLY_ONLINE
  • Method Details

    • values

      public static VersionStatus[] values()
      Returns an array containing the constants of this enum class, in the order they are declared.
      Returns:
      an array containing the constants of this enum class, in the order they are declared
    • valueOf

      public static VersionStatus valueOf(String name)
      Returns the enum constant of this class with the specified name. The string must match exactly an identifier used to declare an enum constant in this class. (Extraneous whitespace characters are not permitted.)
      Parameters:
      name - the name of the enum constant to be returned.
      Returns:
      the enum constant with the specified name
      Throws:
      IllegalArgumentException - if this enum class has no constant with the specified name
      NullPointerException - if the argument is null
    • getVersionStatusFromInt

      public static VersionStatus getVersionStatusFromInt(int v)
    • canDelete

      public static boolean canDelete(VersionStatus status)
      check if a status can be deleted immediately.
      Parameters:
      status -
      Returns:
      true if it can be deleted immediately, false otherwise
    • preserveLastFew

      public static boolean preserveLastFew(VersionStatus status)
      For all the status which returns true, last few versions (few count, controlled by config) will be preserved. For a store typically last few online versions should be preserved.
      Parameters:
      status -
      Returns:
      true if it should be considered, false otherwise
    • isBootstrapCompleted

      public static boolean isBootstrapCompleted(VersionStatus status)
      Check if the Version has completed the bootstrap. We need to make sure that Kafka topic for uncompleted offline job should NOT be deleted. Otherwise Kafka MM would crash. Attention: For streaming case, even version is ONLINE or PUSHED, it might be not safe to delete kafka topic.
    • isVersionKilled

      public static boolean isVersionKilled(VersionStatus status)
    • isVersionErrored

      public static boolean isVersionErrored(VersionStatus status)
    • getValue

      public int getValue()
      Specified by:
      getValue in interface VeniceEnumValue