def _flush(self):
        """Purges the buffer and commits all pending values into the estimator."""
        self._buffer.sort()
        self._replace_batch()
        self._buffer = []
        self._compress()
def _flush ( self ) : self . _buffer . sort ( ) self . _replace_batch ( ) self . _buffer = [ ] self . _compress ( )
Purges the buffer and commits all pending values into the estimator.