Searched refs:compactor_stack_ (Results 1 – 4 of 4) sorted by relevance
49 compactor_stack_.Add(value); in Add()57 compactor_stack_.AddWithWeight(value, weight); in AddWeighted()74 quantile_state->set_k(compactor_stack_.k()); in SerializeToProto()88 compactor_stack_.SortCompactorContents(); in SerializeToProto()91 const std::vector<std::vector<int64_t>>& compactors = compactor_stack_.compactors(); in SerializeToProto()103 if (compactor_stack_.IsSamplerOn()) { in SerializeToProto()104 const auto& sampled_item_and_weight = compactor_stack_.sampled_item_and_weight(); in SerializeToProto()111 quantile_state->mutable_sampler()->set_log_capacity(compactor_stack_.lowest_active_level()); in SerializeToProto()131 compactor_stack_.Reset(); in Reset()
36 if (compactor_stack_->random()->UnbiasedUniform(++item_weight_) == 0) { in Add()49 if (compactor_stack_->random()->UnbiasedUniform(item_weight_) < in AddWithWeight()55 if (compactor_stack_->random()->UnbiasedUniform(capacity_) < in AddWithWeight()72 compactor_stack_->AddWithWeight(sampled_item_, item_weight_); in AddSampleToCompactorStackAndRestart()
46 return compactor_stack_.k(); in k()69 return compactor_stack_.IsSamplerOn(); in IsSamplerOn()77 compactor_stack_(inv_eps_, inv_delta, k, in KllQuantile()94 internal::CompactorStack compactor_stack_; variable
37 KllSampler(CompactorStack* compactor_stack) : compactor_stack_(compactor_stack) { in KllSampler()73 CompactorStack* compactor_stack_; variable