summaryrefslogtreecommitdiffstats
path: root/yql/essentials/core/histogram/eq_width_histogram.cpp
diff options
context:
space:
mode:
authorvvvv <[email protected]>2025-06-18 11:37:13 +0300
committervvvv <[email protected]>2025-06-18 13:38:30 +0300
commitfafaf82fef03d47443d3563fb5ea36af8fa71e64 (patch)
tree517c43562240391278d797c4793eb9cee8b6986f /yql/essentials/core/histogram/eq_width_histogram.cpp
parent06674e69d9005bafa2ac27df970398fd1c389fdf (diff)
YQL-20086 core
commit_hash:af5d81d51befa5cee331fbed69e7e5db2014a260
Diffstat (limited to 'yql/essentials/core/histogram/eq_width_histogram.cpp')
-rw-r--r--yql/essentials/core/histogram/eq_width_histogram.cpp28
1 files changed, 14 insertions, 14 deletions
diff --git a/yql/essentials/core/histogram/eq_width_histogram.cpp b/yql/essentials/core/histogram/eq_width_histogram.cpp
index 3c5a452fdbd..b83fc1638c6 100644
--- a/yql/essentials/core/histogram/eq_width_histogram.cpp
+++ b/yql/essentials/core/histogram/eq_width_histogram.cpp
@@ -3,7 +3,7 @@
namespace NKikimr {
TEqWidthHistogram::TEqWidthHistogram(ui32 numBuckets, EHistogramValueType valueType)
- : ValueType(valueType), Buckets(numBuckets) {
+ : ValueType_(valueType), Buckets_(numBuckets) {
// Exptected at least one bucket for histogram.
Y_ASSERT(numBuckets >= 1);
}
@@ -13,11 +13,11 @@ TEqWidthHistogram::TEqWidthHistogram(const char *str, ui64 size) {
const ui32 numBuckets = *reinterpret_cast<const ui32 *>(str);
Y_ABORT_UNLESS(GetBinarySize(numBuckets) == size);
ui32 offset = sizeof(ui32);
- ValueType = *reinterpret_cast<const EHistogramValueType *>(str + offset);
+ ValueType_ = *reinterpret_cast<const EHistogramValueType *>(str + offset);
offset += sizeof(EHistogramValueType);
- Buckets = TVector<TBucket>(numBuckets);
+ Buckets_ = TVector<TBucket>(numBuckets);
for (ui32 i = 0; i < numBuckets; ++i) {
- std::memcpy(&Buckets[i], reinterpret_cast<const char *>(str + offset), sizeof(TBucket));
+ std::memcpy(&Buckets_[i], reinterpret_cast<const char *>(str + offset), sizeof(TBucket));
offset += sizeof(TBucket);
}
}
@@ -38,36 +38,36 @@ std::unique_ptr<char> TEqWidthHistogram::Serialize(ui64 &binarySize) const {
std::memcpy(binaryData.get(), &numBuckets, sizeof(ui32));
offset += sizeof(ui32);
// 1 byte - values type.
- std::memcpy(binaryData.get() + offset, &ValueType, sizeof(EHistogramValueType));
+ std::memcpy(binaryData.get() + offset, &ValueType_, sizeof(EHistogramValueType));
offset += sizeof(EHistogramValueType);
// Buckets.
for (ui32 i = 0; i < numBuckets; ++i) {
- std::memcpy(binaryData.get() + offset, &Buckets[i], sizeof(TBucket));
+ std::memcpy(binaryData.get() + offset, &Buckets_[i], sizeof(TBucket));
offset += sizeof(TBucket);
}
return binaryData;
}
TEqWidthHistogramEstimator::TEqWidthHistogramEstimator(std::shared_ptr<TEqWidthHistogram> histogram)
- : Histogram(histogram) {
- const auto numBuckets = Histogram->GetNumBuckets();
- PrefixSum = TVector<ui64>(numBuckets);
- SuffixSum = TVector<ui64>(numBuckets);
+ : Histogram_(histogram) {
+ const auto numBuckets = Histogram_->GetNumBuckets();
+ PrefixSum_ = TVector<ui64>(numBuckets);
+ SuffixSum_ = TVector<ui64>(numBuckets);
CreatePrefixSum(numBuckets);
CreateSuffixSum(numBuckets);
}
void TEqWidthHistogramEstimator::CreatePrefixSum(ui32 numBuckets) {
- PrefixSum[0] = Histogram->GetNumElementsInBucket(0);
+ PrefixSum_[0] = Histogram_->GetNumElementsInBucket(0);
for (ui32 i = 1; i < numBuckets; ++i) {
- PrefixSum[i] = PrefixSum[i - 1] + Histogram->GetNumElementsInBucket(i);
+ PrefixSum_[i] = PrefixSum_[i - 1] + Histogram_->GetNumElementsInBucket(i);
}
}
void TEqWidthHistogramEstimator::CreateSuffixSum(ui32 numBuckets) {
- SuffixSum[numBuckets - 1] = Histogram->GetNumElementsInBucket(numBuckets - 1);
+ SuffixSum_[numBuckets - 1] = Histogram_->GetNumElementsInBucket(numBuckets - 1);
for (i32 i = static_cast<i32>(numBuckets) - 2; i >= 0; --i) {
- SuffixSum[i] = SuffixSum[i + 1] + Histogram->GetNumElementsInBucket(i);
+ SuffixSum_[i] = SuffixSum_[i + 1] + Histogram_->GetNumElementsInBucket(i);
}
}
} // namespace NKikimr