Package org.apache.hadoop.chukwa.util

Examples of org.apache.hadoop.chukwa.util.DatabaseWriter.query()

92
93
94
95
96
97
98
99
100
101
102
  if (timestamp != null) {
      // get simple value
            try {
    String query = getSingleQuery(ClusterHadoopRpcHome.table,"timestamp",timestamp);
        ResultSet rs = dbw.query(query);
        if (rs.next()) {
        ClusterHadoopRpc obj = createClusterHadoopRpc(rs);
        return obj;
    }
      } catch (Exception e) {
View Full Code Here
121
122
123
124
125
126
127
128
129
130
131
    Map<String, String> criteriaMap = new HashMap<String,String>();
    criteriaMap.put("timestamp",convertLongToDateString(Long.parseLong(timestamp)));
    criteriaMap.put("host",host);

    String query = getCriteriaQuery(ClusterHadoopRpcHome.table,criteriaMap);
        ResultSet rs = dbw.query(query);
        if (rs.next()) {
        ClusterHadoopRpc obj = createClusterHadoopRpc(rs);
        return obj;
    }
      } catch (Exception e) {
View Full Code Here
146
147
148
149
150
151
152
153
154
155
156
  Collection<ClusterHadoopRpc> collection = new Vector<ClusterHadoopRpc>();

  try {
      String query = getTimeBetweenQuery(ClusterHadoopRpcHome.table,starttime,endtime);     
      ResultSet rs = dbw.query(query);
      while (rs.next()) {
    ClusterHadoopRpc obj = createClusterHadoopRpc(rs);
    collection.add(obj);
      }
  } catch (Exception e) {
View Full Code Here
26
27
28
29
30
31
32
33
34
35
36
           DatabaseWriter db = new DatabaseWriter(cluster);
           Calendar c = Calendar.getInstance();
           long now = c.getTimeInMillis();
           String[] tableName = dbc.findTableName("system_metrics", now, now);
           String query = "select unix_TIMESTAMP(now()) - unix_timestamp(max(timestamp)) as delay from "+tableName[0]+" ;";
           ResultSet rs = db.query(query);
           while(rs.next()) {
               long delay = rs.getLong(1);
               if(delay>600) {
                   log.error("Chukwa: "+cluster+": No new data for the past 30 minutes for system metrics");                  
                   error=true;
View Full Code Here
35
36
37
38
39
40
41
42
43
44
45
                   log.error("Chukwa: "+cluster+": No new data for the past 30 minutes for system metrics");                  
                   error=true;
               }
           }
           query = "select count(*) as UpdatesPerHr from "+tableName[0]+" where Timestamp > date_sub(now(), interval 60 minute) ;";
           rs = db.query(query);
           while(rs.next()) {
               updates = rs.getLong(1);
               if(updates==0) {
                   log.error("Chukwa: "+cluster+": No system metrics data received for the past 60 minutes");                  
                   error=true;
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
                   error=true;
               }
           }
           String[] hodTableNames = dbc.findTableName("HodJob", now, now);
           query = "select count(*) as UpdatesPerHr from "+hodTableNames[0]+" where StartTime > date_sub(now(), interval 60 minute) ;";
           rs = db.query(query);          
           while(rs.next()) {
               long updatesHod = rs.getLong(1);
               if(updatesHod==0) {
                   log.error("Chukwa: "+cluster+": No hod job data received for the past 60 minutes");
               }
View Full Code Here
54
55
56
57
58
59
60
61
62
63
64
                   log.error("Chukwa: "+cluster+": No hod job data received for the past 60 minutes");
               }
           }
           String[] mrTableNames = dbc.findTableName("mr_job", now, now);
           query = "select count(*) as UpdatesPerHr from "+mrTableNames+" where FINISH_TIME > date_sub(now(), interval 1440 minute) ;";
           rs = db.query(query);                     
           while(rs.next()) {
               long updatesMR = rs.getLong(1);
               if(updatesMR==0) {
                   log.error("MDL: no map reduce job data received for the past day.");
                   error=true;
View Full Code Here
68
69
70
71
72
73
74
75
76
77
78
  public void tearDown() {
    DatabaseWriter db = null;
    try {
      db = new DatabaseWriter(cluster);
      ResultSet rs = db.query("show tables");
      ArrayList<String> list = new ArrayList<String>();
      while(rs.next()) {
        String table = rs.getString(1);
        list.add(table);
      }
View Full Code Here
123
124
125
126
127
128
129
130
131
132
133
    for(int i=0;i<tables.length;i++) {
      String query = "select [avg("+tables[i]+")] from ["+tables[i]+"]";
      Macro mp = new Macro(current,query);
      query = mp.toString();
      try {
        ResultSet rs = db.query(query);
        ResultSetMetaData rsmd = rs.getMetaData();
        int numberOfColumns = rsmd.getColumnCount();
        while(rs.next()) {
          for(int j=1;j<=numberOfColumns;j++) {
            assertTrue("Table: "+tables[i]+", Column: "+rsmd.getColumnName(j)+", contains no data.",rs.getString(j)!=null);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.