Package com.linkedin.davinci.kafka.consumer

Class PartitionIngestionSnapshot

java.lang.Object
com.linkedin.davinci.kafka.consumer.PartitionIngestionSnapshot
public class PartitionIngestionSnapshot extends Object
Immutable POJO holding computed rates and averages from a single snapshot interval. Returned by PartitionIngestionMonitor.snapshotAndReset(long).

  • Constructor Details

    • PartitionIngestionSnapshot

      public PartitionIngestionSnapshot(double recordsIngestedPerSec, double bytesIngestedPerSec, double leaderRecordsProducedPerSec, double leaderBytesProducedPerSec, double e2eProcessingLatencyAvgMs, double leaderPreprocessingLatencyAvgMs, double leaderProduceLatencyAvgMs, double leaderCompletionLatencyAvgMs, double leaderCallbackLatencyAvgMs, double storagePutLatencyAvgMs, double valueLookupLatencyAvgMs, double rmdLookupLatencyAvgMs)

  • Method Details

    • getRecordsIngestedPerSec

      public double getRecordsIngestedPerSec()

    • getBytesIngestedPerSec

      public double getBytesIngestedPerSec()

    • getLeaderRecordsProducedPerSec

      public double getLeaderRecordsProducedPerSec()

    • getLeaderBytesProducedPerSec

      public double getLeaderBytesProducedPerSec()

    • getE2eProcessingLatencyAvgMs

      public double getE2eProcessingLatencyAvgMs()

    • getLeaderPreprocessingLatencyAvgMs

      public double getLeaderPreprocessingLatencyAvgMs()

    • getLeaderProduceLatencyAvgMs

      public double getLeaderProduceLatencyAvgMs()

    • getLeaderCompletionLatencyAvgMs

      public double getLeaderCompletionLatencyAvgMs()

    • getLeaderCallbackLatencyAvgMs

      public double getLeaderCallbackLatencyAvgMs()

    • getStoragePutLatencyAvgMs

      public double getStoragePutLatencyAvgMs()

    • getValueLookupLatencyAvgMs

      public double getValueLookupLatencyAvgMs()

    • getRmdLookupLatencyAvgMs

      public double getRmdLookupLatencyAvgMs()