Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Histogram Aggregation: Fix bucket detection logic, performance improvements, and benchmark tests #1869

Merged
merged 24 commits into from
Jan 12, 2023
Merged
Show file tree
Hide file tree
Changes from 15 commits
Commits
Show all changes
24 commits
Select commit Hold shift + click to select a range
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions examples/metrics_simple/metrics_ostream.cc
Original file line number Diff line number Diff line change
Expand Up @@ -75,8 +75,8 @@ void initMetrics(const std::string &name)
std::shared_ptr<opentelemetry::sdk::metrics::AggregationConfig> aggregation_config{
new opentelemetry::sdk::metrics::HistogramAggregationConfig};
static_cast<opentelemetry::sdk::metrics::HistogramAggregationConfig *>(aggregation_config.get())
->boundaries_ = std::list<double>{0.0, 50.0, 100.0, 250.0, 500.0, 750.0,
1000.0, 2500.0, 5000.0, 10000.0, 20000.0};
->boundaries_ = std::vector<double>{0.0, 50.0, 100.0, 250.0, 500.0, 750.0,
1000.0, 2500.0, 5000.0, 10000.0, 20000.0};
std::unique_ptr<metric_sdk::View> histogram_view{new metric_sdk::View{
name, "description", metric_sdk::AggregationType::kHistogram, aggregation_config}};
p->AddView(std::move(histogram_instrument_selector), std::move(histogram_meter_selector),
Expand Down
4 changes: 2 additions & 2 deletions exporters/ostream/test/ostream_metric_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -97,14 +97,14 @@ TEST(OStreamMetricsExporter, ExportHistogramPointData)
std::unique_ptr<metric_sdk::PushMetricExporter>(new exportermetrics::OStreamMetricExporter);

metric_sdk::HistogramPointData histogram_point_data{};
histogram_point_data.boundaries_ = std::list<double>{10.1, 20.2, 30.2};
histogram_point_data.boundaries_ = std::vector<double>{10.1, 20.2, 30.2};
histogram_point_data.count_ = 3;
histogram_point_data.counts_ = {200, 300, 400, 500};
histogram_point_data.sum_ = 900.5;
histogram_point_data.min_ = 1.8;
histogram_point_data.max_ = 12.0;
metric_sdk::HistogramPointData histogram_point_data2{};
histogram_point_data2.boundaries_ = std::list<double>{10.0, 20.0, 30.0};
histogram_point_data2.boundaries_ = std::vector<double>{10.0, 20.0, 30.0};
histogram_point_data2.count_ = 3;
histogram_point_data2.counts_ = {200, 300, 400, 500};
histogram_point_data2.sum_ = (int64_t)900;
Expand Down
4 changes: 2 additions & 2 deletions exporters/otlp/test/otlp_metrics_serialization_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -54,11 +54,11 @@ static metrics_sdk::MetricData CreateHistogramAggregationData()
s_data_1.sum_ = 100.2;
s_data_1.count_ = 22;
s_data_1.counts_ = {2, 9, 4, 7};
s_data_1.boundaries_ = std::list<double>({0.0, 10.0, 20.0, 30.0});
s_data_1.boundaries_ = std::vector<double>({0.0, 10.0, 20.0, 30.0});
s_data_2.sum_ = 200.2;
s_data_2.count_ = 20;
s_data_2.counts_ = {0, 8, 5, 7};
s_data_2.boundaries_ = std::list<double>({0.0, 10.0, 20.0, 30.0});
s_data_2.boundaries_ = std::vector<double>({0.0, 10.0, 20.0, 30.0});

data.aggregation_temporality = metrics_sdk::AggregationTemporality::kCumulative;
data.end_ts = opentelemetry::common::SystemTimestamp(std::chrono::system_clock::now());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ class PrometheusExporterUtils
*/
template <typename T>
static void SetData(std::vector<T> values,
const std::list<double> &boundaries,
const std::vector<double> &boundaries,
const std::vector<uint64_t> &counts,
const opentelemetry::sdk::metrics::PointAttributes &labels,
std::chrono::nanoseconds time,
Expand Down Expand Up @@ -104,7 +104,7 @@ class PrometheusExporterUtils
*/
template <typename T>
static void SetValue(std::vector<T> values,
const std::list<double> &boundaries,
const std::vector<double> &boundaries,
const std::vector<uint64_t> &counts,
::prometheus::ClientMetric *metric);
};
Expand Down
4 changes: 2 additions & 2 deletions exporters/prometheus/src/exporter_utils.cc
Original file line number Diff line number Diff line change
Expand Up @@ -221,7 +221,7 @@ void PrometheusExporterUtils::SetData(std::vector<T> values,
*/
template <typename T>
void PrometheusExporterUtils::SetData(std::vector<T> values,
const std::list<double> &boundaries,
const std::vector<double> &boundaries,
const std::vector<uint64_t> &counts,
const metric_sdk::PointAttributes &labels,
std::chrono::nanoseconds time,
Expand Down Expand Up @@ -340,7 +340,7 @@ void PrometheusExporterUtils::SetValue(std::vector<T> values,
*/
template <typename T>
void PrometheusExporterUtils::SetValue(std::vector<T> values,
const std::list<double> &boundaries,
const std::vector<double> &boundaries,
const std::vector<uint64_t> &counts,
prometheus_client::ClientMetric *metric)
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,10 @@

#pragma once

#include <list>
#include "opentelemetry/version.h"

#include <vector>

OPENTELEMETRY_BEGIN_NAMESPACE
namespace sdk
{
Expand All @@ -19,7 +21,7 @@ class AggregationConfig
class HistogramAggregationConfig : public AggregationConfig
{
public:
std::list<double> boundaries_;
std::vector<double> boundaries_;
bool record_min_max_ = true;
};
} // namespace metrics
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -108,6 +108,26 @@ void HistogramDiff(HistogramPointData &current, HistogramPointData &next, Histog
diff.record_min_max_ = false;
}

template <class T>
size_t BucketBinarySearch(T value, std::vector<double> &boundaries)
ThomsonTan marked this conversation as resolved.
Show resolved Hide resolved
{
size_t lower_bound = 0;
size_t upper_bound = boundaries.size();
while (lower_bound != upper_bound)
{
size_t mid = (lower_bound + upper_bound) / 2;
if (value > boundaries[mid])
{
lower_bound = mid + 1;
}
else
{
upper_bound = mid;
}
}
return lower_bound;
}
lalitb marked this conversation as resolved.
Show resolved Hide resolved

} // namespace metrics
} // namespace sdk
OPENTELEMETRY_END_NAMESPACE
18 changes: 9 additions & 9 deletions sdk/include/opentelemetry/sdk/metrics/data/point_data.h
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
#include "opentelemetry/sdk/metrics/instruments.h"
#include "opentelemetry/version.h"

#include <list>
#include <vector>

OPENTELEMETRY_BEGIN_NAMESPACE
namespace sdk
Expand Down Expand Up @@ -55,14 +55,14 @@ class HistogramPointData
HistogramPointData &operator=(HistogramPointData &&) = default;
HistogramPointData(const HistogramPointData &) = default;
HistogramPointData() = default;
HistogramPointData(std::list<double> &boundaries) : boundaries_(boundaries) {}
std::list<double> boundaries_ = {};
ValueType sum_ = {};
ValueType min_ = {};
ValueType max_ = {};
std::vector<uint64_t> counts_ = {};
uint64_t count_ = {};
bool record_min_max_ = true;
HistogramPointData(std::vector<double> &boundaries) : boundaries_(boundaries) {}
std::vector<double> boundaries_ = {};
ValueType sum_ = {};
ValueType min_ = {};
ValueType max_ = {};
std::vector<uint64_t> counts_ = {};
uint64_t count_ = {};
bool record_min_max_ = true;
};

class DropPointData
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@
#include "opentelemetry/sdk/metrics/state/attributes_hashmap.h"
#include "opentelemetry/sdk/metrics/state/metric_collector.h"

#include <list>
lalitb marked this conversation as resolved.
Show resolved Hide resolved
#include <memory>

OPENTELEMETRY_BEGIN_NAMESPACE
Expand Down
58 changes: 25 additions & 33 deletions sdk/src/metrics/aggregation/histogram_aggregation.cc
Original file line number Diff line number Diff line change
Expand Up @@ -2,13 +2,14 @@
// SPDX-License-Identifier: Apache-2.0

#include "opentelemetry/sdk/metrics/aggregation/histogram_aggregation.h"
#include "opentelemetry/version.h"

#include <algorithm>
#include <iomanip>
#include <limits>
#include <memory>
#include "opentelemetry/version.h"

#include <mutex>

OPENTELEMETRY_BEGIN_NAMESPACE
namespace sdk
{
Expand Down Expand Up @@ -59,16 +60,8 @@ void LongHistogramAggregation::Aggregate(int64_t value,
point_data_.min_ = std::min(nostd::get<int64_t>(point_data_.min_), value);
point_data_.max_ = std::max(nostd::get<int64_t>(point_data_.max_), value);
}
size_t index = 0;
for (auto it = point_data_.boundaries_.begin(); it != point_data_.boundaries_.end(); ++it)
{
if (value < *it)
{
point_data_.counts_[index] += 1;
return;
}
index++;
}
size_t index = BucketBinarySearch(value, point_data_.boundaries_);
point_data_.counts_[index] += 1;
}

std::unique_ptr<Aggregation> LongHistogramAggregation::Merge(
Expand All @@ -77,7 +70,10 @@ std::unique_ptr<Aggregation> LongHistogramAggregation::Merge(
auto curr_value = nostd::get<HistogramPointData>(ToPoint());
auto delta_value = nostd::get<HistogramPointData>(
(static_cast<const LongHistogramAggregation &>(delta).ToPoint()));
LongHistogramAggregation *aggr = new LongHistogramAggregation();
HistogramAggregationConfig agg_config;
agg_config.boundaries_ = curr_value.boundaries_;
agg_config.record_min_max_ = record_min_max_;
LongHistogramAggregation *aggr = new LongHistogramAggregation(&agg_config);
HistogramMerge<int64_t>(curr_value, delta_value, aggr->point_data_);
return std::unique_ptr<Aggregation>(aggr);
}
Expand All @@ -87,7 +83,10 @@ std::unique_ptr<Aggregation> LongHistogramAggregation::Diff(const Aggregation &n
auto curr_value = nostd::get<HistogramPointData>(ToPoint());
auto next_value = nostd::get<HistogramPointData>(
(static_cast<const LongHistogramAggregation &>(next).ToPoint()));
LongHistogramAggregation *aggr = new LongHistogramAggregation();
HistogramAggregationConfig agg_config;
agg_config.boundaries_ = curr_value.boundaries_;
agg_config.record_min_max_ = record_min_max_;
LongHistogramAggregation *aggr = new LongHistogramAggregation(&agg_config);
HistogramDiff<int64_t>(curr_value, next_value, aggr->point_data_);
return std::unique_ptr<Aggregation>(aggr);
}
Expand All @@ -107,8 +106,8 @@ DoubleHistogramAggregation::DoubleHistogramAggregation(const AggregationConfig *
}
else
{
point_data_.boundaries_ =
std::list<double>{0.0, 5.0, 10.0, 25.0, 50.0, 75.0, 100.0, 250.0, 500.0, 1000.0};
point_data_.boundaries_ = {0.0, 5.0, 10.0, 25.0, 50.0, 75.0, 100.0, 250.0,
500.0, 750.0, 1000.0, 2500.0, 5000.0, 7500.0, 10000.0};
}
if (ac)
{
Expand Down Expand Up @@ -141,16 +140,8 @@ void DoubleHistogramAggregation::Aggregate(double value,
point_data_.min_ = std::min(nostd::get<double>(point_data_.min_), value);
point_data_.max_ = std::max(nostd::get<double>(point_data_.max_), value);
}
size_t index = 0;
for (auto it = point_data_.boundaries_.begin(); it != point_data_.boundaries_.end(); ++it)
{
if (value < *it)
{
point_data_.counts_[index] += 1;
return;
}
index++;
}
size_t index = BucketBinarySearch(value, point_data_.boundaries_);
point_data_.counts_[index] += 1;
}

std::unique_ptr<Aggregation> DoubleHistogramAggregation::Merge(
Expand All @@ -159,12 +150,10 @@ std::unique_ptr<Aggregation> DoubleHistogramAggregation::Merge(
auto curr_value = nostd::get<HistogramPointData>(ToPoint());
auto delta_value = nostd::get<HistogramPointData>(
(static_cast<const DoubleHistogramAggregation &>(delta).ToPoint()));
std::shared_ptr<AggregationConfig> aggregation_config(new HistogramAggregationConfig);
static_cast<opentelemetry::sdk::metrics::HistogramAggregationConfig *>(aggregation_config.get())
->boundaries_ = curr_value.boundaries_;
static_cast<opentelemetry::sdk::metrics::HistogramAggregationConfig *>(aggregation_config.get())
->record_min_max_ = record_min_max_;
DoubleHistogramAggregation *aggr = new DoubleHistogramAggregation(aggregation_config.get());
HistogramAggregationConfig agg_config;
agg_config.boundaries_ = curr_value.boundaries_;
agg_config.record_min_max_ = record_min_max_;
DoubleHistogramAggregation *aggr = new DoubleHistogramAggregation(&agg_config);
HistogramMerge<double>(curr_value, delta_value, aggr->point_data_);
return std::unique_ptr<Aggregation>(aggr);
}
Expand All @@ -175,7 +164,10 @@ std::unique_ptr<Aggregation> DoubleHistogramAggregation::Diff(
auto curr_value = nostd::get<HistogramPointData>(ToPoint());
auto next_value = nostd::get<HistogramPointData>(
(static_cast<const DoubleHistogramAggregation &>(next).ToPoint()));
DoubleHistogramAggregation *aggr = new DoubleHistogramAggregation();
HistogramAggregationConfig agg_config;
agg_config.boundaries_ = curr_value.boundaries_;
agg_config.record_min_max_ = record_min_max_;
DoubleHistogramAggregation *aggr = new DoubleHistogramAggregation(&agg_config);
HistogramDiff<double>(curr_value, next_value, aggr->point_data_);
return std::unique_ptr<Aggregation>(aggr);
}
Expand Down
32 changes: 32 additions & 0 deletions sdk/test/metrics/BUILD
Original file line number Diff line number Diff line change
Expand Up @@ -47,6 +47,22 @@ cc_test(
],
)

cc_test(
name = "histogram_test",
srcs = [
"histogram_test.cc",
],
tags = [
"metrics",
"test",
],
deps = [
"//sdk/src/metrics",
"//sdk/src/resource",
"@com_google_googletest//:gtest_main",
],
)

cc_test(
name = "view_registry_test",
srcs = [
Expand Down Expand Up @@ -265,3 +281,19 @@ otel_cc_benchmark(
"//sdk/src/metrics",
],
)

otel_cc_benchmark(
name = "histogram_aggregation_benchmark",
srcs = [
"histogram_aggregation_benchmark.cc",
],
tags = [
"benchmark",
"metrics",
"test",
],
deps = [
"//sdk/src/metrics",
"//sdk/src/resource",
],
)
8 changes: 8 additions & 0 deletions sdk/test/metrics/CMakeLists.txt
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@ foreach(
aggregation_test
attributes_processor_test
attributes_hashmap_test
histogram_test
sync_metric_storage_counter_test
sync_metric_storage_histogram_test
sync_metric_storage_up_down_counter_test
Expand Down Expand Up @@ -37,6 +38,13 @@ if(WITH_BENCHMARK)
add_executable(attributes_hashmap_benchmark attributes_hashmap_benchmark.cc)
target_link_libraries(attributes_hashmap_benchmark benchmark::benchmark
${CMAKE_THREAD_LIBS_INIT} opentelemetry_common)

add_executable(histogram_aggregation_benchmark
histogram_aggregation_benchmark.cc)
target_link_libraries(
histogram_aggregation_benchmark benchmark::benchmark
${CMAKE_THREAD_LIBS_INIT} opentelemetry_common opentelemetry_metrics
opentelemetry_resources)
endif()

add_subdirectory(exemplar)
Loading