You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by av...@apache.org on 2018/01/13 06:07:03 UTC
[ambari] branch branch-feature-AMBARI-21105 updated (2129b39 ->
88fd9fb)
This is an automated email from the ASF dual-hosted git repository.
avijayan pushed a change to branch branch-feature-AMBARI-21105
in repository https://gitbox.apache.org/repos/asf/ambari.git.
from 2129b39 AMBARI-22607 : Design and implement an AD job scheduler. (avijayan)
add fea9c2c AMBARI-22769 : Point in Time Subsystem: Implement EMA Spark Streaming Driver (Initial work). (avijayan)
new 88fd9fb Merge pull request #96 from avijayanhwx/AMBARI-22769-branch-feature-AMBARI-21105
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../pom.xml | 8 +-
.../src/main/resources/hbase-site.xml | 521 ++++++++++-----------
.../metrics/adservice/detection/AdJobManager.scala | 12 +-
...Subsystem.scala => DetectionServiceUtils.scala} | 20 +-
.../detection/SparkApplicationRunner.scala | 3 +-
.../detection/pointintime/EmaAccumulator.scala | 85 ++++
.../EmaConstants.scala} | 10 +-
.../adservice/detection/pointintime/EmaModel.scala | 76 +++
.../detection/pointintime/EmaRunner.scala | 116 +++++
.../detection/pointintime/EmaSparkDriver.scala | 128 +++--
.../pointintime/PointInTimeSubsystem.scala | 13 +-
.../adservice/metadata/ADMetadataProvider.scala | 2 +-
.../metrics/adservice/metadata/MetricKey.scala | 4 +
.../ambari/metrics/adservice/model/Range.scala | 8 +
.../ambari/metrics/adservice/model/Season.scala | 12 +-
.../adservice/service/DetectionServiceImpl.scala | 6 +-
.../adservice/app/DefaultADResourceSpecTest.scala | 42 +-
.../adservice/app/DropwizardAppRuleHelper.scala | 5 +-
.../app/DropwizardResourceTestRuleHelper.scala | 8 +-
.../adservice/detection/TestEmaSparkDriver.scala | 48 ++
.../metrics/adservice/model/SeasonTest.scala | 28 ++
ambari-metrics/ambari-metrics-common/pom.xml | 8 +-
.../ambari-metrics-timelineservice/pom.xml | 7 +-
.../metrics/timeline/sink/KafkaSinkProvider.java | 51 +-
.../timeline/sink/MetricAppIdKafkaPartitioner.java | 78 +++
ambari-metrics/pom.xml | 4 +-
.../0.1.0/configuration/ams-admanager-config.xml | 2 +-
27 files changed, 938 insertions(+), 367 deletions(-)
copy ambari-metrics/ambari-metrics-anomaly-detection-service/src/main/scala/org/apache/ambari/metrics/adservice/detection/{Subsystem.scala => DetectionServiceUtils.scala} (56%)
create mode 100644 ambari-metrics/ambari-metrics-anomaly-detection-service/src/main/scala/org/apache/ambari/metrics/adservice/detection/pointintime/EmaAccumulator.scala
copy ambari-metrics/ambari-metrics-anomaly-detection-service/src/main/scala/org/apache/ambari/metrics/adservice/detection/{Subsystem.scala => pointintime/EmaConstants.scala} (72%)
create mode 100644 ambari-metrics/ambari-metrics-anomaly-detection-service/src/main/scala/org/apache/ambari/metrics/adservice/detection/pointintime/EmaModel.scala
create mode 100644 ambari-metrics/ambari-metrics-anomaly-detection-service/src/main/scala/org/apache/ambari/metrics/adservice/detection/pointintime/EmaRunner.scala
create mode 100644 ambari-metrics/ambari-metrics-anomaly-detection-service/src/test/scala/org/apache/ambari/metrics/adservice/detection/TestEmaSparkDriver.scala
create mode 100644 ambari-metrics/ambari-metrics-timelineservice/src/main/java/org/apache/hadoop/yarn/server/applicationhistoryservice/metrics/timeline/sink/MetricAppIdKafkaPartitioner.java
--
To stop receiving notification emails like this one, please contact
['"commits@ambari.apache.org" <co...@ambari.apache.org>'].
[ambari] 01/01: Merge pull request #96 from
avijayanhwx/AMBARI-22769-branch-feature-AMBARI-21105
Posted by av...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
avijayan pushed a commit to branch branch-feature-AMBARI-21105
in repository https://gitbox.apache.org/repos/asf/ambari.git
commit 88fd9fbf94dbc33abf9f810ce34044d603da81a6
Merge: 2129b39 fea9c2c
Author: avijayanhwx <av...@hortonworks.com>
AuthorDate: Fri Jan 12 22:06:57 2018 -0800
Merge pull request #96 from avijayanhwx/AMBARI-22769-branch-feature-AMBARI-21105
[AMBARI-22769] [ambari-metrics] Implement EMA Spark Streaming Driver (Initial work) (avijayan)
.../pom.xml | 8 +-
.../src/main/resources/hbase-site.xml | 521 ++++++++++-----------
.../metrics/adservice/detection/AdJobManager.scala | 12 +-
.../DetectionServiceUtils.scala} | 39 +-
.../detection/SparkApplicationRunner.scala | 3 +-
.../detection/pointintime/EmaAccumulator.scala | 85 ++++
.../pointintime/EmaConstants.scala} | 29 +-
.../adservice/detection/pointintime/EmaModel.scala | 76 +++
.../detection/pointintime/EmaRunner.scala | 116 +++++
.../detection/pointintime/EmaSparkDriver.scala | 128 +++--
.../pointintime/PointInTimeSubsystem.scala | 13 +-
.../adservice/metadata/ADMetadataProvider.scala | 2 +-
.../metrics/adservice/metadata/MetricKey.scala | 4 +
.../ambari/metrics/adservice/model/Range.scala | 8 +
.../ambari/metrics/adservice/model/Season.scala | 12 +-
.../adservice/service/DetectionServiceImpl.scala | 6 +-
.../adservice/app/DefaultADResourceSpecTest.scala | 42 +-
.../adservice/app/DropwizardAppRuleHelper.scala | 5 +-
.../app/DropwizardResourceTestRuleHelper.scala | 8 +-
.../adservice/detection/TestEmaSparkDriver.scala | 48 ++
.../metrics/adservice/model/SeasonTest.scala | 28 ++
ambari-metrics/ambari-metrics-common/pom.xml | 8 +-
.../ambari-metrics-timelineservice/pom.xml | 7 +-
.../metrics/timeline/sink/KafkaSinkProvider.java | 51 +-
.../timeline/sink/MetricAppIdKafkaPartitioner.java | 78 +++
ambari-metrics/pom.xml | 4 +-
.../0.1.0/configuration/ams-admanager-config.xml | 2 +-
27 files changed, 940 insertions(+), 403 deletions(-)
--
To stop receiving notification emails like this one, please contact
"commits@ambari.apache.org" <co...@ambari.apache.org>.