<s> import sys <EOL> from kafka . metrics . stats . sampled_stat import AbstractSampledStat <EOL> class Min ( AbstractSampledStat ) : <EOL> """<STR_LIT>""" <EOL> def __init__ ( self ) : <EOL> super ( Min , self ) . __init__ ( float ( sys . maxsize ) ) <EOL> def update ( self , sample , config , value , now ) : <EOL> sample . value = min ( sample . value , value ) <EOL> def combine ( self , samples , config , now ) : <EOL> if not samples : <EOL> return float ( sys . maxsize ) <EOL> return float ( min ( sample . value for sample in samples ) ) </s>
