public class Twister2Bolt extends java.lang.Object implements ICompute, Twister2StormNode
| Constructor and Description |
|---|
Twister2Bolt(java.lang.String id,
java.lang.Object bolt,
MadeASourceListener madeASourceListener) |
| Modifier and Type | Method and Description |
|---|---|
void |
addInboundFieldsForEdge(java.lang.String edge,
Fields fields) |
boolean |
execute(IMessage message)
Execute with an incoming message
|
Twister2BoltDeclarer |
getBoltDeclarer() |
java.lang.String |
getId() |
Fields |
getOutFieldsForEdge(java.lang.String edge) |
java.lang.Integer |
getParallelism() |
void |
prepare(Config cfg,
TaskContext context)
Prepare the task to be executed
|
void |
setKeyedOutEdges(java.lang.String edge,
Fields keys) |
void |
setParallelism(java.lang.Integer parallelism) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitendExecutepublic Twister2Bolt(java.lang.String id,
java.lang.Object bolt,
MadeASourceListener madeASourceListener)
public java.lang.Integer getParallelism()
public void setParallelism(java.lang.Integer parallelism)
public Twister2BoltDeclarer getBoltDeclarer()
public java.lang.String getId()
getId in interface Twister2StormNodepublic Fields getOutFieldsForEdge(java.lang.String edge)
getOutFieldsForEdge in interface Twister2StormNodepublic void setKeyedOutEdges(java.lang.String edge,
Fields keys)
setKeyedOutEdges in interface Twister2StormNodepublic void addInboundFieldsForEdge(java.lang.String edge,
Fields fields)
public boolean execute(IMessage message)
IComputepublic void prepare(Config cfg, TaskContext context)
INode