diff options
| author | Paul Bütow <pbuetow@mimecast.com> | 2020-01-20 18:41:05 +0000 |
|---|---|---|
| committer | Paul Bütow <pbuetow@mimecast.com> | 2020-01-21 14:35:23 +0000 |
| commit | c128865c4c7411c29a59fca9a3a2f95537686d7b (patch) | |
| tree | 193bccc70d942c8b70cc93fae2670263701e43aa /mapr/logformat/default.go | |
| parent | 3755a9911ecb05886577095f2b8cc8b9e4066a3a (diff) | |
Move commands to cmd/ and move internal dependencies to internal/
Diffstat (limited to 'mapr/logformat/default.go')
| -rw-r--r-- | mapr/logformat/default.go | 23 |
1 files changed, 0 insertions, 23 deletions
diff --git a/mapr/logformat/default.go b/mapr/logformat/default.go deleted file mode 100644 index f0df5bc..0000000 --- a/mapr/logformat/default.go +++ /dev/null @@ -1,23 +0,0 @@ -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 -} |
