1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
from __future__ import absolute_import
import sys
from kafka.metrics.stats.sampled_stat import AbstractSampledStat
class Min(AbstractSampledStat):
"""An AbstractSampledStat that gives the min over its samples."""
def __init__(self):
super(Min, self).__init__(float(sys.maxsize))
def update(self, sample, config, value, now):
sample.value = min(sample.value, value)
def combine(self, samples, config, now):
if not samples:
return float(sys.maxsize)
return float(min(sample.value for sample in samples))
|
