diff options
Diffstat (limited to 'internal/mapr/aggregateset.go')
| -rw-r--r-- | internal/mapr/aggregateset.go | 14 |
1 files changed, 4 insertions, 10 deletions
diff --git a/internal/mapr/aggregateset.go b/internal/mapr/aggregateset.go index d8705bd..a6cc6eb 100644 --- a/internal/mapr/aggregateset.go +++ b/internal/mapr/aggregateset.go @@ -2,7 +2,6 @@ package mapr import ( "context" - "encoding/base64" "fmt" "strconv" "strings" @@ -71,25 +70,20 @@ func (s *AggregateSet) Serialize(ctx context.Context, groupKey string, ch chan<- var sb strings.Builder sb.WriteString(groupKey) - sb.WriteString("|") - sb.WriteString(fmt.Sprintf("%d|", s.Samples)) + sb.WriteString("ā") + sb.WriteString(fmt.Sprintf("%dā", s.Samples)) for k, v := range s.FValues { sb.WriteString(k) sb.WriteString("=") - sb.WriteString(fmt.Sprintf("%v|", v)) + sb.WriteString(fmt.Sprintf("%vā", v)) } for k, v := range s.SValues { sb.WriteString(k) sb.WriteString("=") - if k == "$line" { - sb.WriteString(base64.StdEncoding.EncodeToString([]byte(v))) - sb.WriteString("|") - continue - } sb.WriteString(v) - sb.WriteString("|") + sb.WriteString("ā") } select { |