Add support for ABATED alerts within CDAP TCA

[dcaegen2/analytics/tca.git] / dcae-analytics-cdap-tca / src / main / java / org / openecomp / dcae / apod / analytics / cdap / tca / TCAAnalyticsApplication.java

diff --git a/dcae-analytics-cdap-tca/src/main/java/org/openecomp/dcae/apod/analytics/cdap/tca/TCAAnalyticsApplication.java b/dcae-analytics-cdap-tca/src/main/java/org/openecomp/dcae/apod/analytics/cdap/tca/TCAAnalyticsApplication.java
index 1a8cb5e..8c634a7 100644 (file)
--- a/dcae-analytics-cdap-tca/src/main/java/org/openecomp/dcae/apod/analytics/cdap/tca/TCAAnalyticsApplication.java
+++ b/dcae-analytics-cdap-tca/src/main/java/org/openecomp/dcae/apod/analytics/cdap/tca/TCAAnalyticsApplication.java
@@ -25,6 +25,7 @@ import co.cask.cdap.api.data.stream.Stream;
 import co.cask.cdap.api.dataset.DatasetProperties;
 import co.cask.cdap.api.dataset.lib.ObjectMappedTable;
 import org.openecomp.dcae.apod.analytics.cdap.common.CDAPComponentsConstants;
+import org.openecomp.dcae.apod.analytics.cdap.common.persistance.tca.TCAAlertsAbatementPersister;
 import org.openecomp.dcae.apod.analytics.cdap.common.persistance.tca.TCAMessageStatusPersister;
 import org.openecomp.dcae.apod.analytics.cdap.common.persistance.tca.TCAVESAlertsPersister;
 import org.openecomp.dcae.apod.analytics.cdap.common.utils.ValidationUtils;
@@ -79,6 +80,16 @@ public class TCAAnalyticsApplication extends AbstractApplication<TCAAppConfig> {
                 TCAMessageStatusPersister.getDatasetProperties(messageStatusTableTTLSeconds);
         createDataset(tcaVESMessageStatusTableName, ObjectMappedTable.class, messageStatusTableProperties);
 
+
+        // Create TCA Alerts Abatement Table
+        final String tcaAlertsAbatementTableName = tcaAppConfig.getTcaAlertsAbatementTableName();
+        final Integer tcaAlertsAbatementTableTTLSeconds = tcaAppConfig.getTcaAlertsAbatementTableTTLSeconds();
+        LOG.info("Creating Alerts Abatement Table: {} with TTL: {}",
+                tcaAlertsAbatementTableName, tcaAlertsAbatementTableTTLSeconds);
+        final DatasetProperties alertsAbatementTableProperties =
+                TCAAlertsAbatementPersister.getDatasetProperties(tcaAlertsAbatementTableTTLSeconds);
+        createDataset(tcaAlertsAbatementTableName, ObjectMappedTable.class, alertsAbatementTableProperties);
+
         // Create TCA VES Alerts Table
         final String tcaVESAlertsTableName = tcaAppConfig.getTcaVESAlertsTableName();
         final Integer alertsTableTTLSeconds = tcaAppConfig.getTcaVESAlertsTableTTLSeconds();