From 93a0be36c0af18cedda95456409608993f881e2d Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Fri, 3 Jul 2020 14:13:13 +0100 Subject: bump up version to 3.0.0. can run continuous background mapreduce queries, useful for log file monitorig for example. breaking protocol change which allows to mapreduce aggreate messages containing the default field separator |. add of more unit tests. add logformat mapreduce query keyword. add set mapreduce clause support and support to evaluate built-in functions such as md5sum() and maskdigits(). --- internal/mapr/aggregateset.go | 14 ++++---------- 1 file changed, 4 insertions(+), 10 deletions(-) (limited to 'internal/mapr/aggregateset.go') 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 { -- cgit v1.2.3