This is an automated email from the ASF dual-hosted git repository.
lostluck pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 972c5eeaaf8 [BEAM-14327] Convert Results to QueryResults directly
(#17398)
972c5eeaaf8 is described below
commit 972c5eeaaf8a0d2c37d90473d6f5320941de871a
Author: Jack McCluskey <[email protected]>
AuthorDate: Fri Apr 22 13:50:47 2022 -0400
[BEAM-14327] Convert Results to QueryResults directly (#17398)
---
sdks/go/pkg/beam/core/metrics/metrics.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/go/pkg/beam/core/metrics/metrics.go
b/sdks/go/pkg/beam/core/metrics/metrics.go
index c7b16f80870..6428d868f7d 100644
--- a/sdks/go/pkg/beam/core/metrics/metrics.go
+++ b/sdks/go/pkg/beam/core/metrics/metrics.go
@@ -514,7 +514,7 @@ func NewResults(
// AllMetrics returns all metrics from a Results instance.
func (mr Results) AllMetrics() QueryResults {
- return QueryResults{mr.counters, mr.distributions, mr.gauges, mr.msecs,
mr.pCols}
+ return QueryResults(mr)
}
// SingleResult interface facilitates metrics query filtering methods.
