1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.hadoop.chukwa.inputtools.plugin.pbsnode;
19
20
21 import org.apache.commons.logging.Log;
22 import org.apache.commons.logging.LogFactory;
23 import org.apache.hadoop.chukwa.inputtools.mdl.DataConfig;
24 import org.apache.hadoop.chukwa.inputtools.plugin.ExecPlugin;
25 import org.apache.hadoop.chukwa.inputtools.plugin.IPlugin;
26 import org.json.simple.JSONObject;
27
28 public class PbsNodePlugin extends ExecPlugin {
29 private static Log log = LogFactory.getLog(PbsNodePlugin.class);
30 private String cmde = null;
31 private DataConfig dataConfig = null;
32
33 public PbsNodePlugin() {
34 dataConfig = new DataConfig();
35 cmde = dataConfig.get("chukwa.inputtools.plugin.pbsNode.cmde");
36 }
37
38 @Override
39 public String getCmde() {
40 return cmde;
41 }
42
43 public static void main(String[] args) {
44 IPlugin plugin = new PbsNodePlugin();
45 JSONObject result = plugin.execute();
46 System.out.print("Result: " + result);
47
48 if ((Integer) result.get("status") < 0) {
49 System.out.println("Error");
50 log.warn("[ChukwaError]:" + PbsNodePlugin.class + ", "
51 + result.get("stderr"));
52 } else {
53 log.info(result.get("stdout"));
54 }
55 }
56 }