co.cask.cdap.etl.mock.alert

Class TMSAlertPublisher

java.lang.Object

co.cask.cdap.etl.api.AlertPublisher

co.cask.cdap.etl.mock.alert.TMSAlertPublisher

All Implemented Interfaces:

Destroyable, PipelineConfigurable, StageLifecycle<AlertPublisherContext>

public class TMSAlertPublisher
extends AlertPublisher

Publishes alerts to TMS.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TMSAlertPublisher.Conf Plugin conf.

Field Summary

Fields

Modifier and Type	Field and Description
static String	NAME
static PluginClass	PLUGIN_CLASS

Fields inherited from class co.cask.cdap.etl.api.AlertPublisher

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
TMSAlertPublisher(TMSAlertPublisher.Conf conf)

Method Summary

Modifier and Type	Method and Description
static ETLPlugin	getPlugin(String topic, String namespace)
void	initialize(AlertPublisherContext context)
void	publish(Iterator<Alert> alerts)

Methods inherited from class co.cask.cdap.etl.api.AlertPublisher

configurePipeline, destroy, getContext

Methods inherited from class java.lang.Object

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

Field Detail

PLUGIN_CLASS

public static final PluginClass PLUGIN_CLASS

NAME

public static final String NAME

See Also:

Constant Field Values

Constructor Detail

TMSAlertPublisher

public TMSAlertPublisher(TMSAlertPublisher.Conf conf)

Method Detail

initialize

public void initialize(AlertPublisherContext context)
                throws Exception

Specified by:

initialize in interface StageLifecycle<AlertPublisherContext>

Overrides:

initialize in class AlertPublisher

Throws:

Exception

publish

public void publish(Iterator<Alert> alerts)
             throws Exception

Specified by:

publish in class AlertPublisher

Throws:

Exception

getPlugin

public static ETLPlugin getPlugin(String topic,
                                  String namespace)