diff options
| author | vvvv <[email protected]> | 2025-06-18 11:37:13 +0300 |
|---|---|---|
| committer | vvvv <[email protected]> | 2025-06-18 13:38:30 +0300 |
| commit | fafaf82fef03d47443d3563fb5ea36af8fa71e64 (patch) | |
| tree | 517c43562240391278d797c4793eb9cee8b6986f /yql/essentials/core/histogram/eq_width_histogram.cpp | |
| parent | 06674e69d9005bafa2ac27df970398fd1c389fdf (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.cpp | 28 |
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 |
