public class EsBolt extends Object implements backtype.storm.topology.IRichBolt
| Constructor and Description |
|---|
EsBolt(String target) |
EsBolt(String target,
boolean writeAck) |
EsBolt(String target,
Map configuration) |
| Modifier and Type | Method and Description |
|---|---|
void |
cleanup() |
void |
declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer) |
void |
execute(backtype.storm.tuple.Tuple input) |
Map<String,Object> |
getComponentConfiguration() |
void |
prepare(Map conf,
backtype.storm.task.TopologyContext context,
backtype.storm.task.OutputCollector collector) |
public EsBolt(String target)
public EsBolt(String target, boolean writeAck)
public void prepare(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.IComponent