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

    • 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)