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

Class TCAVESThresholdViolationCalculatorFlowlet

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.TCAVESThresholdViolationCalculatorFlowlet

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 TCAVESThresholdViolationCalculatorFlowlet
extends co.cask.cdap.api.flow.flowlet.AbstractFlowlet

TCA VES Message Filter filters out messages which are not applicable for TCA as per TCA Policy

Author:

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

Constructor Summary

Constructors

Constructor and Description
TCAVESThresholdViolationCalculatorFlowlet(String messageStatusTableName)

Method Summary

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

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

TCAVESThresholdViolationCalculatorFlowlet

public TCAVESThresholdViolationCalculatorFlowlet(String messageStatusTableName)

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

filterVESMessages

public void filterVESMessages(String vesMessage)
                       throws com.fasterxml.jackson.core.JsonProcessingException

Throws:

com.fasterxml.jackson.core.JsonProcessingException