From c128865c4c7411c29a59fca9a3a2f95537686d7b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Paul=20B=C3=BCtow?= <pbuetow@mimecast.com>
Date: Mon, 20 Jan 2020 18:41:05 +0000
Subject: Move commands to cmd/ and move internal dependencies to internal/

---
 internal/mapr/logformat/default.go | 23 +++++++++++++++++++++++
 1 file changed, 23 insertions(+)
 create mode 100644 internal/mapr/logformat/default.go

(limited to 'internal/mapr/logformat/default.go')

diff --git a/internal/mapr/logformat/default.go b/internal/mapr/logformat/default.go
new file mode 100644
index 0000000..f0df5bc
--- /dev/null
+++ b/internal/mapr/logformat/default.go
@@ -0,0 +1,23 @@
+package logformat
+
+import (
+	"errors"
+	"strings"
+)
+
+// MakeFieldsDEFAULT is the default log file mapreduce parser.
+func (p *Parser) MakeFieldsDEFAULT(maprLine string) (map[string]string, error) {
+	fields := make(map[string]string, 20)
+	splitted := strings.Split(maprLine, "|")
+
+	fields["$hostname"] = p.hostname
+
+	for _, kv := range splitted {
+		keyAndValue := strings.SplitN(kv, "=", 2)
+		if len(keyAndValue) != 2 {
+			return fields, errors.New("Error parsing mapr token: " + kv)
+		}
+		fields[strings.ToLower(keyAndValue[0])] = keyAndValue[1]
+	}
+	return fields, nil
+}
-- 
cgit v1.2.3