org.openecomp.dcae.apod.analytics.tca.flowlet

Class TCAVESAlertsSinkFlowlet

java.lang.Object

co.cask.cdap.internal.api.AbstractProgramDatasetConfigurable<co.cask.cdap.api.flow.flowlet.FlowletConfigurer>

co.cask.cdap.api.flow.flowlet.AbstractFlowlet

org.openecomp.dcae.apod.analytics.tca.flowlet.TCAVESAlertsSinkFlowlet

All Implemented Interfaces:

co.cask.cdap.api.flow.flowlet.Callback, co.cask.cdap.api.flow.flowlet.Flowlet, co.cask.cdap.api.ProgramLifecycle<co.cask.cdap.api.flow.flowlet.FlowletContext>

public class TCAVESAlertsSinkFlowlet
extends co.cask.cdap.api.flow.flowlet.AbstractFlowlet

Saves TCA VES Alert Messages in a Time series Table

Author:

Rajiv Singla. Creation Date: 11/15/2016.

Constructor Summary

Constructors

Constructor and Description
TCAVESAlertsSinkFlowlet(String tcaVESAlertsTableName)

Method Summary

Modifier and Type	Method and Description
void	configure()
void	initialize(co.cask.cdap.api.flow.flowlet.FlowletContext flowletContext)
void	saveAlerts(String alertMessage)

Methods inherited from class co.cask.cdap.api.flow.flowlet.AbstractFlowlet

configure, destroy, getConfigurer, getContext, onFailure, onSuccess, setDescription, setFailurePolicy, setName, setProperties, setResources, useDatasets, useDatasets

Methods inherited from class co.cask.cdap.internal.api.AbstractProgramDatasetConfigurable

addDatasetModule, addDatasetType, addStream, addStream, createDataset, createDataset, createDataset, createDataset

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TCAVESAlertsSinkFlowlet

public TCAVESAlertsSinkFlowlet(String tcaVESAlertsTableName)

Method Detail

configure

public void configure()

Overrides:

configure in class co.cask.cdap.api.flow.flowlet.AbstractFlowlet

initialize

public void initialize(co.cask.cdap.api.flow.flowlet.FlowletContext flowletContext)
                throws Exception

Specified by:

initialize in interface co.cask.cdap.api.flow.flowlet.Flowlet

Specified by:

initialize in interface co.cask.cdap.api.ProgramLifecycle<co.cask.cdap.api.flow.flowlet.FlowletContext>

Overrides:

initialize in class co.cask.cdap.api.flow.flowlet.AbstractFlowlet

Throws:

Exception

saveAlerts

public void saveAlerts(String alertMessage)