import co.cask.cdap.api.flow.AbstractFlow;
import org.openecomp.dcae.apod.analytics.cdap.common.CDAPComponentsConstants;
+import org.openecomp.dcae.apod.analytics.cdap.tca.flowlet.TCAVESAlertsAbatementFlowlet;
import org.openecomp.dcae.apod.analytics.cdap.tca.flowlet.TCAVESAlertsSinkFlowlet;
import org.openecomp.dcae.apod.analytics.cdap.tca.flowlet.TCAVESMessageRouterFlowlet;
import org.openecomp.dcae.apod.analytics.cdap.tca.flowlet.TCAVESThresholdViolationCalculatorFlowlet;
new TCAVESThresholdViolationCalculatorFlowlet(tcaAppConfig.getTcaVESMessageStatusTableName());
addFlowlet(thresholdViolationCalculatorFlowlet, tcaAppConfig.getThresholdCalculatorFlowletInstances());
+ final TCAVESAlertsAbatementFlowlet tcavesAlertsAbatementFlowlet =
+ new TCAVESAlertsAbatementFlowlet(tcaAppConfig.getTcaAlertsAbatementTableName());
+ addFlowlet(tcavesAlertsAbatementFlowlet);
+
final TCAVESAlertsSinkFlowlet alertsSinkFlowlet =
new TCAVESAlertsSinkFlowlet(tcaAppConfig.getTcaVESAlertsTableName());
addFlowlet(alertsSinkFlowlet);
connectStream(tcaAppConfig.getTcaSubscriberOutputStreamName(), messageRouterFlowlet);
// connect message router to VES threshold calculator
connect(messageRouterFlowlet, thresholdViolationCalculatorFlowlet);
- // connect VES threshold calculator flowlet to Alerts Sink Flowlet
- connect(thresholdViolationCalculatorFlowlet, alertsSinkFlowlet);
+ // connect VES threshold calculator flowlet to Alerts Abatement Flowlet
+ connect(thresholdViolationCalculatorFlowlet, tcavesAlertsAbatementFlowlet);
+ // connect Alerts Abatement flowlet to Alerts Sink Flowlet
+ connect(tcavesAlertsAbatementFlowlet, alertsSinkFlowlet);
}
}