blob: 9ccd23350fb168ffc7bb3a4f34666dfc7eae2ba7 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
package clients
import (
"fmt"
"github.com/mimecast/dtail/internal/mapr"
)
func maprRegexForQuery(query *mapr.Query) string {
if query == nil {
return "."
}
switch query.Table {
case "", ".":
return "."
case "*":
return "\\|MAPREDUCE:\\|"
default:
return fmt.Sprintf("\\|MAPREDUCE:%s\\|", query.Table)
}
}
func maprRegexFromQueryString(queryStr string) (*mapr.Query, string, error) {
query, err := mapr.NewQuery(queryStr)
if err != nil {
return nil, "", err
}
return query, maprRegexForQuery(query), nil
}
|
