Package com.linkedin.davinci.stats.ingestion

Class NoOpIngestionOtelStats

java.lang.Object

com.linkedin.davinci.stats.ingestion.IngestionOtelStats

com.linkedin.davinci.stats.ingestion.NoOpIngestionOtelStats

public class NoOpIngestionOtelStats
extends IngestionOtelStats

A no-op implementation of IngestionOtelStats that discards all recording calls. Used when ingestion OTel stats are disabled via config so that all recording call sites in AggVersionedIngestionStats stay as simple unconditional calls instead of being wrapped in null checks. This is a readability/maintainability choice, not a performance one — JIT would optimize null checks equally well via constant-folding of the final boolean guard in getIngestionOtelStats().

Field Summary

Fields

Modifier and Type	Field	Description
static final NoOpIngestionOtelStats	INSTANCE	Singleton instance — safe to share since all methods are stateless no-ops.

Method Summary

Modifier and Type	Method	Description
void	close()	Cleans up all per-version state for this store.
boolean	emitOtelMetrics()
void	recordAssembledSize(int version, VeniceRecordType recordType, long bytes)
void	recordAssembledSizeRatio(int version, double ratio)
void	recordBatchProcessingRequestCount(int version, long value)
void	recordBatchProcessingRequestErrorCount(int version, long value)
void	recordBatchProcessingRequestRecordCount(int version, long value)
void	recordBatchProcessingRequestTime(int version, double latencyMs)
void	recordBytesConsumed(int version, ReplicaType replicaType, long value)
void	recordBytesConsumedAsUncompressedSize(int version, long bytes)
void	recordBytesProduced(int version, ReplicaType replicaType, long value)
void	recordChecksumVerificationFailureCount(int version, long value)
void	recordConsumerActionTime(int version, double latencyMs)
void	recordConsumerQueuePutTime(int version, double latencyMs)
void	recordDcrEventCount(int version, VeniceDCREvent event, long value)
void	recordDcrLookupCacheHitCount(int version, VeniceRecordType recordType, long value)
void	recordDcrLookupTime(int version, VeniceRecordType recordType, double latencyMs)
void	recordDcrMergeTime(int version, VeniceDCROperation op, double latencyMs)
void	recordDcrTotalCount(int version, long value)
void	recordDuplicateKeyUpdateCount(int version, long value)
void	recordIdleTime(int version, long idleTimeMs)
void	recordIngestionFailureCount(int version, VeniceIngestionFailureReason reason, long value)
void	recordIngestionTime(int version, double latencyMs)
void	recordKeySize(int version, long bytes)
void	recordLongRunningTaskCheckTime(int version, double latencyMs)
void	recordPartialUpdateCacheHitCount(int version, long value)
void	recordPartialUpdateTime(int version, VenicePartialUpdateOperation op, double latencyMs)
void	recordPreprocessingInternalTime(int version, double latencyMs)
void	recordPreprocessingLeaderTime(int version, double latencyMs)
void	recordProducerCallbackTime(int version, ReplicaType replicaType, double latencyMs)
void	recordProducerCompressTime(int version, double latencyMs)
void	recordProducerEnqueueTime(int version, double latencyMs)
void	recordProducerSynchronizeTime(int version, double latencyMs)
void	recordProducerTime(int version, double latencyMs)
void	recordRecordsConsumed(int version, ReplicaType replicaType, long value)
void	recordRecordsProduced(int version, ReplicaType replicaType, long value)
void	recordResubscriptionFailureCount(int version, long value)
void	recordRtBytesConsumed(int version, String sourceRegion, VeniceRegionLocality regionLocality, long bytes)
void	recordRtRecordsConsumed(int version, String sourceRegion, VeniceRegionLocality regionLocality, long count)
void	recordStorageEngineDeleteTime(int version, double latencyMs)
void	recordStorageEnginePutTime(int version, double latencyMs)
void	recordStoreMetadataInconsistentCount(int version, long value)
void	recordSubscribePrepTime(int version, double latencyMs)
void	recordTimeBetweenComponents(int version, VeniceIngestionSourceComponent sourceComponent, VeniceIngestionDestinationComponent destComponent, double latencyMs)
void	recordUnexpectedMessageCount(int version, long value)
void	recordValueSize(int version, long bytes)
void	recordViewWriterAckTime(int version, double latencyMs)
void	recordViewWriterProduceTime(int version, double latencyMs)
void	removeIngestionTask(int version)	Removes the StoreIngestionTask and associated per-version state for a specific version.
void	setIngestionTask(int version, StoreIngestionTask task)	Sets the StoreIngestionTask for a specific version.
void	setIngestionTaskPushTimeoutGauge(int version, int value)
void	updateVersionInfo(int currentVersion, int futureVersion)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

INSTANCE

public static final NoOpIngestionOtelStats INSTANCE

Singleton instance — safe to share since all methods are stateless no-ops.

Method Details

setIngestionTask

public void setIngestionTask(int version,
 StoreIngestionTask task)

