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