public class EsBolt
extends java.lang.Object
implements backtype.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(backtype.storm.topology.OutputFieldsDeclarer declarer) |
void |
execute(backtype.storm.tuple.Tuple input) |
java.util.Map<java.lang.String,java.lang.Object> |
getComponentConfiguration() |
void |
prepare(java.util.Map conf,
backtype.storm.task.TopologyContext context,
backtype.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,
backtype.storm.task.TopologyContext context,
backtype.storm.task.OutputCollector collector)
prepare in interface backtype.storm.task.IBoltpublic void execute(backtype.storm.tuple.Tuple input)
execute in interface backtype.storm.task.IBoltpublic void cleanup()
cleanup in interface backtype.storm.task.IBoltpublic void declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer)
declareOutputFields in interface backtype.storm.topology.IComponentpublic java.util.Map<java.lang.String,java.lang.Object> getComponentConfiguration()
getComponentConfiguration in interface backtype.storm.topology.IComponent