svn commit: r751783 - /hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/reducer/SystemMetrics.java

[eyang]

Author: eyang
Date: Mon Mar  9 18:15:17 2009
New Revision: 751783

URL: http://svn.apache.org/viewvc?rev=751783&view=rev
Log:
HADOOP-5387. Collect number of disk read/write operation for system metrics.

Modified:
    
hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/reducer/SystemMetrics.java

Modified: 
hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/reducer/SystemMetrics.java
URL: 
http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/reducer/SystemMetrics.java?rev=751783&r1=751782&r2=751783&view=diff
==============================================================================
--- 
hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/reducer/SystemMetrics.java
 (original)
+++ 
hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/extraction/demux/processor/reducer/SystemMetrics.java
 Mon Mar  9 18:15:17 2009
@@ -81,9 +81,13 @@
                                }
                                
                                if(record.containsField("Device:")) {
+                                       
record.add(record.getValue("Device:")+".r/s", record.getValue("r/s"));
+                                       
record.add(record.getValue("Device:")+".w/s", record.getValue("w/s"));
                                        
record.add(record.getValue("Device:")+".rkB/s", record.getValue("rkB/s"));
                                        
record.add(record.getValue("Device:")+".wkB/s", record.getValue("wkB/s"));
                                        
record.add(record.getValue("Device:")+".%util", record.getValue("%util"));
+                                       record.removeValue("r/s");
+                                       record.removeValue("w/s");
                                        record.removeValue("rkB/s");
                                        record.removeValue("wkB/s");
                                        record.removeValue("%util");