public class EsBolt
extends java.lang.Object
implements org.apache.storm.topology.IRichBolt
| Constructor and Description |
|---|
EsBolt(java.lang.String target) |
EsBolt(java.lang.String target,
boolean writeAck) |
EsBolt(java.lang.String target,
java.util.Map configuration) |
| Modifier and Type | Method and Description |
|---|---|
void |
cleanup() |
void |
declareOutputFields(org.apache.storm.topology.OutputFieldsDeclarer declarer) |
void |
execute(org.apache.storm.tuple.Tuple input) |
java.util.Map<java.lang.String,java.lang.Object> |
getComponentConfiguration() |
void |
prepare(java.util.Map conf,
org.apache.storm.task.TopologyContext context,
org.apache.storm.task.OutputCollector collector) |
public EsBolt(java.lang.String target)
public EsBolt(java.lang.String target,
boolean writeAck)
public EsBolt(java.lang.String target,
java.util.Map configuration)
public void prepare(java.util.Map conf,
org.apache.storm.task.TopologyContext context,
org.apache.storm.task.OutputCollector collector)
prepare in interface org.apache.storm.task.IBoltpublic void execute(org.apache.storm.tuple.Tuple input)
execute in interface org.apache.storm.task.IBoltpublic void cleanup()
cleanup in interface org.apache.storm.task.IBoltpublic void declareOutputFields(org.apache.storm.topology.OutputFieldsDeclarer declarer)
declareOutputFields in interface org.apache.storm.topology.IComponentpublic java.util.Map<java.lang.String,java.lang.Object> getComponentConfiguration()
getComponentConfiguration in interface org.apache.storm.topology.IComponent