5e4c937e3479a09b7a21cd5176b7b2ebdd6c8287 - eagle

commit	5e4c937e3479a09b7a21cd5176b7b2ebdd6c8287	[log] [tgz]
author	Zhao, Qingwen <qingwzhao@apache.org>	Wed Jan 25 12:21:01 2017 +0800
committer	Zhao, Qingwen <qingwzhao@apache.org>	Wed Jan 25 12:21:01 2017 +0800
tree	2f1e820c10e800f919845bfc9b4722024cc0e72a
parent	031835c772a87f1ca5228a409b21145caad79ff4 [diff]

[EAGLE-882] Stream leaf RunningQueueAPIEntity into Kafka for queue monitoring

https://issues.apache.org/jira/browse/EAGLE-882

Author: Zhao, Qingwen <qingwzhao@apache.org>

Closes #793 from qingwen220/EAGLE-882.

eagle-jpm/eagle-hadoop-queue/src/main/java/org/apache/eagle/hadoop/queue/HadoopQueueRunningApp.java[diff]
eagle-jpm/eagle-hadoop-queue/src/main/java/org/apache/eagle/hadoop/queue/HadoopQueueRunningAppConfig.java[diff]
eagle-jpm/eagle-hadoop-queue/src/main/java/org/apache/eagle/hadoop/queue/common/HadoopClusterConstants.java[diff]
eagle-jpm/eagle-hadoop-queue/src/main/java/org/apache/eagle/hadoop/queue/crawler/SchedulerInfoParseListener.java[diff]
eagle-jpm/eagle-hadoop-queue/src/main/java/org/apache/eagle/hadoop/queue/model/scheduler/RunningQueueAPIEntity.java[diff]
eagle-jpm/eagle-hadoop-queue/src/main/java/org/apache/eagle/hadoop/queue/model/scheduler/UserWrapper.java[diff]
eagle-jpm/eagle-hadoop-queue/src/main/java/org/apache/eagle/hadoop/queue/model/scheduler/UserWrappers.java[Added - diff]
eagle-jpm/eagle-hadoop-queue/src/main/java/org/apache/eagle/hadoop/queue/storm/HadoopQueueMetricPersistBolt.java[diff]
eagle-jpm/eagle-hadoop-queue/src/main/resources/META-INF/providers/org.apache.eagle.hadoop.queue.HadoopQueueRunningAppProvider.xml[diff]
eagle-jpm/eagle-hadoop-queue/src/main/resources/application.conf[diff]
eagle-jpm/eagle-hadoop-queue/src/test/java/org/apache/eagle/hadoop/queue/HadoopQueueRunningAppTest.java[diff]
eagle-jpm/eagle-hadoop-queue/src/test/resources/application.conf[diff]

12 files changed

tree: 2f1e820c10e800f919845bfc9b4722024cc0e72a