public class TCADMaaPSubscriberWorker
extends co.cask.cdap.api.worker.AbstractWorker
Constructor and Description |
---|
TCADMaaPSubscriberWorker(String tcaSubscriberOutputStreamName) |
Modifier and Type | Method and Description |
---|---|
void |
configure() |
void |
initialize(co.cask.cdap.api.worker.WorkerContext context) |
void |
run() |
void |
stop() |
configure, destroy, getConfigurer, getContext, setDescription, setInstances, setName, setProperties, setResources
usePlugin, usePlugin, usePluginClass, usePluginClass
public TCADMaaPSubscriberWorker(String tcaSubscriberOutputStreamName)
public void configure()
configure
in class co.cask.cdap.api.worker.AbstractWorker
public void initialize(co.cask.cdap.api.worker.WorkerContext context) throws Exception
initialize
in interface co.cask.cdap.api.ProgramLifecycle<co.cask.cdap.api.worker.WorkerContext>
initialize
in class co.cask.cdap.api.worker.AbstractWorker
Exception
public void run()
public void stop()
stop
in interface co.cask.cdap.api.worker.Worker
stop
in class co.cask.cdap.api.worker.AbstractWorker
Copyright © 2017. All rights reserved.