shlld.py

from __future__ import absolute_import

import cPickle
import zlib
from hyperloglog import SlidingHyperLogLog

def shlld_from_string(string, error_rate, window_count):
  lpfm = cPickle.loads(zlib.decompress(string)) if string else None

  return SlidingHyperLogLog(
    error_rate=error_rate,
    window=window_count,
    lpfm=lpfm,
  )

def shlld_to_string(hyperlog):
  return zlib.compress(cPickle.dumps(hyperlog.LPFM))