Package com.linkedin.venice.hadoop

Enum VenicePushJob.PushJobCheckpoints

java.lang.Object

java.lang.Enum<VenicePushJob.PushJobCheckpoints>

com.linkedin.venice.hadoop.VenicePushJob.PushJobCheckpoints

All Implemented Interfaces:

java.io.Serializable, java.lang.Comparable<VenicePushJob.PushJobCheckpoints>

Enclosing class:

VenicePushJob

public static enum VenicePushJob.PushJobCheckpoints
extends java.lang.Enum<VenicePushJob.PushJobCheckpoints>

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

Enum Constants

Enum Constant	Description
CONCURRENT_BATCH_PUSH
DATA_WRITER_JOB_COMPLETED
DATASET_CHANGED
DUP_KEY_WITH_DIFF_VALUE
DVC_INGESTION_ERROR_DISK_FULL
DVC_INGESTION_ERROR_MEMORY_LIMIT_REACHED
DVC_INGESTION_ERROR_OTHER
DVC_INGESTION_ERROR_TOO_MANY_DEAD_INSTANCES
EXTENDED_INPUT_DATA_SCHEMA_VALIDATION_FAILED
INITIALIZE_PUSH_JOB
INPUT_DATA_SCHEMA_VALIDATION_FAILED
INVALID_INPUT_FILE
JOB_STATUS_POLLING_COMPLETED
NEW_VERSION_CREATED
QUOTA_EXCEEDED
RECORD_TOO_LARGE_FAILED
START_DATA_WRITER_JOB
START_JOB_STATUS_POLLING
START_VALIDATE_SCHEMA_AND_BUILD_DICT_MAP_JOB
VALIDATE_SCHEMA_AND_BUILD_DICT_MAP_JOB_COMPLETED
WRITE_ACL_FAILED
ZSTD_DICTIONARY_CREATION_FAILED

Method Summary

Modifier and Type	Method	Description
int	getValue()
static VenicePushJob.PushJobCheckpoints	valueOf(java.lang.String name)	Returns the enum constant of this type with the specified name.
static VenicePushJob.PushJobCheckpoints[]	values()	Returns an array containing the constants of this enum type, in the order they are declared.

Methods inherited from class java.lang.Enum

clone, compareTo, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Enum Constant Detail

INITIALIZE_PUSH_JOB

public static final VenicePushJob.PushJobCheckpoints INITIALIZE_PUSH_JOB

NEW_VERSION_CREATED

public static final VenicePushJob.PushJobCheckpoints NEW_VERSION_CREATED

START_DATA_WRITER_JOB

public static final VenicePushJob.PushJobCheckpoints START_DATA_WRITER_JOB

DATA_WRITER_JOB_COMPLETED

public static final VenicePushJob.PushJobCheckpoints DATA_WRITER_JOB_COMPLETED

START_JOB_STATUS_POLLING

public static final VenicePushJob.PushJobCheckpoints START_JOB_STATUS_POLLING

JOB_STATUS_POLLING_COMPLETED

public static final VenicePushJob.PushJobCheckpoints JOB_STATUS_POLLING_COMPLETED

START_VALIDATE_SCHEMA_AND_BUILD_DICT_MAP_JOB

public static final VenicePushJob.PushJobCheckpoints START_VALIDATE_SCHEMA_AND_BUILD_DICT_MAP_JOB

VALIDATE_SCHEMA_AND_BUILD_DICT_MAP_JOB_COMPLETED

public static final VenicePushJob.PushJobCheckpoints VALIDATE_SCHEMA_AND_BUILD_DICT_MAP_JOB_COMPLETED

QUOTA_EXCEEDED

public static final VenicePushJob.PushJobCheckpoints QUOTA_EXCEEDED

WRITE_ACL_FAILED

public static final VenicePushJob.PushJobCheckpoints WRITE_ACL_FAILED

DUP_KEY_WITH_DIFF_VALUE

public static final VenicePushJob.PushJobCheckpoints DUP_KEY_WITH_DIFF_VALUE

INPUT_DATA_SCHEMA_VALIDATION_FAILED

public static final VenicePushJob.PushJobCheckpoints INPUT_DATA_SCHEMA_VALIDATION_FAILED

EXTENDED_INPUT_DATA_SCHEMA_VALIDATION_FAILED

public static final VenicePushJob.PushJobCheckpoints EXTENDED_INPUT_DATA_SCHEMA_VALIDATION_FAILED

RECORD_TOO_LARGE_FAILED

public static final VenicePushJob.PushJobCheckpoints RECORD_TOO_LARGE_FAILED

CONCURRENT_BATCH_PUSH

public static final VenicePushJob.PushJobCheckpoints CONCURRENT_BATCH_PUSH

DATASET_CHANGED

public static final VenicePushJob.PushJobCheckpoints DATASET_CHANGED

INVALID_INPUT_FILE

public static final VenicePushJob.PushJobCheckpoints INVALID_INPUT_FILE

ZSTD_DICTIONARY_CREATION_FAILED

public static final VenicePushJob.PushJobCheckpoints ZSTD_DICTIONARY_CREATION_FAILED

DVC_INGESTION_ERROR_DISK_FULL

public static final VenicePushJob.PushJobCheckpoints DVC_INGESTION_ERROR_DISK_FULL

DVC_INGESTION_ERROR_MEMORY_LIMIT_REACHED

public static final VenicePushJob.PushJobCheckpoints DVC_INGESTION_ERROR_MEMORY_LIMIT_REACHED

DVC_INGESTION_ERROR_TOO_MANY_DEAD_INSTANCES

public static final VenicePushJob.PushJobCheckpoints DVC_INGESTION_ERROR_TOO_MANY_DEAD_INSTANCES

DVC_INGESTION_ERROR_OTHER

public static final VenicePushJob.PushJobCheckpoints DVC_INGESTION_ERROR_OTHER

Method Detail

values

public static VenicePushJob.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 (VenicePushJob.PushJobCheckpoints c : VenicePushJob.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 VenicePushJob.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 name

java.lang.NullPointerException - if the argument is null

getValue

public int getValue()