public class BaseWorkerHook extends Object implements IWorkerHook, Serializable
A BaseWorkerHook is a noop implementation of IWorkerHook. You may extends this class and implement any and/or all methods you need for your workers.
| Constructor and Description |
|---|
BaseWorkerHook() |
| Modifier and Type | Method and Description |
|---|---|
void |
shutdown()
This method is called right before a worker shuts down.
|
void |
start(Map<String,Object> topoConf,
WorkerTopologyContext context)
This method is called when a worker is started.
|
public void start(Map<String,Object> topoConf, WorkerTopologyContext context)
This method is called when a worker is started.
start in interface IWorkerHooktopoConf - The Storm configuration for this workercontext - This object can be used to get information about this worker’s place within the topologypublic void shutdown()
This method is called right before a worker shuts down.
shutdown in interface IWorkerHookCopyright © 2021 The Apache Software Foundation. All rights reserved.