Package com.linkedin.davinci.stats.ingestion

Enum Class IngestionOtelMetricEntity

java.lang.Object
java.lang.Enum<IngestionOtelMetricEntity>
com.linkedin.davinci.stats.ingestion.IngestionOtelMetricEntity
All Implemented Interfaces:
ModuleMetricEntityInterface, Serializable, Comparable<IngestionOtelMetricEntity>, Constable
public enum IngestionOtelMetricEntity extends Enum<IngestionOtelMetricEntity> implements ModuleMetricEntityInterface

  • Enum Constant Details

    • INGESTION_TASK_ERROR_COUNT

      public static final IngestionOtelMetricEntity INGESTION_TASK_ERROR_COUNT

    • INGESTION_TASK_PUSH_TIMEOUT_COUNT

      public static final IngestionOtelMetricEntity INGESTION_TASK_PUSH_TIMEOUT_COUNT

    • DISK_QUOTA_USED

      public static final IngestionOtelMetricEntity DISK_QUOTA_USED

    • INGESTION_RECORDS_CONSUMED

      public static final IngestionOtelMetricEntity INGESTION_RECORDS_CONSUMED

    • INGESTION_RECORDS_PRODUCED

      public static final IngestionOtelMetricEntity INGESTION_RECORDS_PRODUCED

    • INGESTION_BYTES_CONSUMED

      public static final IngestionOtelMetricEntity INGESTION_BYTES_CONSUMED

    • INGESTION_BYTES_PRODUCED

      public static final IngestionOtelMetricEntity INGESTION_BYTES_PRODUCED

    • INGESTION_SUBSCRIBE_PREP_TIME

      public static final IngestionOtelMetricEntity INGESTION_SUBSCRIBE_PREP_TIME

    • INGESTION_TIME

      public static final IngestionOtelMetricEntity INGESTION_TIME

    • INGESTION_PRODUCER_CALLBACK_TIME

      public static final IngestionOtelMetricEntity INGESTION_PRODUCER_CALLBACK_TIME

    • INGESTION_PREPROCESSING_LEADER_TIME

      public static final IngestionOtelMetricEntity INGESTION_PREPROCESSING_LEADER_TIME

    • INGESTION_PREPROCESSING_INTERNAL_TIME

      public static final IngestionOtelMetricEntity INGESTION_PREPROCESSING_INTERNAL_TIME

    • INGESTION_TIME_BETWEEN_COMPONENTS

      public static final IngestionOtelMetricEntity INGESTION_TIME_BETWEEN_COMPONENTS

    • INGESTION_PRODUCER_TIME

      public static final IngestionOtelMetricEntity INGESTION_PRODUCER_TIME

    • BATCH_PROCESSING_REQUEST_COUNT

      public static final IngestionOtelMetricEntity BATCH_PROCESSING_REQUEST_COUNT

    • BATCH_PROCESSING_REQUEST_RECORD_COUNT

      public static final IngestionOtelMetricEntity BATCH_PROCESSING_REQUEST_RECORD_COUNT

    • BATCH_PROCESSING_REQUEST_ERROR_COUNT

      public static final IngestionOtelMetricEntity BATCH_PROCESSING_REQUEST_ERROR_COUNT

    • BATCH_PROCESSING_REQUEST_TIME

      public static final IngestionOtelMetricEntity BATCH_PROCESSING_REQUEST_TIME

    • DCR_EVENT_COUNT

      public static final IngestionOtelMetricEntity DCR_EVENT_COUNT

    • DCR_TOTAL_COUNT

      public static final IngestionOtelMetricEntity DCR_TOTAL_COUNT

    • CONSUMER_IDLE_TIME

      public static final IngestionOtelMetricEntity CONSUMER_IDLE_TIME

    • DUPLICATE_KEY_UPDATE_COUNT

      public static final IngestionOtelMetricEntity DUPLICATE_KEY_UPDATE_COUNT

    • RT_RECORDS_CONSUMED

      public static final IngestionOtelMetricEntity RT_RECORDS_CONSUMED

    • RT_BYTES_CONSUMED

      public static final IngestionOtelMetricEntity RT_BYTES_CONSUMED

    • CONSUMER_QUEUE_PUT_TIME

      public static final IngestionOtelMetricEntity CONSUMER_QUEUE_PUT_TIME

    • STORAGE_ENGINE_PUT_TIME

      public static final IngestionOtelMetricEntity STORAGE_ENGINE_PUT_TIME

    • STORAGE_ENGINE_DELETE_TIME

      public static final IngestionOtelMetricEntity STORAGE_ENGINE_DELETE_TIME

    • CONSUMER_ACTION_TIME

      public static final IngestionOtelMetricEntity CONSUMER_ACTION_TIME

    • LONG_RUNNING_TASK_CHECK_TIME

      public static final IngestionOtelMetricEntity LONG_RUNNING_TASK_CHECK_TIME

    • VIEW_WRITER_PRODUCE_TIME

      public static final IngestionOtelMetricEntity VIEW_WRITER_PRODUCE_TIME

    • VIEW_WRITER_ACK_TIME

      public static final IngestionOtelMetricEntity VIEW_WRITER_ACK_TIME

    • PRODUCER_ENQUEUE_TIME

      public static final IngestionOtelMetricEntity PRODUCER_ENQUEUE_TIME

    • PRODUCER_COMPRESS_TIME

      public static final IngestionOtelMetricEntity PRODUCER_COMPRESS_TIME

    • PRODUCER_SYNCHRONIZE_TIME

      public static final IngestionOtelMetricEntity PRODUCER_SYNCHRONIZE_TIME

    • PARTIAL_UPDATE_TIME

      public static final IngestionOtelMetricEntity PARTIAL_UPDATE_TIME

    • DCR_LOOKUP_TIME

      public static final IngestionOtelMetricEntity DCR_LOOKUP_TIME

    • DCR_MERGE_TIME

      public static final IngestionOtelMetricEntity DCR_MERGE_TIME

    • UNEXPECTED_MESSAGE_COUNT

      public static final IngestionOtelMetricEntity UNEXPECTED_MESSAGE_COUNT

    • STORE_METADATA_INCONSISTENT_COUNT

      public static final IngestionOtelMetricEntity STORE_METADATA_INCONSISTENT_COUNT

    • INGESTION_FAILURE_COUNT

      public static final IngestionOtelMetricEntity INGESTION_FAILURE_COUNT

    • RESUBSCRIPTION_FAILURE_COUNT

      public static final IngestionOtelMetricEntity RESUBSCRIPTION_FAILURE_COUNT

    • PARTIAL_UPDATE_CACHE_HIT_COUNT

      public static final IngestionOtelMetricEntity PARTIAL_UPDATE_CACHE_HIT_COUNT

    • CHECKSUM_VERIFICATION_FAILURE_COUNT

      public static final IngestionOtelMetricEntity CHECKSUM_VERIFICATION_FAILURE_COUNT

    • BATCH_PUSH_RECORD_COUNT_MATCH_COUNT

      public static final IngestionOtelMetricEntity BATCH_PUSH_RECORD_COUNT_MATCH_COUNT
      Server-side batch-push record-count verification: the consumer-counted PUT/DELETE total at EOP matched the producer's "prc" count (and the HLL leg also passed, if HLL tracking is on). Informational — fires whether or not the per-server fail-on-mismatch flag is enabled.

    • BATCH_PUSH_RECORD_COUNT_MISMATCH_COUNT

      public static final IngestionOtelMetricEntity BATCH_PUSH_RECORD_COUNT_MISMATCH_COUNT
      Server-side batch-push record-count verification: either leg (counter or HLL) failed at EOP. Informational — fires whether or not the per-server fail-on-mismatch flag is enabled. Use this for visibility / dashboards; use RECORD_COUNT_MISMATCH_FAILURE_COUNT to alert on strict-mode failed-ingestion events.

    • RECORD_COUNT_MISMATCH_FAILURE_COUNT

      public static final IngestionOtelMetricEntity RECORD_COUNT_MISMATCH_FAILURE_COUNT
      Strict-mode record-count mismatch — fires whenever a mismatch is detected AND the server's fail-on-mismatch flag is enabled. On Venice servers this is paired with a thrown VeniceException (ingestion fails). On DaVinci replicas the throw is suppressed (DVC failure is aggregated separately via the push status store) and this counter does not fire.

    • DCR_LOOKUP_CACHE_HIT_COUNT

      public static final IngestionOtelMetricEntity DCR_LOOKUP_CACHE_HIT_COUNT

    • BYTES_CONSUMED_AS_UNCOMPRESSED_SIZE

      public static final IngestionOtelMetricEntity BYTES_CONSUMED_AS_UNCOMPRESSED_SIZE

    • RECORD_KEY_SIZE

      public static final IngestionOtelMetricEntity RECORD_KEY_SIZE

    • RECORD_VALUE_SIZE

      public static final IngestionOtelMetricEntity RECORD_VALUE_SIZE

    • RECORD_ASSEMBLED_SIZE

      public static final IngestionOtelMetricEntity RECORD_ASSEMBLED_SIZE

    • RECORD_ASSEMBLED_SIZE_RATIO

      public static final IngestionOtelMetricEntity RECORD_ASSEMBLED_SIZE_RATIO

    • UNIQUE_INGESTED_KEY_COUNT

      public static final IngestionOtelMetricEntity UNIQUE_INGESTED_KEY_COUNT
      HLL estimate of unique keys ever put or deleted, per replica type, for a store version on this host. Monotonically increasing within a version; resets on new version push.

      LEADER aggregates partitions in LEADER state; FOLLOWER aggregates partitions in STANDBY state plus the standby→leader transition states (IN_TRANSITION_FROM_STANDBY_TO_LEADER, PAUSE_TRANSITION_FROM_STANDBY_TO_LEADER) — those are still consuming as followers per the LFST javadoc.

    • INGESTION_TASK_COUNT

      public static final IngestionOtelMetricEntity INGESTION_TASK_COUNT

    • ACTIVE_KEY_COUNT

      public static final IngestionOtelMetricEntity ACTIVE_KEY_COUNT
      Point-in-time count of unique active keys across partitions of this store version on this host. Non-monotonic (tracks creates and deletes).

      LEADER aggregates partitions in LEADER state; FOLLOWER aggregates partitions in STANDBY state plus the standby→leader transition states (IN_TRANSITION_FROM_STANDBY_TO_LEADER, PAUSE_TRANSITION_FROM_STANDBY_TO_LEADER) — those are still consuming as followers per the LFST javadoc.

      Sentinels: OffsetRecord.ACTIVE_KEY_COUNT_NOT_TRACKED = no partition of this replica type has tracking active; 0 = tracked but empty (e.g., empty push). No data point is emitted when no task exists for the role.

    • PARTIAL_UPDATE_AMPLIFICATION_ALERT_COUNT

      public static final IngestionOtelMetricEntity PARTIAL_UPDATE_AMPLIFICATION_ALERT_COUNT

    • ACTIVE_KEY_COUNT_INVALIDATION

      public static final IngestionOtelMetricEntity ACTIVE_KEY_COUNT_INVALIDATION

  • Method Details

    • values

      public static IngestionOtelMetricEntity[] 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 IngestionOtelMetricEntity 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

    • getMetricEntity

      public MetricEntity getMetricEntity()
      Specified by:
      getMetricEntity in interface ModuleMetricEntityInterface