AMBARI-22343. Add ability in AMS to tee metrics to a set of configured Kafka brokers...
authorSiddharth Wagle <swagle@hortonworks.com>
Tue, 31 Oct 2017 18:34:45 +0000 (11:34 -0700)
committeravijayanhwx <avijayan@hortonworks.com>
Sun, 1 Apr 2018 19:13:52 +0000 (12:13 -0700)
commitc95cc6ea998fc72db7070e990e677b8114533241
tree3afdf90797fbc4141e500305a269d5d7262ed5bd
parentc8cab48bc6c762a4f8ad4781df94b8d94c57b5a5
AMBARI-22343. Add ability in AMS to tee metrics to a set of configured Kafka brokers. (swagle)
ambari-metrics-anomaly-detection-service/pom.xml
ambari-metrics-anomaly-detection-service/src/main/resources/config.yml
ambari-metrics-timelineservice/pom.xml
ambari-metrics-timelineservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/PhoenixHBaseAccessor.java
ambari-metrics-timelineservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TimelineMetricConfiguration.java
ambari-metrics-timelineservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/sink/ExternalSinkProvider.java
ambari-metrics-timelineservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/sink/HttpSinkProvider.java
ambari-metrics-timelineservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/sink/KafkaSinkProvider.java [new file with mode: 0644]
ambari-metrics-timelineservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/source/DefaultInternalMetricsSourceProvider.java
ambari-metrics-timelineservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/source/RawMetricsSource.java