Skip to content

Commit

Permalink
Remove a comment
Browse files Browse the repository at this point in the history
  • Loading branch information
ronensc committed Mar 30, 2022
1 parent 03842db commit 4544452
Showing 1 changed file with 7 additions and 8 deletions.
15 changes: 7 additions & 8 deletions pkg/pipeline/extract/aggregate/aggregate.go
Original file line number Diff line number Diff line change
Expand Up @@ -191,15 +191,14 @@ func (aggregate Aggregate) GetMetrics() []config.GenericMap {
var metrics []config.GenericMap
for _, group := range aggregate.Groups {
metrics = append(metrics, config.GenericMap{
"name": aggregate.Definition.Name,
"operation": aggregate.Definition.Operation,
"record_key": aggregate.Definition.RecordKey,
"by": strings.Join(aggregate.Definition.By, ","),
"aggregate": string(group.normalizedValues),
"total_value": fmt.Sprintf("%f", group.totalValue),
// TODO: change to snake_case
"recent_raw_values": group.recentRawValues,
"name": aggregate.Definition.Name,
"operation": aggregate.Definition.Operation,
"record_key": aggregate.Definition.RecordKey,
"by": strings.Join(aggregate.Definition.By, ","),
"aggregate": string(group.normalizedValues),
"total_value": fmt.Sprintf("%f", group.totalValue),
"total_count": fmt.Sprintf("%d", group.totalCount),
"recent_raw_values": group.recentRawValues,
"recent_op_value": group.recentOpValue,
"recent_count": group.recentCount,
strings.Join(aggregate.Definition.By, "_"): string(group.normalizedValues),
Expand Down

0 comments on commit 4544452

Please sign in to comment.