public class EsBolt extends Object implements 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(OutputFieldsDeclarer declarer) |
void |
execute(Tuple input) |
Map<String,Object> |
getComponentConfiguration() |
void |
prepare(Map conf,
TopologyContext context,
OutputCollector collector) |
public EsBolt(String target)
public EsBolt(String target, boolean writeAck)
public void prepare(Map conf, TopologyContext context, OutputCollector collector)
public void declareOutputFields(OutputFieldsDeclarer declarer)
declareOutputFields in interface IComponentpublic Map<String,Object> getComponentConfiguration()
getComponentConfiguration in interface IComponent