org.openecomp.dcae.apod.analytics.tca.worker

Class TCADMaaPPublisherWorker

java.lang.Object

co.cask.cdap.internal.api.AbstractProgramDatasetConfigurable

co.cask.cdap.internal.api.AbstractPluginConfigurable<co.cask.cdap.api.worker.WorkerConfigurer>

co.cask.cdap.api.worker.AbstractWorker

org.openecomp.dcae.apod.analytics.tca.worker.TCADMaaPPublisherWorker

All Implemented Interfaces:

co.cask.cdap.api.ProgramLifecycle<co.cask.cdap.api.worker.WorkerContext>, co.cask.cdap.api.worker.Worker, Runnable

public class TCADMaaPPublisherWorker
extends co.cask.cdap.api.worker.AbstractWorker

TCA DMaaP Publisher will monitor alerts table at regular intervals and publish any alerts to DMaaP MR Publishing Topic

Author:

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

Constructor Summary

Constructors

Constructor and Description
TCADMaaPPublisherWorker(String tcaVESAlertsTableName)

Method Summary

Modifier and Type	Method and Description
void	configure()
void	initialize(co.cask.cdap.api.worker.WorkerContext context)
void	run()
void	stop()

Methods inherited from class co.cask.cdap.api.worker.AbstractWorker

configure, destroy, getConfigurer, getContext, setDescription, setInstances, setName, setProperties, setResources

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

usePlugin, usePlugin, usePluginClass, usePluginClass

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

TCADMaaPPublisherWorker

public TCADMaaPPublisherWorker(String tcaVESAlertsTableName)

Method Detail

configure

public void configure()

Overrides:

configure in class co.cask.cdap.api.worker.AbstractWorker

initialize

public void initialize(co.cask.cdap.api.worker.WorkerContext context)
                throws Exception

Specified by:

initialize in interface co.cask.cdap.api.ProgramLifecycle<co.cask.cdap.api.worker.WorkerContext>

Overrides:

initialize in class co.cask.cdap.api.worker.AbstractWorker

Throws:

Exception

run

public void run()

stop

public void stop()

Specified by:

stop in interface co.cask.cdap.api.worker.Worker

Overrides:

stop in class co.cask.cdap.api.worker.AbstractWorker