Package com.linkedin.venice
Enum PushJobCheckpoints
- java.lang.Object
-
- java.lang.Enum<PushJobCheckpoints>
-
- com.linkedin.venice.PushJobCheckpoints
-
- All Implemented Interfaces:
VeniceEnumValue
,java.io.Serializable
,java.lang.Comparable<PushJobCheckpoints>
public enum PushJobCheckpoints extends java.lang.Enum<PushJobCheckpoints> implements VeniceEnumValue
Different successful checkpoints and known error scenarios of the VPJ flow. 1. The enums are not sequential 2. Non-negative enums are successful checkpoints 3. Negative enums are error scenarios (Can be user or system errors)
-
-
Enum Constant Summary
-
Field Summary
Fields Modifier and Type Field Description static java.util.Set<PushJobCheckpoints>
DEFAULT_PUSH_JOB_USER_ERROR_CHECKPOINTS
Default set checkpoints to define push job failures are user errors which can be overridden via controller configConfigKeys.PUSH_JOB_FAILURE_CHECKPOINTS_TO_DEFINE_USER_ERROR
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description int
getValue()
static PushJobCheckpoints
valueOf(int value)
Returns the enum constant of this type with the specified name.static PushJobCheckpoints
valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.static PushJobCheckpoints[]
values()
Returns an array containing the constants of this enum type, in the order they are declared.
-
-
-
Enum Constant Detail
-
INITIALIZE_PUSH_JOB
public static final PushJobCheckpoints INITIALIZE_PUSH_JOB
-
NEW_VERSION_CREATED
public static final PushJobCheckpoints NEW_VERSION_CREATED
-
START_DATA_WRITER_JOB
public static final PushJobCheckpoints START_DATA_WRITER_JOB
-
DATA_WRITER_JOB_COMPLETED
public static final PushJobCheckpoints DATA_WRITER_JOB_COMPLETED
-
START_JOB_STATUS_POLLING
public static final PushJobCheckpoints START_JOB_STATUS_POLLING
-
JOB_STATUS_POLLING_COMPLETED
public static final PushJobCheckpoints JOB_STATUS_POLLING_COMPLETED
-
START_VALIDATE_SCHEMA_AND_BUILD_DICT_MAP_JOB
public static final PushJobCheckpoints START_VALIDATE_SCHEMA_AND_BUILD_DICT_MAP_JOB
-
VALIDATE_SCHEMA_AND_BUILD_DICT_MAP_JOB_COMPLETED
public static final PushJobCheckpoints VALIDATE_SCHEMA_AND_BUILD_DICT_MAP_JOB_COMPLETED
-
QUOTA_EXCEEDED
public static final PushJobCheckpoints QUOTA_EXCEEDED
-
WRITE_ACL_FAILED
public static final PushJobCheckpoints WRITE_ACL_FAILED
-
DUP_KEY_WITH_DIFF_VALUE
public static final PushJobCheckpoints DUP_KEY_WITH_DIFF_VALUE
-
INPUT_DATA_SCHEMA_VALIDATION_FAILED
public static final PushJobCheckpoints INPUT_DATA_SCHEMA_VALIDATION_FAILED
-
EXTENDED_INPUT_DATA_SCHEMA_VALIDATION_FAILED
public static final PushJobCheckpoints EXTENDED_INPUT_DATA_SCHEMA_VALIDATION_FAILED
-
RECORD_TOO_LARGE_FAILED
public static final PushJobCheckpoints RECORD_TOO_LARGE_FAILED
-
CONCURRENT_BATCH_PUSH
public static final PushJobCheckpoints CONCURRENT_BATCH_PUSH
-
DATASET_CHANGED
public static final PushJobCheckpoints DATASET_CHANGED
-
INVALID_INPUT_FILE
public static final PushJobCheckpoints INVALID_INPUT_FILE
-
ZSTD_DICTIONARY_CREATION_FAILED
public static final PushJobCheckpoints ZSTD_DICTIONARY_CREATION_FAILED
-
DVC_INGESTION_ERROR_DISK_FULL
public static final PushJobCheckpoints DVC_INGESTION_ERROR_DISK_FULL
-
DVC_INGESTION_ERROR_MEMORY_LIMIT_REACHED
public static final PushJobCheckpoints DVC_INGESTION_ERROR_MEMORY_LIMIT_REACHED
-
DVC_INGESTION_ERROR_TOO_MANY_DEAD_INSTANCES
public static final PushJobCheckpoints DVC_INGESTION_ERROR_TOO_MANY_DEAD_INSTANCES
-
DVC_INGESTION_ERROR_OTHER
public static final PushJobCheckpoints DVC_INGESTION_ERROR_OTHER
-
-
Field Detail
-
DEFAULT_PUSH_JOB_USER_ERROR_CHECKPOINTS
public static final java.util.Set<PushJobCheckpoints> DEFAULT_PUSH_JOB_USER_ERROR_CHECKPOINTS
Default set checkpoints to define push job failures are user errors which can be overridden via controller configConfigKeys.PUSH_JOB_FAILURE_CHECKPOINTS_TO_DEFINE_USER_ERROR
-
-
Method Detail
-
values
public static PushJobCheckpoints[] values()
Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows:for (PushJobCheckpoints c : PushJobCheckpoints.values()) System.out.println(c);
- Returns:
- an array containing the constants of this enum type, in the order they are declared
-
valueOf
public static PushJobCheckpoints valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (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:
java.lang.IllegalArgumentException
- if this enum type has no constant with the specified namejava.lang.NullPointerException
- if the argument is null
-
getValue
public int getValue()
- Specified by:
getValue
in interfaceVeniceEnumValue
-
valueOf
public static PushJobCheckpoints valueOf(int value)
Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)- Parameters:
value
- the name of the enum constant to be returned.- Returns:
- the enum constant with the specified name
- Throws:
java.lang.IllegalArgumentException
- if this enum type has no constant with the specified namejava.lang.NullPointerException
- if the argument is null
-
-