chukwa-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ey...@apache.org
Subject svn commit: r784921 - in /hadoop/chukwa: branches/chukwa-0.2/conf/aggregator.sql trunk/conf/aggregator.sql
Date Mon, 15 Jun 2009 19:08:05 GMT
Author: eyang
Date: Mon Jun 15 19:08:05 2009
New Revision: 784921

URL: http://svn.apache.org/viewvc?rev=784921&view=rev
Log:
CHUKWA-253. Updated SQL statement with proper column names and brackets. (Cheng Zhang via
Eric Yang)

Modified:
    hadoop/chukwa/branches/chukwa-0.2/conf/aggregator.sql
    hadoop/chukwa/trunk/conf/aggregator.sql

Modified: hadoop/chukwa/branches/chukwa-0.2/conf/aggregator.sql
URL: http://svn.apache.org/viewvc/hadoop/chukwa/branches/chukwa-0.2/conf/aggregator.sql?rev=784921&r1=784920&r2=784921&view=diff
==============================================================================
--- hadoop/chukwa/branches/chukwa-0.2/conf/aggregator.sql (original)
+++ hadoop/chukwa/branches/chukwa-0.2/conf/aggregator.sql Mon Jun 15 19:08:05 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(rackLocalMaps), sum(remoteMaps), sum(mapInputBytes),
sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces)
from [user_job_summary_week] where timestamp 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(rackLocalMaps), sum(remoteMaps), sum(mapInputBytes),
sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces)
from [user_job_summary_week] where timestamp 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(rackLocalMaps), sum(remoteMaps), sum(mapInputBytes),
sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces)
from [user_job_summary_week] where timestamp 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(rackLocalMaps), sum(remoteMaps), sum(mapInputBytes),
sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces)
from [user_job_summary_week] where timestamp between '[past_2160_minutes]' and '[now]' group
by FLOOR(UNIX_TIMESTAMP(timestamp)/43200),userid);

Modified: hadoop/chukwa/trunk/conf/aggregator.sql
URL: http://svn.apache.org/viewvc/hadoop/chukwa/trunk/conf/aggregator.sql?rev=784921&r1=784920&r2=784921&view=diff
==============================================================================
--- hadoop/chukwa/trunk/conf/aggregator.sql (original)
+++ hadoop/chukwa/trunk/conf/aggregator.sql Mon Jun 15 19:08:05 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(rackLocalMaps), sum(remoteMaps), sum(mapInputBytes),
sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces)
from [user_job_summary_week] where timestamp 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(rackLocalMaps), sum(remoteMaps), sum(mapInputBytes),
sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces)
from [user_job_summary_week] where timestamp 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(rackLocalMaps), sum(remoteMaps), sum(mapInputBytes),
sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces)
from [user_job_summary_week] where timestamp 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(rackLocalMaps), sum(remoteMaps), sum(mapInputBytes),
sum(reduceOutputRecords), sum(mapSlotHours), sum(reduceSlotHours), sum(totalMaps), sum(totalReduces)
from [user_job_summary_week] where timestamp between '[past_2160_minutes]' and '[now]' group
by FLOOR(UNIX_TIMESTAMP(timestamp)/43200),userid);



Mime
View raw message