1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.chukwa.inputtools.hdfsusage;
20
21 import java.util.Date;
22 import java.util.HashMap;
23
24 import org.apache.hadoop.chukwa.inputtools.jplugin.ChukwaMetrics;
25
26 public class HDFSUsageMetrics implements ChukwaMetrics {
27 private String name = null;
28
29 private Long size;
30 private long lastModified;
31
32 @Override
33 public String getKey() {
34 return getName();
35 }
36
37 public void setName(String name) {
38 this.name = name;
39 }
40
41 public String getName() {
42 return name;
43 }
44
45 public void setSize(Long size) {
46 this.size = size;
47 }
48
49 public Long getSize() {
50 return size;
51 }
52
53 @Override
54 public HashMap<String, String> getAttributes() {
55 HashMap<String, String> attr = new HashMap<String, String>();
56 attr.put("user", name);
57 attr.put("bytes", size.toString());
58 attr.put("timestamp", new Date().getTime() + "");
59 return attr;
60 }
61
62 public void setLastModified(long lastModified) {
63 this.lastModified = lastModified;
64 }
65
66 public long getLastModified() {
67 return lastModified;
68 }
69 }