diff options
Diffstat (limited to 'internal/mapr/client/aggregate.go')
| -rw-r--r-- | internal/mapr/client/aggregate.go | 10 |
1 files changed, 0 insertions, 10 deletions
diff --git a/internal/mapr/client/aggregate.go b/internal/mapr/client/aggregate.go index e7fcdc6..10b34d4 100644 --- a/internal/mapr/client/aggregate.go +++ b/internal/mapr/client/aggregate.go @@ -1,7 +1,6 @@ package client import ( - "encoding/base64" "strconv" "strings" @@ -75,15 +74,6 @@ func (a *Aggregate) makeFields(parts []string) map[string]string { if len(kv) < 2 { continue } - if kv[0] == "$line" { - decoded, err := base64.StdEncoding.DecodeString(kv[1]) - if err != nil { - logger.Error("Unable to decode $line", kv[1], err) - continue - } - fields[kv[0]] = string(decoded) - continue - } fields[kv[0]] = kv[1] } |