Review Board 1.7.22


FLUME-1482: Flume should expose metrics by HTTP.

Review Request #6567 - Created Aug. 13, 2012 and submitted

Hari Shreedharan
FLUME-1482
Reviewers
Flume
flume-git
Support for expose metrics by HTTP. Refactored Ganglia metrics to move the JMX polling code to a util to be reused by JSON server as well.
Added unit tests for JSON server and JMX polling code.
pom.xml
Revision 8c67610 New Change
[20] 674 lines
[+20]
675
        <groupId>org.mortbay.jetty</groupId>
675
        <groupId>org.mortbay.jetty</groupId>
676
        <artifactId>servlet-api</artifactId>
676
        <artifactId>servlet-api</artifactId>
677
        <version>2.5-20110124</version>
677
        <version>2.5-20110124</version>
678
      </dependency>
678
      </dependency>
679

    
   
679

   

    
   
680
      <!--  Gson: Java to Json conversion -->

    
   
681
      <dependency>

    
   
682
        <groupId>com.google.code.gson</groupId>

    
   
683
        <artifactId>gson</artifactId>

    
   
684
        <version>2.2.2</version>

    
   
685
      </dependency>

    
   
686

   
680
      <dependency>
687
      <dependency>
681
        <groupId>org.apache.hadoop</groupId>
688
        <groupId>org.apache.hadoop</groupId>
682
        <artifactId>hadoop-common</artifactId>
689
        <artifactId>hadoop-common</artifactId>
683
        <version>${hadoop.version}</version>
690
        <version>${hadoop.version}</version>
684
      </dependency>
691
      </dependency>
[+20] [20] 214 lines
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FileChannel.java
Revision cc8f89a New Change
 
flume-ng-core/pom.xml
Revision 8dd0d3e New Change
 
flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java
Revision 65b0166 New Change
 
flume-ng-core/src/main/java/org/apache/flume/channel/PseudoTxnMemoryChannel.java
Revision 489d3e5 New Change
 
flume-ng-core/src/main/java/org/apache/flume/instrumentation/ChannelCounter.java
Revision 316384a New Change
 
flume-ng-core/src/main/java/org/apache/flume/instrumentation/ChannelCounterMBean.java
Revision 799dd5d New Change
 
flume-ng-core/src/main/java/org/apache/flume/instrumentation/GangliaServer.java
Revision d93cd33 New Change
 
flume-ng-core/src/main/java/org/apache/flume/instrumentation/MonitoredCounterGroup.java
Revision a03d004 New Change
 
flume-ng-core/src/main/java/org/apache/flume/instrumentation/MonitoringType.java
Revision d132995 New Change
 
flume-ng-core/src/main/java/org/apache/flume/instrumentation/SinkCounterMBean.java
Revision 6905d49 New Change
 
flume-ng-core/src/main/java/org/apache/flume/instrumentation/SourceCounterMBean.java
Revision e6612d5 New Change
 
flume-ng-core/src/main/java/org/apache/flume/instrumentation/http/HTTPMetricsServer.java
New File
 
flume-ng-core/src/main/java/org/apache/flume/instrumentation/util/JMXPollUtil.java
New File
 
flume-ng-core/src/test/java/org/apache/flume/instrumentation/http/TestHTTPMetricsServer.java
New File
 
flume-ng-core/src/test/java/org/apache/flume/instrumentation/util/JMXTestUtils.java
New File
 
flume-ng-core/src/test/java/org/apache/flume/instrumentation/util/TestJMXPollUtil.java
New File
 
flume-ng-doc/sphinx/FlumeUserGuide.rst
Revision 45dd7cc New Change
 
  1. pom.xml: Loading...
  2. flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FileChannel.java: Loading...
  3. flume-ng-core/pom.xml: Loading...
  4. flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java: Loading...
  5. flume-ng-core/src/main/java/org/apache/flume/channel/PseudoTxnMemoryChannel.java: Loading...
  6. flume-ng-core/src/main/java/org/apache/flume/instrumentation/ChannelCounter.java: Loading...
  7. flume-ng-core/src/main/java/org/apache/flume/instrumentation/ChannelCounterMBean.java: Loading...
  8. flume-ng-core/src/main/java/org/apache/flume/instrumentation/GangliaServer.java: Loading...
  9. flume-ng-core/src/main/java/org/apache/flume/instrumentation/MonitoredCounterGroup.java: Loading...
  10. flume-ng-core/src/main/java/org/apache/flume/instrumentation/MonitoringType.java: Loading...
  11. flume-ng-core/src/main/java/org/apache/flume/instrumentation/SinkCounterMBean.java: Loading...
  12. flume-ng-core/src/main/java/org/apache/flume/instrumentation/SourceCounterMBean.java: Loading...
  13. flume-ng-core/src/main/java/org/apache/flume/instrumentation/http/HTTPMetricsServer.java: Loading...
  14. flume-ng-core/src/main/java/org/apache/flume/instrumentation/util/JMXPollUtil.java: Loading...
  15. flume-ng-core/src/test/java/org/apache/flume/instrumentation/http/TestHTTPMetricsServer.java: Loading...
  16. flume-ng-core/src/test/java/org/apache/flume/instrumentation/util/JMXTestUtils.java: Loading...
  17. flume-ng-core/src/test/java/org/apache/flume/instrumentation/util/TestJMXPollUtil.java: Loading...
  18. flume-ng-doc/sphinx/FlumeUserGuide.rst: Loading...