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, wait
endExecute
public 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 Twister2StormNode
public Fields getOutFieldsForEdge(java.lang.String edge)
getOutFieldsForEdge
in interface Twister2StormNode
public void setKeyedOutEdges(java.lang.String edge, Fields keys)
setKeyedOutEdges
in interface Twister2StormNode
public void addInboundFieldsForEdge(java.lang.String edge, Fields fields)
public boolean execute(IMessage message)
ICompute
public void prepare(Config cfg, TaskContext context)
INode