[
https://issues.apache.org/jira/browse/AMBARI-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16075272#comment-16075272
]
Hudson commented on AMBARI-10145:
---------------------------------
SUCCESS: Integrated in Jenkins build Ambari-branch-2.5 #1656 (See
[https://builds.apache.org/job/Ambari-branch-2.5/1656/])
AMBARI-10145 : Add support for tee to another Storage service in Ambari
(avijayan:
[http://git-wip-us.apache.org/repos/asf?p=ambari.git&a=commit&h=b3ec9aab4a3cc8ef2899b5f6fb8347cda7438344])
* (add)
ambari-metrics/ambari-metrics-timelineservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TimelineMetricsAggregatorSink.java
* (edit)
ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/PhoenixHBaseAccessorTest.java
* (add)
ambari-metrics/ambari-metrics-timelineservice/src/test/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TimelineMetricsAggregatorMemorySink.java
* (edit)
ambari-metrics/ambari-metrics-timelineservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/TimelineMetricConfiguration.java
* (edit)
ambari-metrics/ambari-metrics-timelineservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/PhoenixHBaseAccessor.java
> Add support for tee to another Storage service in Ambari Metrics System
> -----------------------------------------------------------------------
>
> Key: AMBARI-10145
> URL: https://issues.apache.org/jira/browse/AMBARI-10145
> Project: Ambari
> Issue Type: Task
> Components: ambari-metrics
> Affects Versions: 2.1.0
> Reporter: Siddharth Wagle
> Assignee: Jameel Naina Mohamed
> Attachments: AMBARI-10145.patch
>
>
> AMS should provide extension to drain metrics to other sources.
> Proposal:
> In PhoenixHBaseAccessor add support to drain aggregated metrics to
> additional sinks apart from writing to HBase. This change required
> introducing new config to register a class which drain metrics. Here is the
> proposed sink interface
> {code:java}
> public interface TimelineMetricsAggregatorSink {
> public void saveHostAggregateRecords(Map<TimelineMetric,
> MetricHostAggregate> hostAggregateMap,
> String tableName);
>
> public void saveClusterTimeAggregateRecords(Map<TimelineClusterMetric,
> MetricHostAggregate> records,
> String tableName) ;
>
> public void saveClusterAggregateRecords(Map<TimelineClusterMetric,
> MetricClusterAggregate> records) ;
> }
> {code}
> new config: timeline.metrics.service.aggregator.sink.class
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
