chukwa-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ey...@apache.org
Subject svn commit: r784220 - /hadoop/chukwa/trunk/conf/aggregator.sql
Date Fri, 12 Jun 2009 17:52:09 GMT
Author: eyang
Date: Fri Jun 12 17:52:08 2009
New Revision: 784220

URL: http://svn.apache.org/viewvc?rev=784220&view=rev
Log:
CHUKWA-253. Fixed group by condition in the SQL statement. (Eric Yang)

Modified:
    hadoop/chukwa/trunk/conf/aggregator.sql

Modified: hadoop/chukwa/trunk/conf/aggregator.sql
URL: http://svn.apache.org/viewvc/hadoop/chukwa/trunk/conf/aggregator.sql?rev=784220&r1=784219&r2=784220&view=diff
==============================================================================
--- hadoop/chukwa/trunk/conf/aggregator.sql (original)
+++ hadoop/chukwa/trunk/conf/aggregator.sql Fri Jun 12 17:52:08 2009
@@ -124,7 +124,7 @@
 replace into [mr_job_conf_year] (select * from [mr_job_conf_week] where ts between '[past_15_minutes]'
and '[now]');
 replace into [mr_job_conf_decade] (select * from [mr_job_conf_week] where ts between '[past_15_minutes]'
and '[now]');
 
-replace into [user_job_summary_month] (select FLOOR(UNIX_TIMESTAMP(timestamp)/300),userid,
sum(totalJobs), sum(dataLocalMaps), sum(rackLoaclMaps), sum(removeMaps), sum(mapInputBytes),
sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces)
from [user_job_summary_week] where ts between '[past_15_minutes]' and '[now]') group by FLOOR(UNIX_TIMESTAMP(timestamp)/300),userid);
-replace into [user_job_summary_quarter] (select FLOOR(UNIX_TIMESTAMP(timestamp)/1800),userid,
sum(totalJobs), sum(dataLocalMaps), sum(rackLoaclMaps), sum(removeMaps), sum(mapInputBytes),
sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces)
from [user_job_summary_week] where ts between '[past_90_minutes]' and '[now]') group by FLOOR(UNIX_TIMESTAMP(timestamp)/1800),userid);
-replace into [user_job_summary_year] (select FLOOR(UNIX_TIMESTAMP(timestamp)/10800),userid,
sum(totalJobs), sum(dataLocalMaps), sum(rackLoaclMaps), sum(removeMaps), sum(mapInputBytes),
sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces)
from [user_job_summary_week] where ts between '[past_540_minutes]' and '[now]') group by FLOOR(UNIX_TIMESTAMP(timestamp)/10800),userid);
-replace into [user_job_summary_decade] (select FLOOR(UNIX_TIMESTAMP(timestamp)/43200),userid,
sum(totalJobs), sum(dataLocalMaps), sum(rackLoaclMaps), sum(removeMaps), sum(mapInputBytes),
sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces)
from [user_job_summary_week] where ts between '[past_2160_minutes]' and '[now]') group by
FLOOR(UNIX_TIMESTAMP(timestamp)/43200),userid);
+replace into [user_job_summary_month] (select FLOOR(UNIX_TIMESTAMP(timestamp)/300),userid,
sum(totalJobs), sum(dataLocalMaps), sum(rackLoaclMaps), sum(removeMaps), sum(mapInputBytes),
sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces)
from [user_job_summary_week] where ts between '[past_15_minutes]' and '[now]') group by FLOOR(UNIX_TIMESTAMP(timestamp)/300)),userid;
+replace into [user_job_summary_quarter] (select FLOOR(UNIX_TIMESTAMP(timestamp)/1800),userid,
sum(totalJobs), sum(dataLocalMaps), sum(rackLoaclMaps), sum(removeMaps), sum(mapInputBytes),
sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces)
from [user_job_summary_week] where ts between '[past_90_minutes]' and '[now]') group by FLOOR(UNIX_TIMESTAMP(timestamp)/1800)),userid;
+replace into [user_job_summary_year] (select FLOOR(UNIX_TIMESTAMP(timestamp)/10800),userid,
sum(totalJobs), sum(dataLocalMaps), sum(rackLoaclMaps), sum(removeMaps), sum(mapInputBytes),
sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces)
from [user_job_summary_week] where ts between '[past_540_minutes]' and '[now]') group by FLOOR(UNIX_TIMESTAMP(timestamp)/10800)),userid;
+replace into [user_job_summary_decade] (select FLOOR(UNIX_TIMESTAMP(timestamp)/43200),userid,
sum(totalJobs), sum(dataLocalMaps), sum(rackLoaclMaps), sum(removeMaps), sum(mapInputBytes),
sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces)
from [user_job_summary_week] where ts between '[past_2160_minutes]' and '[now]') group by
FLOOR(UNIX_TIMESTAMP(timestamp)/43200)),userid;



Mime
View raw message