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

Class TCAVESMessageRouterFlowlet

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

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

TCA Message Router Flowlet emits VES Message to TCAVESThresholdViolationCalculatorFlowlet instances

Author:

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

Constructor Summary

Constructors

Constructor and Description
TCAVESMessageRouterFlowlet()

Method Summary

Modifier and Type	Method and Description
void	configure()
void	routeVESMessage(co.cask.cdap.api.flow.flowlet.StreamEvent vesMessageStreamEvent)

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

configure, destroy, getConfigurer, getContext, initialize, 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

TCAVESMessageRouterFlowlet

public TCAVESMessageRouterFlowlet()

Method Detail

configure

public void configure()

Overrides:

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

routeVESMessage

public void routeVESMessage(co.cask.cdap.api.flow.flowlet.StreamEvent vesMessageStreamEvent)