in sketches/Sampler.py [0:0]
def add(self, item, weight):
self.processed += 1
if item in self.item_dict:
topk_item = self.item_dict[item]
#print("initinc", topk_item.priority, topk_item.count, item, weight)
nhat = topk_item.nhat()
topk_item.priority *= nhat / (nhat+1)
topk_item.count += 1
#print("inc", topk_item.priority, topk_item.count, item, weight)
if not self.is_infreq(item):
self.heavy_set.add(item)
return
R = self.priority(item, weight)
#print("add", item, R)
if R < self.threshold:
entry = TopKItem(R, item, weight, self.threshold, 0)
self.buffer.append(entry)
self.item_dict[item] = entry
self.compact()