1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.hadoop.chukwa.extraction.engine;
19
20
21 import java.util.regex.Matcher;
22 import java.util.regex.Pattern;
23
24 import org.apache.hadoop.chukwa.Chunk;
25
26
27
28
29
30 public class RecordUtil {
31 static Pattern clusterPattern = Pattern
32 .compile("(.*)?cluster=\"(.*?)\"(.*)?");
33
34 public static String getClusterName(Record record) {
35 String tags = record.getValue(Record.tagsField);
36 if (tags != null) {
37 Matcher matcher = clusterPattern.matcher(tags);
38 if (matcher.matches()) {
39 return matcher.group(2);
40 }
41 }
42
43 return "undefined";
44 }
45
46
47
48
49
50 public static String getClusterName(Chunk chunk) {
51 String tags = chunk.getTags();
52 if (tags != null) {
53 Matcher matcher = clusterPattern.matcher(tags);
54 if (matcher.matches()) {
55 return matcher.group(2);
56 }
57 }
58
59 return "undefined";
60 }
61
62
63 }