Package com.linkedin.davinci.stats

Class 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 Detail

      • ASSEMBLED_RECORD_SIZE_RATIO

        public static final java.lang.String ASSEMBLED_RECORD_SIZE_RATIO
        See Also:
        Constant Field Values

      • ASSEMBLED_RECORD_SIZE_IN_BYTES

        public static final java.lang.String ASSEMBLED_RECORD_SIZE_IN_BYTES
        See Also:
        Constant Field Values

      • ASSEMBLED_RMD_SIZE_IN_BYTES

        public static final java.lang.String ASSEMBLED_RMD_SIZE_IN_BYTES
        See Also:
        Constant Field Values

    • Constructor Detail

      • HostLevelIngestionStats

        public HostLevelIngestionStats​(io.tehuti.metrics.MetricsRepository metricsRepository,
                               VeniceServerConfig serverConfig,
                               java.lang.String storeName,
                               HostLevelIngestionStats totalStats,
                               java.util.Map<java.lang.String,​StoreIngestionTask> ingestionTaskMap,
                               Time time)
        Parameters:
        totalStats - the total stats singleton instance, or null if we are constructing the total stats

    • Method Detail

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

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