public class EsSpout extends Object implements backtype.storm.topology.IRichSpout
| Constructor and Description |
|---|
EsSpout(String target) |
EsSpout(String target,
String query) |
EsSpout(String target,
String query,
Map configuration) |
| Modifier and Type | Method and Description |
|---|---|
void |
ack(Object msgId) |
void |
activate() |
void |
close() |
void |
deactivate() |
void |
declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer) |
void |
fail(Object msgId) |
Map<String,Object> |
getComponentConfiguration() |
void |
nextTuple() |
void |
open(Map conf,
backtype.storm.task.TopologyContext context,
backtype.storm.spout.SpoutOutputCollector collector) |
public EsSpout(String target)
public void open(Map conf, backtype.storm.task.TopologyContext context, backtype.storm.spout.SpoutOutputCollector collector)
open in interface backtype.storm.spout.ISpoutpublic void close()
close in interface backtype.storm.spout.ISpoutpublic void activate()
activate in interface backtype.storm.spout.ISpoutpublic void deactivate()
deactivate in interface backtype.storm.spout.ISpoutpublic void nextTuple()
nextTuple in interface backtype.storm.spout.ISpoutpublic void ack(Object msgId)
ack in interface backtype.storm.spout.ISpoutpublic void fail(Object msgId)
fail in interface backtype.storm.spout.ISpoutpublic void declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer)
declareOutputFields in interface backtype.storm.topology.IComponent