kazusa
/
skywalking
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix checking OTEL DataPointFlags (#12682)

This commit is contained in:
kezhenxu94 2024-10-08 20:59:42 +08:00 committed by GitHub
parent 36e34672ed
commit 180ca71375
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
oap-server/server-receiver-plugin/otel-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/otel/otlp/OpenTelemetryMetricRequestProcessor.java
View File

@ -238,8 +238,8 @@ public class OpenTelemetryMetricRequestProcessor implements Service {
final Map<String, String> nodeLabels,
final io.opentelemetry.proto.metrics.v1.Metric metric) {
if (metric.hasGauge()) {
return metric.getGauge().getDataPointsList().stream().filter(point -> point.getFlags()
!= DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE)
return metric.getGauge().getDataPointsList().stream().filter(point ->
(point.getFlags() & DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE) != DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE)
.map(point -> new Gauge(
metric.getName(),
mergeLabels(
@ -259,8 +259,8 @@ public class OpenTelemetryMetricRequestProcessor implements Service {
}
if (sum
.getAggregationTemporality() == AGGREGATION_TEMPORALITY_DELTA) {
return sum.getDataPointsList().stream().filter(point -> point.getFlags()
!= DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE)
return sum.getDataPointsList().stream().filter(point ->
(point.getFlags() & DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE) != DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE)
.map(point -> new Gauge(
metric.getName(),
mergeLabels(
@ -273,8 +273,8 @@ public class OpenTelemetryMetricRequestProcessor implements Service {
));
}
if (sum.getIsMonotonic()) {
return sum.getDataPointsList().stream().filter(point -> point.getFlags()
!= DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE)
return sum.getDataPointsList().stream().filter(point ->
(point.getFlags() & DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE) != DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE)
.map(point -> new Counter(
metric.getName(),
mergeLabels(
@ -286,8 +286,8 @@ public class OpenTelemetryMetricRequestProcessor implements Service {
point.getTimeUnixNano() / 1000000
));
} else {
return sum.getDataPointsList().stream().filter(point -> point.getFlags()
!= DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE)
return sum.getDataPointsList().stream().filter(point ->
(point.getFlags() & DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE) != DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE)
.map(point -> new Gauge(
metric.getName(),
mergeLabels(
@ -301,8 +301,8 @@ public class OpenTelemetryMetricRequestProcessor implements Service {
}
}
if (metric.hasHistogram()) {
return metric.getHistogram().getDataPointsList().stream().filter(point -> point.getFlags()
!= DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE)
return metric.getHistogram().getDataPointsList().stream().filter(point ->
(point.getFlags() & DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE) != DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE)
.map(point -> new Histogram(
metric.getName(),
mergeLabels(
@ -319,8 +319,8 @@ public class OpenTelemetryMetricRequestProcessor implements Service {
));
}
if (metric.hasExponentialHistogram()) {
return metric.getExponentialHistogram().getDataPointsList().stream().filter(point -> point.getFlags()
!= DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE)
return metric.getExponentialHistogram().getDataPointsList().stream().filter(point ->
(point.getFlags() & DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE) != DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE)
.map(point -> new Histogram(
metric.getName(),
mergeLabels(
@ -340,8 +340,8 @@ public class OpenTelemetryMetricRequestProcessor implements Service {
));
}
if (metric.hasSummary()) {
return metric.getSummary().getDataPointsList().stream().filter(point -> point.getFlags()
!= DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE)
return metric.getSummary().getDataPointsList().stream().filter(point ->
(point.getFlags() & DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE) != DataPointFlags.FLAG_NO_RECORDED_VALUE_VALUE)
.map(point -> new Summary(
metric.getName(),
mergeLabels(