Description copied from class: IngestionOtelStats

Sets the StoreIngestionTask for a specific version. This enables async gauge metrics to access task data.

Overrides:

setIngestionTask in class IngestionOtelStats

removeIngestionTask

public void removeIngestionTask(int version)

Description copied from class: IngestionOtelStats

Removes the StoreIngestionTask and associated per-version state for a specific version.

Overrides:

removeIngestionTask in class IngestionOtelStats

close

public void close()

Description copied from class: IngestionOtelStats

Cleans up all per-version state for this store. Call this when the store is being deleted.

Note: OTel instruments (counters, histograms, async gauges) are NOT deregistered here. OpenTelemetry SDK does not support deregistering individual instruments from a Meter. The instruments will remain registered but will report zero/stale values until the MeterProvider is shut down.

Overrides:

close in class IngestionOtelStats

setIngestionTaskPushTimeoutGauge

public void setIngestionTaskPushTimeoutGauge(int version,
 int value)

Overrides:

setIngestionTaskPushTimeoutGauge in class IngestionOtelStats

recordIdleTime

public void recordIdleTime(int version,
 long idleTimeMs)

Overrides:

recordIdleTime in class IngestionOtelStats

emitOtelMetrics

public boolean emitOtelMetrics()

Overrides:

emitOtelMetrics in class IngestionOtelStats

updateVersionInfo

public void updateVersionInfo(int currentVersion,
 int futureVersion)

Overrides:

updateVersionInfo in class IngestionOtelStats

recordSubscribePrepTime

public void recordSubscribePrepTime(int version,
 double latencyMs)

Overrides:

recordSubscribePrepTime in class IngestionOtelStats

recordIngestionTime

public void recordIngestionTime(int version,
 double latencyMs)

Overrides:

recordIngestionTime in class IngestionOtelStats

recordPreprocessingLeaderTime

public void recordPreprocessingLeaderTime(int version,
 double latencyMs)

Overrides:

recordPreprocessingLeaderTime in class IngestionOtelStats

recordPreprocessingInternalTime

public void recordPreprocessingInternalTime(int version,
 double latencyMs)

Overrides:

recordPreprocessingInternalTime in class IngestionOtelStats

recordProducerTime

public void recordProducerTime(int version,
 double latencyMs)

Overrides:

recordProducerTime in class IngestionOtelStats

recordBatchProcessingRequestCount

public void recordBatchProcessingRequestCount(int version,
 long value)

Overrides:

recordBatchProcessingRequestCount in class IngestionOtelStats

recordBatchProcessingRequestRecordCount

public void recordBatchProcessingRequestRecordCount(int version,
 long value)

Overrides:

recordBatchProcessingRequestRecordCount in class IngestionOtelStats

recordBatchProcessingRequestErrorCount

public void recordBatchProcessingRequestErrorCount(int version,
 long value)

Overrides:

recordBatchProcessingRequestErrorCount in class IngestionOtelStats

recordBatchProcessingRequestTime

public void recordBatchProcessingRequestTime(int version,
 double latencyMs)

Overrides:

recordBatchProcessingRequestTime in class IngestionOtelStats

recordDcrTotalCount

public void recordDcrTotalCount(int version,
 long value)

Overrides:

recordDcrTotalCount in class IngestionOtelStats

recordDuplicateKeyUpdateCount

public void recordDuplicateKeyUpdateCount(int version,
 long value)

Overrides:

recordDuplicateKeyUpdateCount in class IngestionOtelStats

recordRecordsConsumed

public void recordRecordsConsumed(int version,
 ReplicaType replicaType,
 long value)

Overrides:

recordRecordsConsumed in class IngestionOtelStats

recordRecordsProduced

public void recordRecordsProduced(int version,
 ReplicaType replicaType,
 long value)

Overrides:

recordRecordsProduced in class IngestionOtelStats

recordBytesConsumed

public void recordBytesConsumed(int version,
 ReplicaType replicaType,
 long value)

Overrides:

recordBytesConsumed in class IngestionOtelStats

recordBytesProduced

public void recordBytesProduced(int version,
 ReplicaType replicaType,
 long value)

Overrides:

recordBytesProduced in class IngestionOtelStats

recordProducerCallbackTime

public void recordProducerCallbackTime(int version,
 ReplicaType replicaType,
 double latencyMs)

Overrides:

recordProducerCallbackTime in class IngestionOtelStats

recordDcrEventCount

public void recordDcrEventCount(int version,
 VeniceDCREvent event,
 long value)

Overrides:

recordDcrEventCount in class IngestionOtelStats

recordTimeBetweenComponents

public void recordTimeBetweenComponents(int version,
 VeniceIngestionSourceComponent sourceComponent,
 VeniceIngestionDestinationComponent destComponent,
 double latencyMs)

Overrides:

recordTimeBetweenComponents in class IngestionOtelStats

recordRtRecordsConsumed

public void recordRtRecordsConsumed(int version,
 String sourceRegion,
 VeniceRegionLocality regionLocality,
 long count)

