forked from tagomoris/shib
-
Notifications
You must be signed in to change notification settings - Fork 0
/
shib_query.js
44 lines (40 loc) · 1.14 KB
/
shib_query.js
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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
var config = {
hiveserver: {
host: 'localhost',
port: 10000
},
kyototycoon: {
host: 'localhost',
port: 1978
}
};
var querystring = "SELECT hhmm, (split(fullpath,'\/'))[1] AS blogname, count(userlabel) AS cnt " +
"FROM access_log WHERE service='blog' AND yyyymmdd='20110531' " +
"GROUP BY hhmm, blogname SORT BY cnt DESC limit 100";
var shib = require('shib');
shib.init(config);
var qid;
console.log("====== execute stage ======");
shib.client().createQuery(querystring, [], function(err, query){
console.log("queryid:" + query.queryid);
qid = query.queryid;
console.log(query);
this.execute(query);
});
setTimeout(function(){
console.log("====== display stage ======");
console.log("queryid:" + qid);
shib.client().getQuery(qid, function(err, query){
console.log(query);
this.status(query, function(status){
console.log("status:" + status);
});
this.getLastResult(query, function(err, result){
console.log(result);
this.rawResultData(result.resultid, function(err, data){
console.log("====== display stage ======");
console.log(data);
});
});
});
}, 3000);