blob: f0df5bc31627ae075e4849aced36387c537d3cbc (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
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
}
|