Overrides:

recordRtRecordsConsumed in class IngestionOtelStats

recordRtBytesConsumed

public void recordRtBytesConsumed(int version,
 String sourceRegion,
 VeniceRegionLocality regionLocality,
 long bytes)

Overrides:

recordRtBytesConsumed in class IngestionOtelStats

recordConsumerQueuePutTime

public void recordConsumerQueuePutTime(int version,
 double latencyMs)

Overrides:

recordConsumerQueuePutTime in class IngestionOtelStats

recordStorageEnginePutTime

public void recordStorageEnginePutTime(int version,
 double latencyMs)

Overrides:

recordStorageEnginePutTime in class IngestionOtelStats

recordStorageEngineDeleteTime

public void recordStorageEngineDeleteTime(int version,
 double latencyMs)

Overrides:

recordStorageEngineDeleteTime in class IngestionOtelStats

recordConsumerActionTime

public void recordConsumerActionTime(int version,
 double latencyMs)

Overrides:

recordConsumerActionTime in class IngestionOtelStats

recordLongRunningTaskCheckTime

public void recordLongRunningTaskCheckTime(int version,
 double latencyMs)

Overrides:

recordLongRunningTaskCheckTime in class IngestionOtelStats

recordViewWriterProduceTime

public void recordViewWriterProduceTime(int version,
 double latencyMs)

Overrides:

recordViewWriterProduceTime in class IngestionOtelStats

recordViewWriterAckTime

public void recordViewWriterAckTime(int version,
 double latencyMs)

Overrides:

recordViewWriterAckTime in class IngestionOtelStats

recordProducerEnqueueTime

public void recordProducerEnqueueTime(int version,
 double latencyMs)

Overrides:

recordProducerEnqueueTime in class IngestionOtelStats

recordProducerCompressTime

public void recordProducerCompressTime(int version,
 double latencyMs)

Overrides:

recordProducerCompressTime in class IngestionOtelStats

recordProducerSynchronizeTime

public void recordProducerSynchronizeTime(int version,
 double latencyMs)

Overrides:

recordProducerSynchronizeTime in class IngestionOtelStats

recordPartialUpdateTime

public void recordPartialUpdateTime(int version,
 VenicePartialUpdateOperation op,
 double latencyMs)

Overrides:

recordPartialUpdateTime in class IngestionOtelStats

recordDcrLookupTime

public void recordDcrLookupTime(int version,
 VeniceRecordType recordType,
 double latencyMs)

Overrides:

recordDcrLookupTime in class IngestionOtelStats

recordDcrMergeTime

public void recordDcrMergeTime(int version,
 VeniceDCROperation op,
 double latencyMs)

Overrides:

recordDcrMergeTime in class IngestionOtelStats

recordUnexpectedMessageCount

public void recordUnexpectedMessageCount(int version,
 long value)

Overrides:

recordUnexpectedMessageCount in class IngestionOtelStats

recordStoreMetadataInconsistentCount

public void recordStoreMetadataInconsistentCount(int version,
 long value)

Overrides:

recordStoreMetadataInconsistentCount in class IngestionOtelStats

recordResubscriptionFailureCount

public void recordResubscriptionFailureCount(int version,
 long value)

Overrides:

recordResubscriptionFailureCount in class IngestionOtelStats

recordPartialUpdateCacheHitCount

public void recordPartialUpdateCacheHitCount(int version,
 long value)

Overrides:

recordPartialUpdateCacheHitCount in class IngestionOtelStats

recordChecksumVerificationFailureCount

public void recordChecksumVerificationFailureCount(int version,
 long value)

Overrides:

recordChecksumVerificationFailureCount in class IngestionOtelStats

recordIngestionFailureCount

public void recordIngestionFailureCount(int version,
 VeniceIngestionFailureReason reason,
 long value)

Overrides:

recordIngestionFailureCount in class IngestionOtelStats

recordDcrLookupCacheHitCount

public void recordDcrLookupCacheHitCount(int version,
 VeniceRecordType recordType,
 long value)

Overrides:

recordDcrLookupCacheHitCount in class IngestionOtelStats

recordBytesConsumedAsUncompressedSize

public void recordBytesConsumedAsUncompressedSize(int version,
 long bytes)

Overrides:

recordBytesConsumedAsUncompressedSize in class IngestionOtelStats

recordKeySize

public void recordKeySize(int version,
 long bytes)

Overrides:

recordKeySize in class IngestionOtelStats

recordValueSize

public void recordValueSize(int version,
 long bytes)

Overrides:

recordValueSize in class IngestionOtelStats

recordAssembledSize

public void recordAssembledSize(int version,
 VeniceRecordType recordType,
 long bytes)

Overrides:

recordAssembledSize in class IngestionOtelStats

recordAssembledSizeRatio

public void recordAssembledSizeRatio(int version,
 double ratio)

Overrides:

recordAssembledSizeRatio in class IngestionOtelStats