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
['"[email protected]" <[email protected]>'].
