Package com.linkedin.davinci.stats

Class HostLevelIngestionStats

java.lang.Object
com.linkedin.venice.stats.AbstractVeniceStats
com.linkedin.davinci.stats.HostLevelIngestionStats
public class HostLevelIngestionStats extends AbstractVeniceStats
This class contains stats for stats on the storage node host level. Stats inside this class can either: (1) Total only: The stat indicate total number of all the stores on this host. (2) Per store only: The stat is registered for each store on this host. (3) Per store and total: The stat is registered for each store on this host and the total number for this host.

  • Field Details

  • Constructor Details

  • Method Details

    • recordTotalBytesConsumed

      public void recordTotalBytesConsumed(long bytes)
      Record a host-level byte consumption rate across all store versions

    • recordTotalRecordsConsumed

      public void recordTotalRecordsConsumed()
      Record a host-level record consumption rate across all store versions

    • recordTotalBlobTransferBytesSend

      public void recordTotalBlobTransferBytesSend(long bytes)
      Records the total number of bytes sent during blob transfer operations at the host level. This metric aggregates blob transfer send operations across all store versions on the host.
      Parameters:
      bytes - the number of bytes sent

    • recordTotalBlobTransferBytesReceived

      public void recordTotalBlobTransferBytesReceived(long bytes)
      Records the total number of bytes received during blob transfer operations at the host level. This metric aggregates blob transfer receive operations across all store versions on the host.
      Parameters:
      bytes - the number of bytes received

    • recordTotalBytesReadFromKafkaAsUncompressedSize

      public void recordTotalBytesReadFromKafkaAsUncompressedSize(long bytes)

    • recordStorageQuotaUsed

      public void recordStorageQuotaUsed(double quotaUsed)

    • recordConsumerRecordsQueuePutLatency

      public void recordConsumerRecordsQueuePutLatency(double latency, long currentTimeMs)

    • recordViewProducerLatency

      public void recordViewProducerLatency(double latency)

    • recordViewProducerAckLatency

      public void recordViewProducerAckLatency(double latency)

    • recordUnexpectedMessage

      public void recordUnexpectedMessage()

    • recordInconsistentStoreMetadata

      public void recordInconsistentStoreMetadata()

    • recordKeySize

      public void recordKeySize(long bytes, long currentTimeMs)

    • recordValueSize

      public void recordValueSize(long bytes, long currentTimeMs)

    • recordAssembledRecordSize

      public void recordAssembledRecordSize(long bytes, long currentTimeMs)

    • recordAssembledRecordSizeRatio

      public void recordAssembledRecordSizeRatio(double ratio, long currentTimeMs)

    • recordAssembledRmdSize

      public void recordAssembledRmdSize(long bytes, long currentTimeMs)

    • recordIngestionFailure

      public void recordIngestionFailure()

    • recordResubscriptionFailure

      public void recordResubscriptionFailure()

    • recordLeaderProducerSynchronizeLatency

      public void recordLeaderProducerSynchronizeLatency(double latency)

    • recordWriteComputeLookUpLatency

      public void recordWriteComputeLookUpLatency(double latency)

    • recordIngestionValueBytesLookUpLatency

      public void recordIngestionValueBytesLookUpLatency(double latency, long currentTime)

    • recordIngestionValueBytesCacheHitCount

      public void recordIngestionValueBytesCacheHitCount(long currentTime)

    • recordIngestionReplicationMetadataLookUpLatency

      public void recordIngestionReplicationMetadataLookUpLatency(double latency, long currentTimeMs)

    • recordIngestionActiveActivePutLatency

      public void recordIngestionActiveActivePutLatency(double latency)

    • recordIngestionActiveActiveUpdateLatency

      public void recordIngestionActiveActiveUpdateLatency(double latency)

    • recordIngestionActiveActiveDeleteLatency

      public void recordIngestionActiveActiveDeleteLatency(double latency)

    • recordWriteComputeUpdateLatency

      public void recordWriteComputeUpdateLatency(double latency)

    • recordProcessConsumerActionLatency

      public void recordProcessConsumerActionLatency(double latency)

    • recordCheckLongRunningTasksLatency

      public void recordCheckLongRunningTasksLatency(double latency)

    • recordStorageEnginePutLatency

      public void recordStorageEnginePutLatency(double latency, long currentTimeMs)

    • recordStorageEngineDeleteLatency

      public void recordStorageEngineDeleteLatency(double latency, long currentTimeMs)

    • recordWriteComputeCacheHitCount

      public void recordWriteComputeCacheHitCount()

    • recordIngestionReplicationMetadataCacheHitCount

      public void recordIngestionReplicationMetadataCacheHitCount(long currentTimeMs)

    • recordUpdateIgnoredDCR

      public void recordUpdateIgnoredDCR()

    • recordTombstoneCreatedDCR

      public void recordTombstoneCreatedDCR()

    • recordTotalLeaderBytesConsumed

      public void recordTotalLeaderBytesConsumed(long bytes)

    • recordTotalLeaderRecordsConsumed

      public void recordTotalLeaderRecordsConsumed()

    • recordTotalFollowerBytesConsumed

      public void recordTotalFollowerBytesConsumed(long bytes)

    • recordTotalFollowerRecordsConsumed

      public void recordTotalFollowerRecordsConsumed()

    • recordTotalRegionHybridBytesConsumed

      public void recordTotalRegionHybridBytesConsumed(int regionId, long bytes, long currentTimeMs)

    • recordTotalLeaderBytesProduced

      public void recordTotalLeaderBytesProduced(long bytes)

    • recordTotalLeaderRecordsProduced

      public void recordTotalLeaderRecordsProduced(int count)

    • recordChecksumVerificationFailure

      public void recordChecksumVerificationFailure()

    • recordTimestampRegressionDCRError

      public void recordTimestampRegressionDCRError()

    • recordOffsetRegressionDCRError

      public void recordOffsetRegressionDCRError()

    • recordLeaderProduceLatency

      public void recordLeaderProduceLatency(double latency)

    • recordLeaderCompressLatency

      public void recordLeaderCompressLatency(double latency)

    • recordBatchProcessingRequest

      public void recordBatchProcessingRequest(int size)

    • recordBatchProcessingRequestError

      public void recordBatchProcessingRequestError()

    • recordBatchProcessingRequestLatency

      public void recordBatchProcessingRequestLatency(double latency)